Java에서 로그 파일 모니터링을 구현하고 관련 데이터를 읽는 방법

프로젝트 요구 사항

데이터 센터 프로젝트 팀은 파일 및 폴더가 변경될 때 해당 비즈니스 프로세스를 수행하기 위해 폴더 또는 로그 파일을 모니터링하고 해당 형식의 더티 데이터를 읽는 요구 사항을 구현해야 하므로 여기에 기록합니다. 관련사업의 기술선정.

Apache Commons-IO

먼저 해당 종속성을 추가해야 합니다.

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

버전은 직접 선택할 수 있습니다. 버전 2.7 이상에는 Java 8

공식 웹사이트 스크린샷이 필요합니다.

Apache Commos IO org.apache.commons.io.monitor 패키지는 파일 시스템 모니터링 기능을 제공합니다. 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

  

핵심 지식🎜

• 🎜한 문장 요약: 관찰자 모드 및 이벤트 수신 메커니즘을 통해 FileAlterationObserver를 핵심으로 한 다음 FileAlterationListener , FileAlterationMonitor를 사용하면 파일 시스템의 이벤트 모니터링을 구현할 수 있습니다. 🎜🎜
• 🎜전체 프로세스: 🎜🎜🎜
  • 🎜파일 수신 클래스를 사용자 정의하고 FileAlterationListenerAdaptor를 상속하여 파일 및 디렉터리를 생성하고 처리합니다. 수정 및 삭제 이벤트🎜🎜
  • 🎜사용자 정의 파일 모니터링 클래스, FileAlterationObserver🎜🎜
  • 🎜이 모니터에 파일 시스템 관찰자를 추가하고 파일을 추가하여 관찰자를 생성합니다. 리스너 🎜🎜
  • 🎜ApplicationRunner 또는 CommandLineRunner를 통해 🎜🎜🎜🎜코드 구현을 호출하고 실행합니다. 🎜
    • 🎜파일 모니터링 클래스: 🎜🎜🎜

      /**
       * 项目启动之后开启文件监听功能
       * @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();
          }
      }

      • 🎜파일 모니터링 클래스: 🎜🎜🎜rrreee
        🎜Customize CommandLineRunner 실행 및 구현:🎜🎜🎜rrreee

위 내용은 Java에서 로그 파일 모니터링을 구현하고 관련 데이터를 읽는 방법의 상세 내용입니다. 자세한 내용은 PHP 중국어 웹사이트의 기타 관련 기사를 참조하세요!