我有一個關於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套接字發送這個」。
乾杯,
約翰
您是否看過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
@cmbaxter如果你把它寫成回答我會接受它。謝謝 – 2014-10-31 15:00:31