java - 更改 WatchService 的状态

Question

我正在编写一个应用程序，它将扫描目录以查找新添加的文件，然后使用 WatchService 对它们进行一些处理。这部分按预期工作。现在，我需要编写代码来处理在服务启动之前添加到目录中的文件。

天真的方法是在向 WatchService 注册路径之前简单地获取文件夹中的文件列表；不过，我担心这可能会在处理预先存在的文件和监视新事件之间留下空隙，我可能会错过传入的文件。最安全的选择是开始观察事件，但不处理它们，直到我处理完已经存在的文件。

有什么方法可以手动将 WatchKey 的状态更改为“已发出信号”？这将实现我的目标，但我在 WatchService 的文档中没有看到这样做的方法。

标签： javawatchservice

Answer 1

天真的方法是在向 WatchService 注册路径之前简单地获取文件夹中的文件列表；不过，我担心这可能会在处理预先存在的文件和监视新事件之间留下空隙，我可能会错过传入的文件。最安全的选择是开始观察事件，但不处理它们，直到我处理完已经存在的文件。

以下是解决问题的方法：

同时启动watch-service和get-files-list-from-folder-process。

这两个进程都将文件（文件路径）放入线程安全队列集合中 - 首先 - 允许后进先出 (LIFO) 或先进先出 (FIFO) 处理。可以考虑java.util.concurrent.ConcurrentLinkedDeque, LinkedBlockingDeque,ConcurrentLinkedQueue或LinkedBlockingQueue根据需求。这样，所有文件都会一个接一个地处理——不管它是来自 get-files-list-from-folder-process 还是 watch-service。

但是，需要检查以避免重复文件处理，以确保没有文件两次添加到队列中。这仅在应用程序开始时需要。实际的文件处理程序本身可以跟踪在另一个集合中处理的文件 - 这可用于检查文件是否已被处理。