java 中通过 watchservice 监控文件变化，核心做法是调用 filesystem 的 newwatchservice() 方法获取服务实例，并将目标目录注册到该服务上，同时指定需要监听的事件类型（如创建、修改、删除）。程序启动后进入循环阻塞等待事件，一旦有文件变动，take() 或 poll() 会返回包含具体变更信息的 watchkey，遍历该键即可获取变化的文件名和类型。需要注意的是，watchservice 仅监控目录层级下的直接子文件或子目录的变化，不递归监控深层嵌套目录，且某些文件系统实现可能存在延迟或丢失事件的特性。
如何正确注册目录并处理轮询逻辑
要开始监控，必须先将一个 Path 对象与 WatchEvent.Kind 枚举组合，传递给 register() 方法。常见的操作包括 ENTRY_CREATE、ENTRY_DELETE 和 ENTRY_MODIFY。在代码实现中，通常使用一个无限循环配合 while(true)，内部调用 watchKey.take() 来阻塞直到有事件发生。获取到 WatchKey 后，必须调用其 reset() 方法以重置状态，否则后续事件将无法被接收。如果忘记重置，程序将停止响应新的文件变化。
import java.nio.file.*;
import java.nio.file.attribute.BasicFileAttributes;
import java.io.IOException;
public class SimpleWatcher {
public static void main(String[] args) throws Exception {
Path dir = Paths.get("./test_dir");
WatchService watcher = FileSystems.getDefault().newWatchService();
// 注册目录，监听创建、删除和修改
dir.register(watcher,
StandardWatchEventKinds.ENTRY_CREATE,
StandardWatchEventKinds.ENTRY_DELETE,
StandardWatchEventKinds.ENTRY_MODIFY);
System.out.println("Watching directory: " + dir);
while (true) {
WatchKey key = watcher.take(); // 阻塞等待
for (WatchEvent<?> event : key.pollEvents()) {
WatchEvent.Kind<?> kind = event.kind();
// 处理溢出事件
if (kind == StandardWatchEventKinds.OVERFLOW) continue;
WatchEvent.Path context = (WatchEvent.Path) event.context();
System.out.println(kind + ": " + context);
}
// 关键步骤：重置 Key
boolean valid = key.reset();
if (!valid) break;
}
}
}
上述代码展示了最基础的单目录监控流程。输入为当前工作目录下的 test_dir，实际运行时会打印类似 ENTRY_CREATE: file.txt 的日志。如果在同一目录下快速创建多个文件，可能会触发 OVERFLOW 事件，此时应跳过处理以避免数据错乱。此外，take() 是阻塞式调用，适合单线程长期运行的守护进程场景。
立即学习“Java免费学习笔记（深入）”；
如何实现递归监控整个目录树
由于 WatchService 原生不支持递归监控，要实现对整个目录树的监控，需要在发现新目录时动态注册它。具体做法是在遍历现有目录结构时，对每个子目录也执行 register() 操作。当监听到 ENTRY_CREATE 事件且上下文是一个目录时，立即将该新目录注册到同一个 WatchService 实例中。这样，无论用户创建多少层嵌套文件夹，都能被持续追踪。这种方法避免了启动时扫描所有文件的开销，实现了按需监控。
import java.nio.file.*;
import java.util.concurrent.ConcurrentHashMap;
import java.util.Map;
public class RecursiveWatcher {
private final WatchService watcher;
private final Map<WatchKey, Path> keys = new ConcurrentHashMap<>();
public RecursiveWatcher(Path startDir) throws Exception {
this.watcher = FileSystems.getDefault().newWatchService();
registerAll(startDir); // 初始注册
}
private void registerAll(Path dir) throws Exception {
Files.walkFileTree(dir, new SimpleFileVisitor<Path>() {
@Override
public FileVisitResult preVisitDirectory(Path d, BasicFileAttributes attrs) throws IOException {
try {
keys.put(d.register(watcher,
StandardWatchEventKinds.ENTRY_CREATE,
StandardWatchEventKinds.ENTRY_DELETE,
StandardWatchEventKinds.ENTRY_MODIFY), d);
} catch (Exception x) {
x.printStackTrace();
}
return FileVisitResult.CONTINUE;
}
});
}
public void processEvents() {
while (true) {
WatchKey key;
try {
key = watcher.take();
} catch (InterruptedException e) {
return;
}
Path dir = keys.get(key);
if (dir == null) continue;
for (WatchEvent<?> event : key.pollEvents()) {
WatchEvent.Kind<?> kind = event.kind();
if (kind == StandardWatchEventKinds.OVERFLOW) continue;
WatchEvent.Path context = (WatchEvent.Path) event.context();
Path child = dir.resolve(context);
// 如果是新创建的目录，递归注册
if (kind == StandardWatchEventKinds.ENTRY_CREATE) {
try {
if (Files.isDirectory(child)) {
registerAll(child);
}
} catch (Exception e) {
e.printStackTrace();
}
}
System.out.println(kind + ": " + child);
}
key.reset();
}
}
}
此方案通过维护一个 Map<watchkey path></watchkey> 来关联每个监控键对应的物理路径。输入为根目录 startDir，实际运行时，每当用户在任意子目录下新建文件夹，程序会自动将其纳入监控范围。这种动态注册机制确保了监控范围的完整性，同时保持了较低的初始资源消耗。需要注意的是，并发环境下建议使用线程安全的集合类来存储键值对，以防止多线程访问冲突。
如何处理特定文件类型的过滤与异常捕获
在实际应用中，往往不需要监控所有文件，而是只关心特定扩展名（如 .java 或 .xml）的变化。可以在事件处理循环中加入字符串匹配逻辑，利用 context.toString().endsWith() 进行过滤。同时，文件操作可能因权限不足、文件被占用等原因抛出 IOException 或 ClosedWatchServiceException。因此，必须在 try-catch 块中包裹注册和事件处理代码。对于 ClosedWatchServiceException，通常意味着底层文件系统服务已关闭，此时应退出监控循环或尝试重新初始化服务。通过结合类型过滤和异常处理，可以构建出健壮且高效的文件监控模块。
