更改 WatchService 的状态

Question

我正在编写一个应用程序，它将扫描新添加的文件的目录，然后使用 WatchService 对它们进行一些处理。这部分按预期工作。现在，我需要编写代码来处理在服务启动之前添加到目录中的文件。最简单的方法是在向 WatchService 注册路径之前简单地获取文件夹中的文件列表；但是，我担心这可能会在处理预先存在的文件和观察新事件之间留下间隙，我可能会错过传入的文件。最安全的选择是开始监视事件，但不处理它们，直到我处理了已经存在的文件。有什么方法可以手动将 WatchKey 的状态更改为“已发出信号”？这将实现我的目标，但我在 WatchService 的文档中没有看到这样做的方法。

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。

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