拦截 STDOUT 并通过 akka 进行流式传输

Question

是否可以拦截任何其他进程的STDOUT并通过akka流流式传输它们？

谢谢

阿伦

Answer 1

请不要立即在此处交叉发布您的问题和akka-user，这使得跟踪已回答的问题变得更加困难。如果一段时间后您没有收到答复，可以交叉发布，但请不要立即这样做。

为了在Java中"拦截"stdout，你可以在System对象上setOut。它需要一个 PrintWriter，我们可以通过包装 Akka Streams 提供的 OutputStream "桥接器"来创建它，方法如下：

 val is: OutputStream = StreamConverters.asOutputStream()
   .to(Sink.foreach(println)) // your logic pipeline here
   .run()
 System.setOut(new PrintStream(is))