java - 如何在文件行出现时读取它们并将其表示为Flux？

假设我们依赖Reactor 3(即在Spring 5应用程序中)和文本文件my/file.txt。

我需要订阅文本文件行(既有现有文件行，也有将来将出现的行)并创建Flux<String>。如果您愿意，忽略阻塞IO会引起您的关注，让我们仅揭示构建此类订阅的原理。

为了简单起见，假设我们将这些行打印到std输出:

flowLinesFrom(Path.of("my/file.txt"))
   .subscribe(System.out::println);

实现Flux<String> flowLinesFrom(Path)的正确方法是什么？

最佳答案

您可以像这样使用this

//Create FluxTailer
FluxTailer tailer = new FluxTailer(
    //The file to tail
    Path.of("my/file.txt").toFile(),
    //Polling interval for changes
    Duration.ofSeconds(1)
);

//Start tailing
tailer.start();

//Subscribe to the tailer flux
tailer.flux().subscribe(System.out::println);

//Just for demo you wait for 10 seconds
try{
    Thread.sleep(10000);
}catch (Exception e){}

//Stop the tailer when done, will also complete the flux
tailer.stop();

您可以根据需要开始停止，也可以使用以下命令设置从文件的开头或结尾读取

tailer.readFromStart();
tailer.readFromEnd();