WatchService未正确轮询

我想每10秒轮询一次目录，看看是否添加或修改了任何文件。如果它们在10秒内有任何更改，我希望有一组所有文件路径，然后我可以将其传递给另一个方法。

问题

添加文件后，会立即识别该文件，并调用addedFiles方法。相反，我希望它等待10秒，并使用已找到的多个文件调用addedFiles方法。

示例
我已经创建了一个监视目录的完整示例。然后，线程等待5秒钟，并将2000个文件复制到被监视的目录中
WatchService的预期行为是每10秒检查一次更改。相反，它似乎正在立即接受变化。

代码

import java.io.IOException;
import java.io.PrintWriter;
import java.nio.file.FileSystems;
import java.nio.file.Path;
import java.nio.file.Paths;
import java.nio.file.StandardWatchEventKinds;
import java.nio.file.WatchEvent;
import java.nio.file.WatchKey;
import java.nio.file.WatchService;
import java.util.Collection;
import java.util.HashSet;
import java.util.concurrent.TimeUnit;
public class DirectoryWatcherExample 
{
private static final int POLLING_TIME = 10;
public static void main(final String args[]) throws InterruptedException, IOException
{
final Path directory = Paths.get("directory/to/be/watched");
/**
* Start a thread that will create 2000 files to the selected directory
* This will occur after waiting 5 seconds.
*/
new Thread(new Runnable()
{
@Override
public void run() 
{
try 
{
Thread.sleep(5000);         
System.out.println("Copying 2000 files to directory: " + directory);
for(int i = 0; i < 2000; i++)
{
final PrintWriter writer = new PrintWriter(directory.resolve("test_file_" + i + ".txt").toFile(), "UTF-8");
writer.println("The first line");
writer.println("The second line");
writer.close();
}
System.out.println("Finished copying files to directory: " + directory);
} 
catch (final Exception e) 
{
e.printStackTrace();
} 
}
}).start();
/**
* Start the watch service polling every 10 seconds
*/
new DirectoryWatcherExample().startWatchService(directory);
}
public void startWatchService(final Path directory) throws InterruptedException, IOException
{
final WatchService watchService = FileSystems.getDefault().newWatchService();
directory.register(watchService, StandardWatchEventKinds.ENTRY_CREATE, StandardWatchEventKinds.ENTRY_MODIFY);
while(true)
{
System.out.println("Start polling");
final WatchKey key = watchService.poll(POLLING_TIME, TimeUnit.SECONDS);
System.out.println("Finished polling and retrieved key");
if(key != null)
{
final Collection<Path> paths = new HashSet<>();
for (final WatchEvent<?> watchEvent : key.pollEvents())
{
final Path path = ((Path) key.watchable()).resolve((Path) watchEvent.context());
paths.add(path);
System.out.println("Path added: " + path);
}
// Do something with the paths
addedFiles(paths);
if (!key.reset())
{
break;
}   
}
}
}
// Unimplemented
public void addedFiles(final Collection<Path> paths)
{
}
}

是什么原因造成的？

有两个选项：

您需要在watchService上调用poll，并在其间休眠。正如其他人指出的，poll方法中的超时适用于缓冲区中没有可用事件的情况。此外，由于您没有立即处理事件，一些事件可能会溢出操作系统缓冲区并最终丢失。因此，您还需要处理溢出场景。
或者，您可能希望使用Apache Commons IO文件监控库。它根据您的需要轮询文件系统。您甚至可以设置轮询间隔。

请参阅以下三个类/接口：

FileAlterationMonitor-它基本上是一个线程(Runnable实现(，它在轮询间隔期间休眠，并在每个间隔之后调用FileAlterationObserver
FileAlterationObserver-它列出目录中的文件，将当前列表与以前的列表进行比较，识别文件更改并调用FileAlterationListener实现中的适当方法
FileAlterationListener-您需要实现和编写逻辑的接口

您可能会考虑为您的用例做的是，在添加或修改所有文件详细信息时，不断将其添加到列表中。最后，当调用onStop()方法时，使用完整的列表调用addedFiles方法，清除列表并重新开始。

WatchService.poll(timeout, unit)中的超时参数不是用来定义它必须延迟多长时间的。它只定义了最长等待时间(在此之后，它返回是否检测到事件。(

一旦检测到变化，它仍然会返回。阅读WatchService.poll的JavaDoc

检索并删除下一个监视键，如果需要，请等待指定的等待时间(如果还没有(。

没有任何地方写过它会一直等待那么长时间。

相关内容

最新更新

热门标签：