Блог

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

Возможно, есть лучшее предложение???

  package net.codejava.io;

import static java.nio.file.StandardWatchEventKinds.ENTRY_CREATE;
import static java.nio.file.StandardWatchEventKinds.ENTRY_DELETE;
import static java.nio.file.StandardWatchEventKinds.ENTRY_MODIFY;

import java.io.BufferedWriter;
import java.io.File;
import java.io.FileWriter;
import java.io.IOException;
import java.io.RandomAccessFile;
import java.nio.channels.FileChannel;
import java.nio.channels.FileLock;
import java.nio.file.FileSystems;
import java.nio.file.Path;
import java.nio.file.Paths;
import java.nio.file.WatchEvent;
import java.nio.file.WatchKey;
import java.nio.file.WatchService;
import java.sql.Timestamp;
import java.util.Date;


public class DirectoryWatchDemo {

    static String logfile = "C:/Temp/log.txt";

    volatile static boolean suspended = false;

    public static void main(String[] args) {
        try {
            WatchService watcher = FileSystems.getDefault().newWatchService();
            Path dir = Paths.get("C:/Temp/");
            dir.register(watcher, ENTRY_CREATE, ENTRY_DELETE, ENTRY_MODIFY);
            // System.out.println("Watch Service registered for dir: "  
            // dir.getFileName());

            while (true) {
                WatchKey key;
                try {
                    key = watcher.take();
                } catch (InterruptedException ex) {
                    return;
                }

                if (!suspended) {
                    resume();

                } else {
                    updateFile();
                    suspend();

                }

                if (key.isValid())

                    for (WatchEvent<?> event : key.pollEvents()) {
                        WatchEvent.Kind<?> kind = event.kind();

                        @SuppressWarnings("unchecked")
                        WatchEvent<Path> ev = (WatchEvent<Path>) event;
                        Path fileName = ev.context();
                        System.out.println(kind.name()   ": "   fileName);
                    }

                boolean valid = key.reset();
                if (!valid) {
                    System.out.println("Watch service invalid");
                    break;
                }
            }

        } catch (IOException ex) {
            System.err.println(ex);
        }
    }

    private static void suspend() {
        suspended = false;

    }

    private static void resume() {
        suspended = true;

    }

    public static void updateFile() {

        try {
            File outfile = new File(logfile);
            if (!outfile.exists()) {
                System.out.println("No file exists...writing a new file");
                outfile.createNewFile();
            }
            FileWriter fw = new FileWriter(outfile.getAbsoluteFile(), true);
            BufferedWriter bw = new BufferedWriter(fw);
            bw.write("TimeStamp: "   new Timestamp(new java.util.Date().getTime()).toString()   "rn");
            bw.flush();
            bw.close();
            System.out.println("done");
        } catch (IOException e) {
            e.printStackTrace();
        }
    }
}
  

Вам нужно прервать поток, который использует службу наблюдения, потому что это единственный способ выйти из watcher.take() него. Пример с потоками старой школы:

 public void start() {
    thread = new Thread(directoryWatchDemo::watch);
    thread.start();
}

public void pause() throws InterruptedException {
    if (thread.isAlive()) {
        thread.interrupt();
        thread.join();
    }
}
  

Смотрите ExecutorService, например Executors.newSingleThreadExecutor() и Future.cancel() для большей гибкости.

В качестве альтернативы, вы можете take() все события и игнорировать их на основе volatile boolean .