如何从标准输入获取演员消息？

Question

我想知道是否有可能（以及如何）让 akka actor 接收来自 stdin 的消息。本质上，这个想法是将每一行输入作为消息发送给参与者，例如

> myprogram
DO X
DO Y
...

，然后让参与者接收消息“DO X”、“DO Y”等。

是否有标准解决方案可以做到这一点？

我想一种方法是这样做：

spawn {
    while(in.available) {
        actor ! in.readLine
    }
}

但是我有两个演员（或者一个基于演员的任务和一个演员），并且我会使用阻塞 IO（顺便问一下，这对于演员来说安全吗？）。 ..此外，它使得控制生成块变得更加困难（例如杀死任务）。

添加了来自 OP 的进一步跟进

如果您允许的话，我有几个跟进...

1. 使用此解决方案是否会影响性能（即 CamelServiceManager启动很多东西吗？HTTP 服务器等）？

2. 有适合​​初学者的良好教程吗？我开始从官方 Akka 文档中阅读 Camel ，但似乎假设对 Camel 的了解比我目前拥有的更多。例如，我不知道如何使用自定义 java.io.InputStream 作为 endpointUri。

Answer 1

您可以将 akka-camel 与 camel-stream 组件让参与者从标准输入接收消息。这是一个工作示例：

import akka.actor.Actor
import akka.camel.{Message, CamelServiceManager, Consumer}

object Example extends App {
  CamelServiceManager.startCamelService
  Actor.actorOf[ExampleConsumer].start
}

class ExampleConsumer extends Actor with Consumer {
  def endpointUri = "stream:in"
  def receive = {
    case msg: Message => println("received %s" format msg.bodyAs[String])
  }
}

更新： 后续问题的解答

• CamelServiceManager.startCamelService 方法启动一个 CamelContext 和两个新注册的 Akka Actor在 CamelContext 处启动了 Consumer actor 端点。没有启动 HTTP 服务器。
• Apache Camel：集成涅槃 文章和 rel="nofollow">骆驼在行动一书。 Camel in Action 的附录 E 是对 akka-camel 的介绍。
• 目前，camel-stream 组件无法在端点 URI 处设置自定义 InputStream。