Java如何實(shí)現(xiàn)日志文件監(jiān)聽(tīng)并讀取相關(guān)數(shù)據(jù)

這篇“Java如何實(shí)現(xiàn)日志文件監(jiān)聽(tīng)并讀取相關(guān)數(shù)據(jù)”文章的知識(shí)點(diǎn)大部分人都不太理解，所以小編給大家總結(jié)了以下內(nèi)容，內(nèi)容詳細(xì)，步驟清晰，具有一定的借鑒價(jià)值，希望大家閱讀完這篇文章能有所收獲，下面我們一起來(lái)看看這篇“Java如何實(shí)現(xiàn)日志文件監(jiān)聽(tīng)并讀取相關(guān)數(shù)據(jù)”文章吧。

項(xiàng)目需求

由于所在數(shù)據(jù)中臺(tái)項(xiàng)目組需要實(shí)現(xiàn)監(jiān)聽(tīng)文件夾或者日志文件并讀取對(duì)應(yīng)格式的臟數(shù)據(jù)的需求，以便在文件、文件夾發(fā)生變化時(shí)進(jìn)行相應(yīng)的業(yè)務(wù)流程；所以在這里記錄下相關(guān)業(yè)務(wù)的實(shí)現(xiàn)及技術(shù)選型。

Apache Commons-IO

首先需要添加對(duì)應(yīng)依賴：

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

版本可自行選擇，這里需要注意的是 2.7 版本及以上需要 Java 8

官網(wǎng)截圖：

Apache Commos IO中的 org.apache.commons.io.monitor包提供了文件系統(tǒng)監(jiān)聽(tīng)的功能。

核心知識(shí)

• 一句話總結(jié)：通過(guò)觀察者模式以及事件監(jiān)聽(tīng)機(jī)制，以 FileAlterationObserver 為核心，再通過(guò) FileAlterationListener，FileAlterationMonitor，就可以實(shí)現(xiàn)對(duì)文件系統(tǒng)的事件監(jiān)聽(tīng)。

• 整體流程：

• 自定義文件監(jiān)聽(tīng)類并繼承 FileAlterationListenerAdaptor 實(shí)現(xiàn)對(duì)文件與目錄的創(chuàng)建，修改，刪除事件的處理

• 自定義文件監(jiān)控類，通過(guò)指定目錄創(chuàng)建一個(gè)觀察者 FileAlterationObserver

• 向此監(jiān)視器添加文件系統(tǒng)觀察器，并添加文件監(jiān)聽(tīng)器

• 通過(guò) ApplicationRunner 或者 CommandLineRunner 調(diào)用并執(zhí)行

代碼實(shí)現(xiàn)

• 文件監(jiān)聽(tīng)類：

/**
 * 文件監(jiān)聽(tīng)類
 * @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)){
                    // 獲取對(duì)應(yīng)格式的數(shù)據(jù)并輸出，這里可自行添加業(yè)務(wù)處理
                    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("讀取文件內(nèi)容失敗",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");
    }
}

• 文件監(jiān)控類：

/**
 * 文件監(jiān)聽(tīng)測(cè)試 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);
    }

    /**
     * 給文件添加監(jiān)聽(tīng)
     * @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 并實(shí)現(xiàn) CommandLineRunner :

/**
 * 項(xiàng)目啟動(dòng)之后開(kāi)啟文件監(jiān)聽(tīng)功能
 * @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()+"[開(kāi)啟文件夾監(jiān)聽(tīng)功能]");
        FileMonitor fileMonitor = new FileMonitor(1000);
        fileMonitor.monitor(path,new FileListener());
        fileMonitor.start();
    }
}

以上就是關(guān)于“Java如何實(shí)現(xiàn)日志文件監(jiān)聽(tīng)并讀取相關(guān)數(shù)據(jù)”這篇文章的內(nèi)容，相信大家都有了一定的了解，希望小編分享的內(nèi)容對(duì)大家有幫助，若想了解更多相關(guān)的知識(shí)內(nèi)容，請(qǐng)關(guān)注億速云行業(yè)資訊頻道。