Get新技能,Java实现文件监控

public class JavaWatchAPI {

    public static void main(String[] args) throws Exception {
        //第一步：取得WatchService
        WatchService watchService = FileSystems.getDefault().newWatchService();
//第二步：确定要监控的路径
        Path path = Paths.get("/Users/liuxin/Github/nobug-learn-project/nobug-learn-01/src/main/java");

//第三步：为本路径绑定WatchService，并确定监控的事件
        path.register(
                watchService,
                // StandardWatchEventKinds.ENTRY_CREATE—当有新文件时触发。可能是创建了一个新文件
                StandardWatchEventKinds.ENTRY_CREATE,
                // StandardWatchEventKinds.ENTRY_DELETE—当文件被删除、移动或重命名时触发
                StandardWatchEventKinds.ENTRY_DELETE,
                // StandardWatchEventKinds.ENTRY_MODIFY—当文件被修改时触发。
                StandardWatchEventKinds.ENTRY_MODIFY);
// StandardWatchEventKinds.OVERFLOW—触发表示丢失或丢弃的事件。
        WatchKey key = null;
while ((key = watchService.take()) != null) {
            for (WatchEvent<?> event : key.pollEvents()) {
                System.out.println("事件" + event.kind() + "发生了，文件是：" + event.context());
}
            key.reset();
}
    }
}

package cn.github.chinesszz;

import org.apache.commons.io.filefilter.FileFilterUtils;
import org.apache.commons.io.monitor.FileAlterationListener;
import org.apache.commons.io.monitor.FileAlterationMonitor;
import org.apache.commons.io.monitor.FileAlterationObserver;
import org.junit.Test;

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

/**
 * @author liuxin
 * 2021/11/9 8:55 下午
 */
public class CommonIOAPI {

    public static void main(String[] args) throws Exception {
        File directory = new File("/Users/liuxin/Github/nobug-learn-project/nobug-learn-01/src/main/java");
// 轮询间隔 5 秒
        long interval = TimeUnit.SECONDS.toMillis(5);
// 创建一个文件观察器用于处理文件的格式
        FileAlterationObserver observer = new FileAlterationObserver(directory, FileFilterUtils.and(
                FileFilterUtils.fileFileFilter(), FileFilterUtils.suffixFileFilter(".txt"),
                FileFilterUtils.prefixFileFilter("lx")));
// 设置文件变化监听器
        observer.addListener(new MyFileListener());
FileAlterationMonitor monitor = new FileAlterationMonitor(interval, observer);
monitor.start();
System.out.println(1);
}

    @Test
    public void watchDir() throws Exception {
        File directory = new File("/Users/liuxin/Github/nobug-learn-project/nobug-learn-01/src/main/java");
FileAlterationObserver fileAlterationObserver = new FileAlterationObserver(directory, FileFilterUtils.and(
                FileFilterUtils.directoryFileFilter()));
long interval = TimeUnit.SECONDS.toMillis(5);
// 设置文件变化监听器
        fileAlterationObserver.addListener(new MyFileListener());
FileAlterationMonitor monitor = new FileAlterationMonitor(interval, fileAlterationObserver);
monitor.start();
while (true);
}

    static final class MyFileListener implements FileAlterationListener {
        @Override
        public void onStart(FileAlterationObserver fileAlterationObserver) {
            System.out.println("monitor start scan files..");
}


        @Override
        public void onDirectoryCreate(File file) {
            System.out.println(file.getName() + " director created.");
}


        @Override
        public void onDirectoryChange(File file) {
            System.out.println(file.getName() + " director changed.");
}


        @Override
        public void onDirectoryDelete(File file) {
            System.out.println(file.getName() + " director deleted.");
}


        @Override
        public void onFileCreate(File file) {
            System.out.println(file.getName() + " created.");
}


        @Override
        public void onFileChange(File file) {
            System.out.println(file.getName() + " changed.");
}


        @Override
        public void onFileDelete(File file) {
            System.out.println(file.getName() + " deleted.");
}


        @Override
        public void onStop(FileAlterationObserver fileAlterationObserver) {
            System.out.println("monitor stop scanning..");
}
    }
}