akka-remote-actor

1熱度

1回答

是否有可能進一步限定序列化綁定？運行時類型看起來太有限了。例如我有我現在無法序列ToDo[MyPayload]用不同的串行比ToDo[OtherPayload]（甚至在不同的演員！），因爲其運行時類的名字是相同的（PersistentExecutorProtocol$ToDo）。我錯過了什麼嗎？ - 引入AProtocolClass或使PersistentExecutorProtocol和

1熱度

1回答

java akka默認序列化器警告

我不想禁用警告消息，因爲我想知道如何完成建議來定義序列化器以提高性能？ [INFO] [06/24/2016 19:28:34.659] [main] [akka.remote.Remoting] Starting remoting [INFO] [06/24/2016 19:28:34.827] [main] [akka.remote.Remoting] Remoting started; l

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

1熱度

1回答

Akka.NET：無法發送列表消息給其他演員系統

我是Akka.NET的新手。我最近開始做我的大學項目並面臨奇怪的問題。我在兩個不同的桌面應用程序中有兩個ActorSystems。在第一個ActorSystem中，我使用Akka.Remote在兩個演員之間發送消息ZippedAddressListMessage。 public class ZippedAddressListMessage { public ZippedAd

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

0熱度

1回答

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

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

0熱度

2回答

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

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

1熱度

1回答

錯誤：從Actor到Actor的消息未送達。[1]遇到死信。分佈式pub-sub跨羣集工作不起作用

我試圖在不同的羣集系統上創建分佈式pub-sub，但它無法正常工作。我想要做的就是創建一個簡單的例子。 1）我創建了一個話題，說「內容」。 2）say jvm A中的一個節點創建該主題，訂閱該主題以及發佈該主題的發佈者。 3）在一個不同的節點上，比如jvm B在不同的端口上，我創建一個訂戶。 4）當我從jvm A向主題發送消息時，我想讓jvm B上的訂閱者收到它，因爲它訂閱了同一主題。任何幫助

1熱度

3回答

Akka - 創建遠程演員

我試圖在遠程主機上創建Akka Actor。繼官方文檔之後，我創建了一個遠程Actor系統解析application.config文件，然後創建一個新的actor。這是我的代碼： public static void main(String[] args) { Config config = ConfigFactory.parseFile(new File("application