2014-10-29 124 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