Using Tailer and WatchService

Question

我使用以下代码同时使用了Tailer和WatchService:

AgentTailerListener listener = new AgentTailerListener();
Tailer tailer;
WatchService watcher = FileSystems.getDefault().newWatchService();
while (true) {
    WatchKey watchKey;
    watchKey = Paths.get("/tmp").register(watcher, ENTRY_CREATE);
    watchKey = watcher.take();
    for (WatchEvent<?> event : watchKey.pollEvents()) {
        if (event.kind() == StandardWatchEventKinds.ENTRY_CREATE) {
            tailSource = event.context().toString();
            System.out.println(tailSource);
            File file = new File("/tmp/" + tailSource);
            String end = "log";
            if (file.getName().endsWith(end)) {
                tailer = TailerFactory.createTailer(file, listener);
                (new Thread(tailer)).start();
            }
        }
    }
    watchKey.reset();
    transport.close();
}

但问题是:我只想用尾部检查一个文件(比如停止线程，但我不能停止特定于文件的线程)，当我用echo命令写入文件时，并不是我写的所有字母都出现。

当我在一行中多次使用echo写入同一文本时，所有的字母都被写入

我看到了这个主题，如何用给定的模式跟踪最新的日志文件，但我不知道我是否可以使用它来解决我的问题(我不知道tail和tailer之间的区别)。

Answer 1

最后，我认为这样更好:

AgentTailerListener listener = new AgentTailerListener();
Tailer tailer;
String tailSource;
Thread thread;
WatchService watcher = FileSystems.getDefault().newWatchService();
WatchKey watchKey;
watchKey = Paths.get("/tmp").register(watcher, ENTRY_CREATE);
List<Thread> threadList = new ArrayList<Thread>();
while (true) {
    watchKey = watcher.take();
    for (WatchEvent<?> event : watchKey.pollEvents()) {
    if (event.kind() == StandardWatchEventKinds.ENTRY_CREATE) {
        tailSource = event.context().toString();
        System.out.println(tailSource);
        File file = new File("/tmp/" + tailSource);
        String end = "log";
        if (file.getName().endsWith(end)) {
            tailer= TailerFactory.createTailer(file, listener);
            if(threadList.isEmpty()){}
            else{
                Thread.sleep(1000);
                threadList.get(0).stop();
                threadList.clear();}
            System.out.println(threadList.size());
            threadList.add(thread = new Thread(tailer));
            threadList.get(0).start();
            }
    }
}
watchKey.reset();
} 

但是它创建了很多线程，我想我必须使用一个固定的线程池