Java 监控多个文件夹

Question

我需要监控多个文件夹，我想知道哪个文件夹收到了执行特定处理的事件。我试过这段代码。

WatchService watchService = FileSystems.getDefault().newWatchService();
opexFolder.register(watchService, StandardWatchEventKinds.ENTRY_CREATE);
docupostFolder.register(watchService, StandardWatchEventKinds.ENTRY_CREATE);

    boolean valid = true;
    do {
        WatchKey watchKey = watchService.take();
        for (WatchEvent<?> event : watchKey.pollEvents()) {
            WatchEvent.Kind kind = event.kind();                
            if (StandardWatchEventKinds.ENTRY_CREATE.equals(event.kind())) {                    
                String fileName = event.context().toString();                   

                //here I want to khow the path of the folder that has 
                // received the ENTRY event 
               String pathToExplore = ??;
              if (pathToExplore has some value) {
                treatments;
              } else {
                other treatments;
                }

            }
        }
        valid = watchKey.reset();

    } while (valid);
}

是否可以这样做，或者我必须为每个文件夹创建 watchService。

谢谢。

Answer 1

WatchService.take() 将 return 每个监视目录的不同监视键。您可以从 WatchKey::watchable() 方法中获取监视目录。

因此，通过检查 WatchKey::watchable() 的 returned 值，您将知道该事件针对哪个目录。

Is the WatchKey usualy constant?

没有。 WatchKey 不是常数。您可以通过调用获得它 WatchKey watchKey = watchService.take(); 您已经在发布的代码中完成了它。

How can I say this is opexFolder's key or docupostFolder's key

只需调用Path directory = WatchKey::watchable()

这是一个简单的示例应用程序：

import java.io.IOException;
import java.nio.file.*;
import java.nio.file.attribute.BasicFileAttributes;

public final class WatchServiceExample {

    public static void main(String[] args) throws Exception {
        //We'll use this watch service to monitor all directories we are interested in
        final WatchService watchService = FileSystems.getDefault().newWatchService();

        //We'll use this directory for the test in order not to create junk in the system
        final Path tempDirectory = Files.createTempDirectory("watch-service-example");
        System.out.println("Created temporary directory: " + tempDirectory.toAbsolutePath());

        for (int i = 0; i < 10; i++) {
            final Path watchedDir = Files.createDirectory(tempDirectory.resolve("watched_" + i));
            System.out.println("Created watched directory: " + watchedDir.toAbsolutePath());
            watchedDir.register(watchService, StandardWatchEventKinds.ENTRY_CREATE);
        }

        System.out.println("Initialization complete. When you create an entry in the watch dirs you'll be notified.");
        while (true) {
            final WatchKey watchKey = watchService.take();
            final Watchable watchable = watchKey.watchable();

            //Since we are registering only paths in teh watch service, the watchables must be paths
            if (!(watchable instanceof Path)) {
                throw new AssertionError("The watchable should have been a Path");
            }

            final Path directory = (Path) watchable;
            System.out.println("Processing events for watched directory: " + directory);

            for (WatchEvent<?> event : watchKey.pollEvents()) {
                System.out.println("Received event '"
                  + event.kind()
                  + "' for entry '"
                  + event.context()
                  + "' in watched directory '"
                  + directory + "'"
                );
            }

            if (!watchKey.reset()) {
                System.out.println("Failed to reset watch key: will not process more events");
                break;
            }
        }

        //Lets clean up after ourselves
        Files.walkFileTree(tempDirectory, new SimpleFileVisitor<Path>() {
            @Override
            public FileVisitResult visitFile(Path file, BasicFileAttributes attrs) throws IOException {
                Files.delete(file);
                return FileVisitResult.CONTINUE;
            }

            @Override
            public FileVisitResult postVisitDirectory(Path dir, IOException exc) throws IOException {
                Files.delete(dir);
                return FileVisitResult.CONTINUE;
            }
        });
    }
}

示例应用程序的输出：

Created temporary directory: /tmp/watch-service-example4292865635932187600
Created watched directory: /tmp/watch-service-example4292865635932187600/watched_0
Created watched directory: /tmp/watch-service-example4292865635932187600/watched_1
Created watched directory: /tmp/watch-service-example4292865635932187600/watched_2
Created watched directory: /tmp/watch-service-example4292865635932187600/watched_3
Created watched directory: /tmp/watch-service-example4292865635932187600/watched_4
Created watched directory: /tmp/watch-service-example4292865635932187600/watched_5
Created watched directory: /tmp/watch-service-example4292865635932187600/watched_6
Created watched directory: /tmp/watch-service-example4292865635932187600/watched_7
Created watched directory: /tmp/watch-service-example4292865635932187600/watched_8
Created watched directory: /tmp/watch-service-example4292865635932187600/watched_9
Initialization complete. When you create an entry in the watch dirs you'll be notified.
Processing events for watched directory: /tmp/watch-service-example4292865635932187600/watched_5
Received event 'ENTRY_CREATE' for entry 'test' in watched directory '/tmp/watch-service-example4292865635932187600/watched_5'
Processing events for watched directory: /tmp/watch-service-example4292865635932187600/watched_8
Received event 'ENTRY_CREATE' for entry 'test' in watched directory '/tmp/watch-service-example4292865635932187600/watched_8'

Java 监控多个文件夹

Java monitoring multiple folders

java

watchservice