如何在 Scala 中流式传输标准输出？

Question

基本上，我有一个输出到标准输出的程序。我正在我的 Scala 代码中运行该程序。我现在要做的是将输出重定向到文件。像这样。

val cmd = progName + " " + arguments 
cmd #> new java.io.File(outputFilePath) !

我还必须稍后处理该输出文件。这就是为什么这种方法很慢，因为我必须首先等待程序完成并将所有内容写入输出文件。我更喜欢流式传输标准输出的内容，以便在流式传输时从另一个线程读取内容。这样，我可以在我从 Scala 运行的程序运行时处理数据。

此外，输出文件中的数据由换行符分隔。有没有办法，可以在程序运行的时候逐行获取数据。

最后，Java 中有什么东西可以做到这一点，然后我也可以在 Scala 中使用它吗？

Answer 1

ProcessBuilder 有一个lineStream 方法，我认为它完全符合您的要求。它返回一个Stream[String]，让您在输出可用时对其进行处理。

这是一个简单的程序，输出速度很慢，我保存为slow-printer.scala：

// slow-printer.scala
for (i <- 1 to 10) {
  println(i)
  Thread.sleep(1000)
}

您可以像这样从程序中流式传输输出（每秒 1 行）：

import scala.sys.process._

val lines = "scala slow-printer.scala".lineStream

lines foreach println

---

如果您坚持使用 2.10，或者如果您的输出不是换行符分隔，那么您可以使用 ProcessIO 来处理输出：

import scala.sys.process._

Seq("scala", "slow-printer.scala").run(new ProcessIO(
  _.close(), // stdin
  out => { // stdout
    val src = scala.io.Source.fromInputStream(out)
    for (line <- src.getLines()) {
      println(line)
    }
  },
  _.close() // stderr
))