监听文件和文件夹

compile('commons-io:commons-io:2.6')

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

public class FileListener extends FileAlterationListenerAdaptor {
 
    // 声明业务服务
    private ListenerService listenerService;
 
    // 采用构造函数注入服务
    public FileListener(ListenerService listenerService) {
        this.listenerService = listenerService;
    }
 
    // 文件创建执行
    @Override
    public void onFileCreate(File file) {
    }
 
    // 文件创建修改
    @Override
    public void onFileChange(File file) {
        // 触发业务
        listenerService.doSomething();
    }
 
    // 文件创建删除
    @Override
    public void onFileDelete(File file) {
    }
 
    // 目录创建
    @Override
    public void onDirectoryCreate(File directory) {
    }
 
    // 目录修改
    @Override
    public void onDirectoryChange(File directory) {
    }
 
    // 目录删除
    @Override
    public void onDirectoryDelete(File directory) {
    }
 
 
    // 轮询开始
    @Override
    public void onStart(FileAlterationObserver observer) {
    }
 
    // 轮询结束
    @Override
    public void onStop(FileAlterationObserver observer) {
    }
}

@Component
public class FileListenerFactory {
 
    // 设置监听路径
    private final String monitorDir = "/tmp/monitorTest";
 
    // 设置轮询间隔
    private final long interval = TimeUnit.SECONDS.toMillis(1);
 
    // 自动注入业务服务
    @Autowired
    private ListenerService listenerService;
 
    public FileAlterationMonitor getMonitor() {
        // 创建过滤器
        IOFileFilter directories = FileFilterUtils.and(
                FileFilterUtils.directoryFileFilter(),
                HiddenFileFilter.VISIBLE);
        IOFileFilter files = FileFilterUtils.and(
                FileFilterUtils.fileFileFilter(),
                FileFilterUtils.suffixFileFilter(".log"));
        IOFileFilter filter = FileFilterUtils.or(directories, files);
 
        // 装配过滤器
        // FileAlterationObserver observer = new FileAlterationObserver(new File(monitorDir));
        FileAlterationObserver observer = new FileAlterationObserver(new File(monitorDir), filter);
 
        // 向监听者添加监听器，并注入业务服务
        observer.addListener(new FileListener(listenerService));
 
        // 返回监听者
		//监听多个路径
		//return new FileAlterationMonitor(interval, observer,observer,observer);
		//监听单个路径
        return new FileAlterationMonitor(interval, observer);
    }
}

@Component
public class FileListenerRunner implements CommandLineRunner {
 
    @Autowired
    private FileListenerFactory fileListenerFactory;
 
    @Override
    public void run(String... args) throws Exception {
        // 创建监听者
        FileAlterationMonitor fileAlterationMonitor = fileListenerFactory.getMonitor();
        try {
            // do not stop this thread
            fileAlterationMonitor.start();
        } catch (Exception e) {
            e.printStackTrace();
        }
    }
}