java - 从正在使用 Java 主动写入的文件中读取 [改进]

Question

我想从一个正在被另一个应用程序/进程写入的文件中读取。

我在另一个问题中找到的这段代码完成了这项工作:它在写入文件时读取文件，并且只读取新内容。

即使没有向文件添加数据，它也会消耗大量 CPU 的问题。我该如何优化这段代码？

• 使用计时器？或 thread.sleep 暂停？

要补充的另一件事是，我尝试编写的整个程序实时读取文件并处理其内容。所以这意味着 thread.sleep 或计时器将暂停我的整个程序。我正在寻找的理想改进不是等待几秒钟，而是等待某个事件发生 => 添加新数据。这可能吗？

public class FileReader {

    public static void main(String args[]) throws Exception {
        if(args.length>0){
            File file = new File(args[0]);
            System.out.println(file.getAbsolutePath());
            if(file.exists() && file.canRead()){
                long fileLength = file.length();
                readFile(file,0L);
                while(true){

                    if(fileLength<file.length()){
                        readFile(file,fileLength);
                        fileLength=file.length();
                    }
                }
            }
        }else{
            System.out.println("no file to read");
        }
    }

    public static void readFile(File file,Long fileLength) throws IOException {
        String line = null;

        BufferedReader in = new BufferedReader(new java.io.FileReader(file));
        in.skip(fileLength);
        while((line = in.readLine()) != null)
        {
            System.out.println(line);
        }
        in.close();
    }
}

Answer 1

The ideal improvement I am looking for is not to wait few seconds, but for a certain event to happen => New data is added. Is this possible ?

最佳解决方案:数据推送:

产生内容的应用程序应该通知其他应用程序，因为它可能会读取内容。

您可以使用任何可以在两个不同应用程序之间传递信息的 channel 。

例如，通过使用作者更新的特定文件来通知要读取的新内容。
写入者可以在此文件中写入/覆盖一个更新日期，而读取者只有在自该日期以来未读取任何内容时才会读取数据文件。

一种更健壮但开销更大的方法可能是从阅读器端公开通知服务。
为什么不是 REST 服务。
这样，当新内容准备就绪时，作者可以通过该服务通知读者。

Another thing to add, the whole program I am trying to write reads a file in real-time and process its content. So this means that thread.sleep or the timer will pause my whole program.

变通解决方案:由特定线程执行数据拉取:

你可能有一个多核 CPU。
因此，创建一个单独的线程来读取生成的文件，以允许您的应用程序的其他线程运行。
此外，您还可以执行一些常规暂停:Thread.sleep() 以优化读取线程完成的核心使用。

它可能看起来像:

Thread readingThread = new Thread(new MyReadingProcessing());
readingThread.start();

MyReadingProcessing 是一个 Runnable :

public class MyReadingProcessing implements Runnable{

     public void run(){
          while (true){
               readFile(...);
               try{
                  Thread.sleep(1000); // 1 second here but choose the deemed reasonable time according the metrics of your producer application
               }  
               catch(InterruptedException e){
                  Thread.currentThread().interrupt();
               }
               if (isAllReadFile()){ // condition to stop the reading process
                   return;
               }
          }
     }
}