akka-remoting

1熱度

1回答

我正在將Play 2.3.x應用程序遷移到Play 2.5.x，並且在使用依賴注入時遇到了一些問題。在2.3中，我有一個特性HasRemoteActor，控制器會根據配置混合引用一些遠程參與者。由於這需要應用程序的配置對象，現在要求它變成一個類，因此可以注入配置。這裏是我的嘗試： /* Dummy controller that has environment and configur

2熱度

1回答

如何使用Akka Remoting通過CLI將消息發送給遠程演員？

我有一個遠程演員，Bar和本地演員Foo。我希望使用Foo在每次調用CLI時將消息傳遞給Bar。 Bar可以成功傳遞消息，但Foo在等待消息時掛起。爲了解決這個問題，我在Foo的最後添加了一個sys.exit(0)。這會導致與Foo的系統有關聯問題。如何在連續CLI發行之間關閉本地演員而不手動殺死本地演員？閉嘴，給我代碼！的Foo： build.sbt name := "Foo" ver

0熱度

1回答

創建遠程演員以編程方式不起作用

我正在以編程方式創建遠程演員演員。以下是節目 - package remoting.programatic.demo import akka.actor.{ActorSystem, Props} import com.typesafe.config.ConfigFactory import remoting.config.demo.RemoteActor object RemoteA

0熱度

1回答

來自RemoteDeadLetterActorRef的SelectChildName消息

我有兩個通過akka遠程通信的角色系統。當我看看JVM堆時，我看到（太）akka.dispatch.Envelope的許多實例包含來自akka.remote.RemoteActorRefProvider$RemoteDeadLetterActorRef的SelectChildName消息。這些消息的保留堆非常大，並導致內存問題。這些SelectChildName消息的目的是什麼？有沒有辦法避

0熱度

1回答

AKKA：關於編程式遠程部署的困惑

我正在使用akka remote deployment。我使用日誌記錄來確保角色是否已成功部署到遠程。這是我的日誌信息 [adaptiveCEP-akka.actor.default-dispatcher-18] [akka.tcp://[email protected]:2555/remote/akka.tcp/[email protected]:2554/user/disjunction/si

3熱度

1回答

維護Akka Streams中涉及多個JVM的背壓的方法

我知道，從Akka 2.4.16開始，沒有「遠程」實現Reactive Streams。規範側重於在單個JVM上運行的流。但是，考慮用例涉及另一個JVM進行某些處理，同時保持背壓。這個想法是有一個主要的應用程序，提供一個運行流的用戶界面。例如，這個流有一個階段執行一些重要的計算，應該運行在不同的機器上。我感興趣的方式來運行在分佈式的方式流 - 我一些相關的文章來指出一些想法：通過TCP連接流使

0熱度

1回答

向觀看特定演員的演員廣播消息？

如何向所有正在觀看特定演員的演員播放訊息？對於上下文，假設我有一個AuctionActor（這可能是一個遠程角色），正在被大量的AuctionParticipantActor類型監視。我想AuctionActor廣播各種消息到AuctionParicipantActor類型。一種可能性是AuctionActor保留所有參與者ActorRef實例的集合，然後在需要將消息發送給所有參與者時循環該集

0熱度

2回答

串行器是否是從Akka消息中移除共享狀態的正確位置？

我正在使用分佈式算法，並決定使用Akka在機器間進行縮放。機器需要非常頻繁地交換消息，並且這些消息引用每臺機器上存在的一些不可變對象。因此，從消息中共享的，複製的對象不應被序列化的意義上來說，「壓縮」消息似乎是明智的。這不僅可以節省網絡帶寬，而且還可以避免在消息反序列化時在接收端創建重複對象。現在，我的問題是如何正確地做到這一點。到目前爲止，我能想到的兩個選項：處理這種情況「業務層」上，即，將

0熱度

1回答

Akka remote：是否可以使用來自兩個不同應用程序的類沒有相同包名稱的類？

我有兩個應用程序通過Akka遠程通信。我在我的第一個應用程序一類的pachage a： @SerialVersionUID(42L) case class A() 和同樣一個在我的第二個應用程序，但在不同的包b： @SerialVersionUID(42L) case class A() 但是，當我得到由具有類別a的實例的演員消息，由於包名稱不同，我得到java.lang.Class

1熱度

2回答

如何處理陳舊的akka.net遠程iactorref

我在akka.net中使用遠程演員長期保持windows服務。我使用ActorSelection爲遠程actor創建一個IActorRef，並在服務中保持IActorRef長時間處於活動狀態。 IActorRef指向在另一個Windows服務中運行的角色系統。我明白，遠程actor的重啓不會使遠程actor參數失效。但是，可以想象，遠程Windows服務可能會在某個時間點重新啓動，並且調用Win