So implementieren Sie die Protokolldateiüberwachung und lesen zugehörige Daten in Java

Projektanforderungen

Da das Rechenzentrumsprojektteam die Anforderung der Überwachung von Ordnern oder Protokolldateien und des Lesens schmutziger Daten in entsprechenden Formaten umsetzen muss, um entsprechende Geschäftsprozesse durchzuführen, wenn sich Dateien und Ordner ändern, notieren Sie diese hier Technologieauswahl relevanter Unternehmen.

Apache Commons-IO

Zuerst müssen Sie die entsprechenden Abhängigkeiten hinzufügen:

<dependency>
 <groupId>commons-io</groupId>
 <artifactId>commons-io</artifactId>
 <version>2.7</version>
</dependency>

Die Version kann selbst ausgewählt werden. Hierbei ist zu beachten, dass Version 2.7 und höher Java 8 erfordert

Offizieller Website-Screenshot:

Apache Commos IO Das Paket org.apache.commons.io.monitor bietet Funktionen zur Dateisystemüberwachung. org.apache.commons.io.monitor包提供了文件系统监听的功能。

核心知识

• 一句话总结：通过观察者模式以及事件监听机制，以 FileAlterationObserver 为核心，再通过 FileAlterationListener，FileAlterationMonitor，就可以实现对文件系统的事件监听。

• 整体流程：

• 自定义文件监听类并继承 FileAlterationListenerAdaptor 实现对文件与目录的创建，修改，删除事件的处理

• 自定义文件监控类，通过指定目录创建一个观察者 FileAlterationObserver

• 向此监视器添加文件系统观察器，并添加文件监听器

• 通过 ApplicationRunner 或者 CommandLineRunner 调用并执行

代码实现

• 文件监听类：

/**
 * 文件监听类
 * @author Greenarrow
 * @date 2022-05-12 14:43
 **/
public class FileListener extends FileAlterationListenerAdaptor {

    private static Logger logger = LoggerFactory.getLogger(FileListener.class);
    @Override
    public void onStart(FileAlterationObserver observer) {
        super.onStart(observer);
        logger.info("onStart");
    }

    @Override
    public void onDirectoryCreate(File directory) {
        logger.info("[新建]:" + directory.getAbsolutePath());
    }

    @Override
    public void onDirectoryChange(File directory) {
        logger.info("[修改]:" + directory.getAbsolutePath());
    }

    @Override
    public void onDirectoryDelete(File directory) {
        logger.info("[删除]:" + directory.getAbsolutePath());
    }

    @Override
    public void onFileCreate(File file) {
        String compressedPath = file.getAbsolutePath();
        logger.info("[新建]:" + compressedPath);
        List<String> contentList = null;
        try {
            if (file.canRead()){
                // 将文件按行读取为字符串集合
                contentList = FileUtils.readLines(new File(compressedPath), StandardCharsets.UTF_8);
                if (CollectionUtil.isNotEmpty(contentList)){
                    // 获取对应格式的数据并输出，这里可自行添加业务处理
                    List<String> dirtyRecord  = contentList.stream().filter(s -> s.startsWith("{") && s.endsWith("}")).collect(Collectors.toList());
                    dirtyRecord.forEach(System.out::println);
                }
            }

        } catch (IOException e) {
            e.printStackTrace();
            logger.error("读取文件内容失败",e);
        }
    }

    @Override
    public void onFileChange(File file) {
        String compressedPath = file.getAbsolutePath();
        logger.info("[修改]:" + compressedPath);
    }

    @Override
    public void onFileDelete(File file) {
        logger.info("[删除]:" + file.getAbsolutePath());
    }

    @Override
    public void onStop(FileAlterationObserver observer) {
        super.onStop(observer);
        logger.info("onStop");
    }
}

• 文件监控类：

/**
 * 文件监听测试 demo
 * @author Greenarrow
 * @date 2022-05-12 14:45
 **/
public class FileMonitor {

    FileAlterationMonitor monitor = null;

    public FileMonitor(long interval) throws Exception {
        monitor = new FileAlterationMonitor(interval);
    }

    /**
     * 给文件添加监听
     * @param path
     * @param listener
     */
    public void monitor(String path, FileAlterationListener listener) {
        FileAlterationObserver observer = new FileAlterationObserver(new File(path));
        monitor.addObserver(observer);
        observer.addListener(listener);
    }

    public void stop() throws Exception {
        monitor.stop();
    }

    public void start() throws Exception {
        monitor.start();

    }
}

• 自定义 Runner 并实现 CommandLineRunner

  

Kernwissen🎜

• 🎜Zusammenfassung in einem Satz: Durch den Beobachtermodus und den Ereignisüberwachungsmechanismus mit FileAlterationObserver als Kern und dann durch FileAlterationListener , FileAlterationMonitor können Sie eine Ereignisüberwachung des Dateisystems implementieren. 🎜🎜
• 🎜Gesamtprozess: 🎜🎜🎜
  • 🎜Passen Sie die Datei-Listening-Klasse an und erben Sie FileAlterationListenerAdaptor, um Dateien und Verzeichnisse zu erstellen und zu verarbeiten von Änderungs- und Löschereignissen🎜🎜
  • 🎜Benutzerdefinierte Dateiüberwachungsklasse, erstellen Sie einen Beobachter durch Angabe des Verzeichnisses FileAlterationObserver🎜🎜
  • 🎜Fügen Sie diesem Monitor einen Dateisystembeobachter hinzu und fügen Sie eine Datei hinzu Listener 🎜🎜
  • 🎜Aufrufen und ausführen 🎜🎜🎜🎜Code-Implementierung durch ApplicationRunner oder CommandLineRunner 🎜
    • 🎜Dateiüberwachungsklasse: 🎜🎜🎜

      /**
       * 项目启动之后开启文件监听功能
       * @author Greenarrow
       * @date 2022-05-12 10:02
       **/
      @Component
      // @Order(Integer.MIN_VALUE)
      public class DirtyRecordRunner implements CommandLineRunner {
      
          private static Logger logger = LoggerFactory.getLogger(DirtyRecordRunner.class);
      
          @Value("${test}")
          private String path;
      
          @Override
          public void run(String... args) throws Exception {
              logger.info(this.getClass().getName()+"[开启文件夹监听功能]");
              FileMonitor fileMonitor = new FileMonitor(1000);
              fileMonitor.monitor(path,new FileListener());
              fileMonitor.start();
          }
      }

      • 🎜Dateiüberwachungsklasse: 🎜🎜🎜rrreee
        🎜Anpassen Runner und implementieren Sie CommandLineRunner:🎜🎜🎜rrreee

      Das obige ist der detaillierte Inhalt vonSo implementieren Sie die Protokolldateiüberwachung und lesen zugehörige Daten in Java. Für weitere Informationen folgen Sie bitte anderen verwandten Artikeln auf der PHP chinesischen Website!