SpringBoot整合jnotify实现针对指定目录及其(动态)子目录的监听的方法

<dependency>
	<groupId>net.contentobjects.jnotify</groupId>
	<artifactId>jnotify</artifactId>
	<version>0.94</version>
</dependency>

@Component
public class FileMonitorListener extends JNotifyAdapter {
    /**
     * 文件创建后调用
     *
     * @param watchId      监视Id  初始为1，多个监控程序以此加1
     * @param watchPath    被监视的最上层路径
     * @param relativePath 创建的文件相对watchPath的相对路径
     */
    @Override
    public void fileCreated(int watchId, String watchPath, String relativePath) {
        System.out.println(String.format("watchId = [%s], 被监视路径 = [%s], 创建文件 = [%s]", watchId, watchPath, relativePath));
    }
    /**
     * 文件删除后调用
     *
     * @param watchId      监视Id 初始为1，多个监控程序以此加1
     * @param watchPath    被监视的最上层路径
     * @param relativePath 删除的文件相对watchPath的相对路径
     */
    @Override
    public void fileDeleted(int watchId, String watchPath, String relativePath) {
        System.out.println(String.format("watchId = [%s], 被监视路径 = [%s], 删除文件 = [%s]",
                watchId, watchPath, relativePath));
    }
    /**
     * 文件修改 (文件内容被修改和文件夹被修改都可以检测到)
     * @param watchId      监视Id  初始为1，多个监控程序以此加1
     * @param watchPath    被监视的最上层路径
     * @param relativePath 修改的文件相对watchPath的相对路径
     */
    @Override
    public void fileModified(int watchId, String watchPath, String relativePath) {
        System.out.println(String.format("watchId = [%s], 被监视路径 = [%s], 修改文件 = [%s]",
                watchId, watchPath, relativePath));
    }
    /**
     * 文件重命名后调用
     *
     * @param watchId         监视Id  初始为1，多个监控程序以此加1
     * @param watchPath       被监视的最上层路径
     * @param oldRelativePath 修改前文件名（相对watchPath的相对路径）
     * @param newRelativePath 修改后文件名（相对watchPath的相对路径）
     */
    @Override
    public void fileRenamed(int watchId, String watchPath, String oldRelativePath, String newRelativePath) {
        System.out.println(String.format("watchId = [%s], 被监视路径 = [%s], 文件重命名: [%s] -> [%s]",
                watchId, watchPath, oldRelativePath, newRelativePath));
    }
}

@RestController
@RequestMapping("/file")
public class FileMonitorController {
    @Resource
    private FileMonitorListener fileMonitorListener;
    @GetMapping("/v1/monitor")
    public ResultBean<Void> monitorDir() {
        //在新线程中开启监听
        new Thread(() -> {
            try {
                beginWatch();
            } catch (JNotifyException e) {
                e.printStackTrace();
            }
        }).start();
        return ResultBeanUtil.<Void>success(null).setMsg("文件监听开启成功");
    }
    private void beginWatch() throws JNotifyException {
        String path1 = "e:/test/001";
        String path2 = "e:/test/002";
        // 是否监视子目录
        boolean watchSubtree = true;
        // 需要监视的文件变更类型，此处用4个bit位表示，类似linux的文件访问权限
        int mask = JNotify.FILE_CREATED | JNotify.FILE_DELETED | JNotify.FILE_MODIFIED | JNotify.FILE_RENAMED;
        //添加监听
        int watchId1 = JNotify.addWatch(path1, mask, watchSubtree, fileMonitorListener);
        System.out.println("watchId1 = " + watchId1 + ", 开始监视路径：" + path1);
        // 添加监听
        int watchId2 = JNotify.addWatch(path2, JNotify.FILE_ANY, false, fileMonitorListener);
        System.out.println("watchId2 = " + watchId2 + ", 开始监视路径：" + path2);
    }
}