Служба часов JAVA 7

У меня есть тот же вариант использования, и я удивлен, что не нашел много полезного в Интернете для такого распространенного сценария. Я вижу некоторые проблемы в следующем подходе. Допустим, мы используем метод walkTree для сканирования существующих файлов в каталоге, а затем регистрируем каталог для WatchService.

1. Files.walkTree(...);
2. Path dir =  Paths.get(...);
3. WatchService watcher = dir.getFileSystem().newWatchService();       
4. dir.register(watcher, StandardWatchEventKinds.ENTRY_CREATE);
5. // other logic

Как насчет файлов, которые создаются после окончания строки 1 и до начала строки 5. Я просто использую это как грубую границу, чтобы облегчить обсуждение. Реальные границы окна возможности потери файлов могут быть еще шире.

WatchService справляется только с изменениями в файловой системе. Файлы, которые уже есть, не были изменены и, следовательно, не извлекаются службой WatchService. Вам нужно будет рекурсивно просмотреть все файлы и каталоги, чтобы получить начальный «представление» файлов:

Files.walkFileTree(basePath, new SimpleFileVisitor<Path>() {
            @Override
            public FileVisitResult visitFile(Path file,
                    BasicFileAttributes attrs) throws IOException {
                // do something with the file
                return FileVisitResult.CONTINUE;
            }

            @Override
            public FileVisitResult preVisitDirectory(Path dir,
                    BasicFileAttributes attrs) throws IOException {
                // do something with the directory
                return FileVisitResult.CONTINUE;
            }
        });

Все изменения, происходящие после инициализации, перехватываются WatchService.

WatchService отслеживает зарегистрированные объекты на предмет определенных типов изменений и событий. Код вызывается, когда происходит событие, которое мы слушаем. Мы можем отслеживать создание, удаление или изменение файла(ов):

• ENTRY_CREATE
• ENTRY_DELETE
• ENTRY_MODIFY

При использовании

WatchKey watchKey = path.register(watchService, StandardWatchEventKinds.ENTRY_CREATE);

… будут сообщены только вновь созданные файлы. Чтобы просмотреть уже созданные файлы, используйте:

StandardWatchEventKinds.ENTRY_MODIFY