Java - RandomAccessFile（模拟Linux tail函数）

Question

unix/linux“tail -f”的Java IO实现有类似的问题；但该解决方案对于每秒生成约 50-100 行的日志文件不可行。

我有一个模拟 Linux 中尾部功能的算法。例如，

File _logFile = new File("/tmp/myFile.txt");
long _filePtr = _logFile.length();

while (true)
{
     long length = _logFile.length();
     if (length < _filePtr)
     {
            // means file was truncated
     }
     else if (length > _filePtr)
     {
            // means something was added to the file
     } 
// we ignore len = _filePtr ... nothing was written to file
}

我的问题是：“某些内容被添加到文件中”（指 else if() 语句）。

else if (length > _filePtr)
{
     RandomAccessFile _raf = new RandomAccessFile(_logFile, "r");
     raf.seek(_filePtr);

     while ((curLine = raf.readLine()) != null)
           myTextPane.append(curLine);

        _filePtr = raf.getFilePointer();
        raf.close();
}

程序在运行 15 秒后阻塞在 while ((curLine = raf.readLine())....（注意：程序在前 15 秒内运行正确）。

看起来 raf.readLine()永远不会达到 NULL，因为我相信这个日志文件写入的速度太快，以至于我们进入了“无尽的猫和老鼠”循环

模拟 Linux 尾巴的最佳方法是什么？

Answer 1

我认为最好的方法是根据文件的长度抓取一个字节块，然后释放文件并解析 ByteArrayInputStream （而不是尝试直接从文件中读取）。

因此，请使用 RandomAccessFile#read(byte[])，并使用返回的文件长度调整缓冲区大小。您不会总是显示文件的确切结尾，但这是这种轮询算法所期望的。

顺便说一句，这个算法很糟糕 - 你正在一个疯狂的紧密循环中运行 IO 操作 - 对 File#length() 的调用会阻塞，但不会太多。希望这个例程能够让您的应用程序在 CPU 方面陷入困境。我不一定能为您提供更好的解决方案（实际上，我确实有 - 让源应用程序写入流而不是文件 - 但我认识到这并不总是可行）。

除了上述之外，您可能还想引入轮询延迟（每个循环让线程休眠 100 毫秒 - 在我看来，就像您正在向 GUI 显示一样 - 100 毫秒的延迟不会伤害任何人，并且会大大提高性能摆动操作）。

好的 - 最后的牛肉：您正在调整 Swing 组件（我希望）是不在 EDT 上运行的代码。使用 SwingWorker#invokeLater() 更新文本窗格。

Answer 2

看来我已经找到了问题并创建了解决方案。

在 else if 语句下：

while ((curLine = raf.readLine()) != null)
    myTextPane.append(curLine);

这就是问题所在。 myTextPane（JTextPane 的派生类）的append(String) 方法在每一行追加上引发“setCaretPosition()”，这是错误的！

这意味着 setCaretPosition() 被调用为 50-100 Hz 试图“向下滚动”。这导致了接口的阻塞开销。

一个简单的解决方案是创建一个 StringBuffer 类并附加“curLine”，直到 raf.readLine() 读取 null。

然后，附加 StringBuffer 并瞧... setCaretPosition() 不再阻塞！

感谢凯文带领我走向正确的方向。

Answer 3

您始终可以执行 tail 程序：

    BufferedReader in = new BufferedReader(new InputStreamReader(
            Runtime.getRuntime().exec("tail -F /tmp/myFile.txt").getInputStream()));
    String line;
    while ((line = in.readLine()) != null) {
        // process line
    }