public class DirectoryWatcher implements Runnable {
    private final Path watchDir;
    private final WatchService watchService;
    private final FileChangeHandler handler;

    public DirectoryWatcher(Path dir, FileChangeHandler handler) throws IOException {
        this.watchDir = dir;
        this.handler = handler;
        this.watchService = FileSystems.getDefault().newWatchService();
        register();
    }

    private void register() throws IOException {
        watchDir.register(watchService,
                StandardWatchEventKinds.ENTRY_CREATE,
                StandardWatchEventKinds.ENTRY_MODIFY,
                StandardWatchEventKinds.ENTRY_DELETE);
    }

    @Override
    public void run() {
        try {
            while (!Thread.currentThread().isInterrupted()) {
                WatchKey key = watchService.take();
                for (WatchEvent<?> event : key.pollEvents()) {
                    WatchEvent.Kind<?> kind = event.kind();
                    Path filename = (Path) event.context();
                    Path fullPath = watchDir.resolve(filename);
                    handler.onFileChanged(fullPath, kind);
                }
                key.reset();
            }
        } catch (InterruptedException e) {
            Thread.currentThread().interrupt();
        } catch (Exception e) {
            e.printStackTrace();
        } finally {
            try { watchService.close(); } catch (IOException ignored) {}
        }
    }

    public interface FileChangeHandler {
        void onFileChanged(Path path, WatchEvent.Kind<?> kind);
    }
}

public class ConfigLoader {
    public void load(Path file) {
        // 讀取并解析 JSON 文件，更新內(nèi)存配置
        System.out.println("配置文件更新：" + file.getFileName());
    }
}

public class ConfigHotReload {
    public static void main(String[] args) throws Exception {
        Path configDir = Paths.get("config");
        ConfigLoader loader = new ConfigLoader();

        DirectoryWatcher watcher = new DirectoryWatcher(configDir, (path, kind) -> {
            if (path.toString().endsWith(".json")) {
                loader.load(path);
            }
        });

        Thread thread = new Thread(watcher, "ConfigHotReload");
        thread.setDaemon(true);
        thread.start();

        // 主線程繼續(xù)其他工作
        Thread.sleep(Long.MAX_VALUE);
    }
}