路径监听 · 《Java 编程思想》第五版

## [路径监听](https://lingcoder.gitee.io/onjava8/#/book/17-Files?id=%e8%b7%af%e5%be%84%e7%9b%91%e5%90%ac) 通过**WatchService**可以设置一个进程对目录中的更改做出响应。在这个例子中，**delTxtFiles()**作为一个单独的任务执行，该任务将遍历整个目录并删除以**.txt**结尾的所有文件，**WatchService**会对文件删除操作做出反应： ~~~ // files/PathWatcher.java // {ExcludeFromGradle} import java.io.IOException; import java.nio.file.*; import static java.nio.file.StandardWatchEventKinds.*; import java.util.concurrent.*; public class PathWatcher { static Path test = Paths.get("test"); static void delTxtFiles() { try { Files.walk(test) .filter(f -> f.toString() .endsWith(".txt")) .forEach(f -> { try { System.out.println("deleting " + f); Files.delete(f); } catch(IOException e) { throw new RuntimeException(e); } }); } catch(IOException e) { throw new RuntimeException(e); } } public static void main(String[] args) throws Exception { Directories.refreshTestDir(); Directories.populateTestDir(); Files.createFile(test.resolve("Hello.txt")); WatchService watcher = FileSystems.getDefault().newWatchService(); test.register(watcher, ENTRY_DELETE); Executors.newSingleThreadScheduledExecutor() .schedule(PathWatcher::delTxtFiles, 250, TimeUnit.MILLISECONDS); WatchKey key = watcher.take(); for(WatchEvent evt : key.pollEvents()) { System.out.println("evt.context(): " + evt.context() + "\nevt.count(): " + evt.count() + "\nevt.kind(): " + evt.kind()); System.exit(0); } } } /* Output: deleting test\bag\foo\bar\baz\File.txt deleting test\bar\baz\bag\foo\File.txt deleting test\baz\bag\foo\bar\File.txt deleting test\foo\bar\baz\bag\File.txt deleting test\Hello.txt evt.context(): Hello.txt evt.count(): 1 evt.kind(): ENTRY_DELETE */ ~~~ **delTxtFiles()**中的**try**代码块看起来有些多余，因为它们捕获的是同一种类型的异常，外部的**try**语句似乎已经足够了。然而出于某种原因，Java 要求两者都必须存在(这也可能是一个 bug)。还要注意的是在**filter()**中，我们必须显式地使用**f.toString()**转为字符串，否则我们调用**endsWith()**将会与整个**Path**对象进行比较，而不是路径名称字符串的一部分进行比较。一旦我们从**FileSystem**中得到了**WatchService**对象，我们将其注册到**test**路径以及我们感兴趣的项目的变量参数列表中，可以选择**ENTRY\_CREATE**，**ENTRY\_DELETE**或**ENTRY\_MODIFY**(其中创建和删除不属于修改)。因为接下来对**watcher.take()**的调用会在发生某些事情之前停止所有操作，所以我们希望**deltxtfiles()**能够并行运行以便生成我们感兴趣的事件。为了实现这个目的，我通过调用**Executors.newSingleThreadScheduledExecutor()**产生一个**ScheduledExecutorService**对象，然后调用**schedule()**方法传递所需函数的方法引用，并且设置在运行之前应该等待的时间。此时，**watcher.take()**将等待并阻塞在这里。当目标事件发生时，会返回一个包含**WatchEvent**的**Watchkey**对象。展示的这三种方法是能对**WatchEvent**执行的全部操作。查看输出的具体内容。即使我们正在删除以**.txt**结尾的文件，在**Hello.txt**被删除之前，**WatchService**也不会被触发。你可能认为，如果说"监视这个目录"，自然会包含整个目录和下面子目录，但实际上：只会监视给定的目录，而不是下面的所有内容。如果需要监视整个树目录，必须在整个树的每个子目录上放置一个**Watchservice**。 ~~~ // files/TreeWatcher.java // {ExcludeFromGradle} import java.io.IOException; import java.nio.file.*; import static java.nio.file.StandardWatchEventKinds.*; import java.util.concurrent.*; public class TreeWatcher { static void watchDir(Path dir) { try { WatchService watcher = FileSystems.getDefault().newWatchService(); dir.register(watcher, ENTRY_DELETE); Executors.newSingleThreadExecutor().submit(() -> { try { WatchKey key = watcher.take(); for(WatchEvent evt : key.pollEvents()) { System.out.println( "evt.context(): " + evt.context() + "\nevt.count(): " + evt.count() + "\nevt.kind(): " + evt.kind()); System.exit(0); } } catch(InterruptedException e) { return; } }); } catch(IOException e) { throw new RuntimeException(e); } } public static void main(String[] args) throws Exception { Directories.refreshTestDir(); Directories.populateTestDir(); Files.walk(Paths.get("test")) .filter(Files::isDirectory) .forEach(TreeWatcher::watchDir); PathWatcher.delTxtFiles(); } } /* Output: deleting test\bag\foo\bar\baz\File.txt deleting test\bar\baz\bag\foo\File.txt evt.context(): File.txt evt.count(): 1 evt.kind(): ENTRY_DELETE */ ~~~ 在**watchDir()**方法中给**WatchSevice**提供参数**ENTRY\_DELETE**，并启动一个独立的线程来监视该**Watchservice**。这里我们没有使用**schedule()**进行启动，而是使用**submit()**启动线程。我们遍历整个目录树，并将**watchDir()**应用于每个子目录。现在，当我们运行**deltxtfiles()**时，其中一个**Watchservice**会检测到每一次文件删除。