Akka Remoting是否支持單向連接？

Question

我有一個Android設備上運行的Akka系統，它通過Akka Remoting與服務器上的Akka系統進行通信。

Android設備可能會獲得任何IP地址，在應用程序運行時IP可能會更改，並且IP可能無法從服務器訪問。因此我在Android設備上配置了Akka，使用akka.remote.netty.hostname = "0.0.0.0"和akka.remote.netty.port = 8000。

Android Akka系統獲取對服務器上的actor的引用，向它發送消息，服務器上的Actor記錄sender（）actorRef並不斷髮送消息給它。當服務器和Android設備位於相同的無線局域網上，以及他們通過互聯網通過GPRS進行通話時，這種方式就可以工作。

現在我正在仔細研究連接損耗和重新連接。我一直關注的場景是：

• Android設備和服務器都在wlan上。
• Android設備向服務器發送消息。
• Android上的Akka remoting生成RemoteClientStarted。
• 服務器上的Akka遠程處理產生RemoteClientStarted和RemoteServerClientConnected。
• 然後關閉Android上的wlan，等待幾秒後再打開。中間不會嘗試發送消息到服務器。在Android
• 阿卡遠程產生RemoteClientShutdown和RemoteClientError（ETIMEDOUT）
• 服務器上遠程阿卡什麼都不說。
• Android向服務器發送消息。
• 服務器產生RemoteServerClientConnected並接收該消息。
• 服務器嘗試發送消息（稱之爲一個下面的問題）到Android，併產生：RemoteServerError，RemoteServerClientDisconnected，RemoteClientShutdown，RemoteServerClientClosed。
• Android從不會從服務器獲取消息。
• 服務器嘗試發送另一個消息，但Akkas RemoteClient說：
  • [PassiveRemoteClient @阿卡：//xxx@0.0.0.0：8000]已經關閉
  • 啓動遠程客戶端連接到[阿卡：//xxx@0.0.0.0：8000 | /0.0.0.0]
  • RemoteClientError @阿卡：//vts@0.0.0.0：8000：錯誤[...

最後一個錯誤似乎來自於Akka Remote想創建一個新的ActiveRemoteClient而不是重新使用現有的PassiveRemoteClient。我想這也是因爲服務器在看到錯誤/斷開連接/關閉/客戶端關閉之前觀察RemoteServerClientConnected事件。

現在的問題：

1. 在這種情況下發送報文的時候，服務器如何我可以重複使用的Android設備的最後一個進來的連接（PassiveRemoteClient）？
2. 如何指示服務器永遠不要嘗試連接回客戶端？

版本：

• 的Android：15（4.0.3）
• 阿卡：2.1
• 爪哇：1.6 64bits的
• Scala中：2.10.1
• Netty的：3.5 .8

Answer 1

這可能不是真的只是你一直希望得到的答案，但在這裏（我是阿卡科技領先者）。

Akka遠程處理旨在用作對等系統。開發背後的驅動因素是構建集羣支持，該支持從2.1版開始出現，並將從2.2版開始正式支持並進一步開發。這有幾個重要的後果：

• ActorRefs應是位置透明的，這意味着它們的工作方式相同無論你在哪裏使用它們，因此每個節點需要能夠連接到節點，在一個給定的參考點至。
• Akka節點之間的通信基本上是對稱的，即使您的使用可能不是。
• 傳遞ActorRef作爲進行對話的方式意味着通過引用指向的實體需要保持可用或通信失敗;並保持可用意味着「在參考所指的同一位置」。

這對你的場景意味着什麼，你會更好地聯繫你的演員系統，而不是使用簡單的遠程處理，而是使用其他支持短時間關聯的東西。例如，您可以將服務器作爲REST服務公開，或者您可以使用Akka IO層使用裸TCP（或甚至UDP）。在處理服務器端端點的actor中，您可以識別同一個客戶端是否從不同的網絡位置與您通信，緩存回覆消息，僞裝在本地代理角色後面的外部角色等。通過此方案，您甚至可以構建可靠的消息通過你不可靠的渠道（使用ACK），而且美麗的是，在服務器（可能是一個集羣）內，所有的通信都能正常工作，因爲如何與客戶交談的問題部分被封裝在一個地方。

長話短說：您的使用案例不是由簡單的Akka遠程支持開箱即用的。