2014-10-29 97 views
1

我有一个关于Akka 2.4 TCP API的问题。Scala Akka TCP演员

我运行一个服务器,并在Akka TCP中有两个TCP服务器,一个用于传入客户端,另一个用于我的服务器的工作节点(位于其他计算机/ IP上)。我有一个当前连接到客户端,并有一个连接到一个工作节点。

如果接收到来自客户端的消息,我想将某些信息传递给工作节点,但是表示工作节点连接的TCP Akka Actor似乎并不喜欢我从运行客户端的线程Akka Actor,发送消息给Akka Actor worker节点。例如,如果客户端发送消息来删除文件,并且该文件上的分区位于工作者节点上,那么我想向该工作器节点发送一条TCP消息,以便删除该分区。

我该如何从客户端角色向工作者节点Actor发送消息,它应该通过TCP传递给工作节点服务器?当只是做正常的workerActorRef ! msg它根本没有收到它,并没有显示日志。

我希望这个问题不明确,但是基本上我想要的workerActorRef以某种方式能够有类似的一些功能“通过TCP套接字发送这个”。

干杯,

约翰

+1

您是否看过Akka Remoting:http://doc.akka.io/docs/akka/2.3.6/scala/remoting.html。如果使用得当,它应该能够实现你想要的。你可能也想看看Clustering,因为它是建立在Remoting之上的:http://doc.akka.io/docs/akka/2.3.6/scala/cluster-usage.html – cmbaxter 2014-10-29 18:37:56

+0

@cmbaxter如果你把它写成回答我会接受它。谢谢 – 2014-10-31 15:00:31

回答

3

你有没有看着Akka Remoting呢?如果使用得当,它应该能够实现你想要的。你可能也想看看Clustering,因为它是建立在Remoting之上的。

+0

看起来正是我所需要的。再次感谢! – 2014-10-31 15:24:41