Java實現文件夾下文件實時監控

一、commons-io方法

1、使用Commons-io的monitor下的相關類可以處理對文件進行監控，它采用的是觀察者模式來實現的

• （1）可以監控文件夾的創建、刪除和修改
• （2）可以監控文件的創建、刪除和修改
• （3）采用的是觀察者模式來實現的
• （4）采用線程去定時去刷新檢測文件的變化情況

2、引入commons-io包，需要2.0以上。

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

 

3、編寫繼承FileAlterationListenerAdaptor的類FileListener。

 

import java.io.File;
import java.util.concurrent.TimeUnit;

import org.apache.commons.io.filefilter.FileFilterUtils;
import org.apache.commons.io.filefilter.HiddenFileFilter;
import org.apache.commons.io.filefilter.IOFileFilter;
import org.apache.commons.io.monitor.FileAlterationListenerAdaptor;
import org.apache.commons.io.monitor.FileAlterationMonitor;
import org.apache.commons.io.monitor.FileAlterationObserver;
import org.swdc.skybox.ui.CompareFolder;

import lombok.extern.slf4j.Slf4j;
/**
 * 文件變化監聽器
 * 在Apache的Commons-IO中有關於文件的監控功能的代碼. 文件監控的原理如下：
 * 由文件監控類FileAlterationMonitor中的線程不停的掃描文件觀察器FileAlterationObserver，
 * 如果有文件的變化，則根據相關的文件比較器，判斷文件時新增，還是刪除，還是更改。（默認為1000毫秒執行一次掃描）
 */
@Slf4j
public class FileListener extends FileAlterationListenerAdaptor {
    
    public static void main(String[] args) throws Exception {
        // 監控目錄
        String rootDir = "E:\\test\\runPath\\test";
        // 輪詢間隔 3 秒
        long interval = TimeUnit.SECONDS.toMillis(3);
        // 創建過濾器
        IOFileFilter directories = FileFilterUtils.and(FileFilterUtils.directoryFileFilter(), HiddenFileFilter.VISIBLE);
        IOFileFilter files = FileFilterUtils.and(FileFilterUtils.fileFileFilter(),
                FileFilterUtils.suffixFileFilter(".txt"));
        IOFileFilter filter = FileFilterUtils.or(directories, files);
        // 使用過濾器
        FileAlterationObserver observer = new FileAlterationObserver(new File(rootDir), filter);
        // 不使用過濾器
        // FileAlterationObserver observer = new FileAlterationObserver(new
        // File(rootDir));
        observer.addListener(new FileListener());
        // 創建文件變化監聽器
        FileAlterationMonitor monitor = new FileAlterationMonitor(interval, observer);
        // 開始監控
        monitor.start();
    }
    
    
  /**
   * 文件創建執行
   */
  public void onFileCreate(File file) {
    changeNotice(file.getAbsolutePath(), "文件創建");
    log.info("[新建]:" + file.getAbsolutePath());
  }
  /**
   * 文件修改
   */
  public void onFileChange(File file) {
    changeNotice(file.getAbsolutePath(), "文件修改");
    log.info("[修改]:" + file.getAbsolutePath());
  }
  /**
   * 文件刪除
   */
  public void onFileDelete(File file) {
    changeNotice(file.getAbsolutePath(), "文件刪除");
    log.info("[刪除]:" + file.getAbsolutePath());
  }
  /**
   * 目錄創建
   */
  public void onDirectoryCreate(File directory) {
    changeNotice(directory.getAbsolutePath(), "目錄創建");
    log.info("[新建]:" + directory.getAbsolutePath());
  }
  /**
   * 目錄修改
   */
  public void onDirectoryChange(File directory) {
    changeNotice(directory.getAbsolutePath(), "目錄修改");
    log.info("[修改]:" + directory.getAbsolutePath());
  }
  /**
   * 目錄刪除
   */
  public void onDirectoryDelete(File directory) {
    changeNotice(directory.getAbsolutePath(), "目錄刪除");
    log.info("[刪除]:" + directory.getAbsolutePath());
  }
  public void onStart(FileAlterationObserver observer) {
    log.info("文件變化監聽器啟動");
    super.onStart(observer);
  }
  public void onStop(FileAlterationObserver observer) {
    log.info("文件變化監聽器停止");
    super.onStop(observer);
  }
  
  public void changeNotice(String filePath, String type) {
      log.info(type + "："+ filePath);
      CompareFolder.NO_COMPARE_FILE_LIST.stream().filter(str -> filePath.startsWith(str)).forEach(str -> {
          log.info("不參與對比的文件：{}", str);
      });
  }
  
}