Java TimerTask文件监控：HashMap状态管理与常见陷阱规避指南

public abstract class DirWatcher extends TimerTask {

    // 存储文件及其最后修改时间的HashMap
    public HashMap<File, Long> files = new HashMap<>(); 
    private final File folder;

    public DirWatcher(String path) {
        this.folder = new File(path);
        System.out.println("Watching files on path: " + path);
        // 初始化时扫描并添加现有文件
        File[] startingFiles = this.folder.listFiles(file -> file.getName().endsWith(".json"));

        if(startingFiles != null && startingFiles.length > 0) {
            for (File file : startingFiles) {
                files.put(file, file.lastModified());
            }
        }
        System.out.println("Constructor: files map has values: " + files); // 此时files有值
    }

    @Override
    public final void run() {
        // 第一次或后续执行时，files可能会意外为空
        System.out.println("Run method: files map is: " + files); // 此时可能为空
        // ... 文件监控逻辑 ...
    }
    // ... 其他方法 ...
}

public class ConfigHandler {
    public ConfigHandler(Instance instance) {
        String path = instance.getDataFolder().getAbsolutePath();
        TimerTask configWatch = new DirWatcher(path) {
            @Override
            protected void onUpdate(File file, String action) {
                // 处理文件更新、添加、删除事件
            }
        };
        Timer timer = new Timer();
        timer.schedule(configWatch, new Date(), 5000); // 每5秒执行一次
    }
}

import java.util.concurrent.ConcurrentHashMap;

public abstract class DirWatcher extends TimerTask {
    // 将HashMap替换为ConcurrentHashMap
    public ConcurrentHashMap<File, Long> files = new ConcurrentHashMap<>(); 
    // ... 其他代码不变 ...
}

public final void run() {
    // ... 文件更新/添加逻辑 ...

    // 检查已删除文件
    Set<File> ref = files.keySet(); // 获取files的键集合视图
    ref.removeAll(checkedFiles);    // 问题所在：直接修改了files的底层数据
    for (File deletedFile : ref) {
        files.remove(deletedFile); // 从跟踪中移除
        onUpdate(deletedFile, "delete");
    }
}

import java.util.HashSet;
import java.util.Set;
// ...

public final void run() {
    // ... 文件更新/添加逻辑 ...

    // 检查已删除文件
    // 正确的做法：创建一个files.keySet()的独立副本
    Set<File> ref = new HashSet<>(files.keySet()); // 创建副本
    ref.removeAll(checkedFiles);    // 在副本上执行移除操作，不影响原始files
    for (File deletedFile : ref) {
        files.remove(deletedFile); // 从跟踪中移除
        onUpdate(deletedFile, "delete");
    }
}

import java.nio.file.*;
import static java.nio.file.StandardWatchEventKinds.*;

public class NioFileWatcher {

    public void watchDirectory(Path dir) throws Exception {
        WatchService watcher = FileSystems.getDefault().newWatchService();
        dir.register(watcher, ENTRY_CREATE, ENTRY_DELETE, ENTRY_MODIFY);

        System.out.println("Watching directory: " + dir);

        while (true) {
            WatchKey key;
            try {
                key = watcher.take(); // 阻塞直到有事件发生
            } catch (InterruptedException x) {
                return;
            }

            for (WatchEvent<?> event : key.pollEvents()) {
                WatchEvent.Kind<?> kind = event.kind();

                if (kind == OVERFLOW) { // 事件丢失或溢出
                    continue;
                }

                // 获取事件关联的文件名
                WatchEvent<Path> ev = (WatchEvent<Path>)event;
                Path filename = ev.context();

                // 打印事件信息
                System.out.format("%s: %s%n", event.kind().name(), filename);

                // 在这里处理文件变更逻辑，例如重新加载配置文件
            }

            boolean valid = key.reset(); // 重置key以接收更多事件
            if (!valid) {
                System.out.println("Watch key no longer valid!");
                break;
            }
        }
    }

    public static void main(String[] args) throws Exception {
        Path dirToWatch = Paths.get("/path/to/your/config/directory"); // 替换为实际路径
        new NioFileWatcher().watchDirectory(dirToWatch);
    }
}