akka-actor

0熱度

1回答

閱讀akka流的文檔，我不太清楚諸如消息順序之類的東西，以及我是否可以執行它。讓我用我爲聊天服務器編寫的一小段代碼來設置我的問題的上下文。 def flowShape(user: User) = GraphDSL .create(Source.actorRef[ChatMessage](bufferSize = 5, OverflowStrategy.fail)) { impl

0熱度

1回答

阿卡靜態使用

我有一個簡單的演員系統與默認配置。我有一個類擴展演員 class Test extend Actor { def receive: Receive = { case Foo(collection) => sender ! extract(collection) } private def extract(c: List[FooItem]): List[

1熱度

1回答

我應該創建一個新的演員，每次或將其創建爲靜態較早

我用akka.net和內存泄漏，因爲它耗費了大量的內存，並增加所有的時間我應該創建一個新的演員可能發生每次或創建它爲靜態更早？

0熱度

1回答

Akka ActorSystem永遠不會以Java終止

在Java 8中使用Akka 2.5.6我想知道正確的方式來完成ActorSystem，我的代碼的一部分功能是處理一些XML文件並驗證它們，以實現我已經創建了3個角色：控制器，處理器和驗證器。控制器負責啓動進程並通過文件和其他信息向處理器發送文件，然後處理器創建該文件的數字簽名並將響應發送給驗證器，最終驗證狀態並向其發送一條OK消息控制器對正在驗證的文件數進行計數，並將其與總文件進行比較。一旦

1熱度

1回答

在akka演員系統外發送響應

我有一個play（2.4.2其中有akka 2.4.18）應用程序，我正在使用akka actors來上傳文件。我有一個父主管演員用這種層次的UploadSupervisor ---孩子---> UploadActor ---孩子---> DataWriteActor & MetaWriteActor 葉演員MetaWriteActor DataWriteActor執行實際寫入。我的代碼一個非常

0熱度

1回答

阿卡演員的孩子的煩惱

我真的被這種情況感到驚訝。有任何想法爲什麼會發生這種情況？我們，如果孩子是不存在的創建演員：這個每次工作正常。然後發送Ping消息。這一段時間對演員的情況下掛斷已經存在： child(name) getOrElse actorOf(PingActor.props, name) ! GetState 爲什麼？

0熱度

2回答

ExecutionContext導致Akka死信

出於某種原因，我必須同時使用gRPC和Akka。當這個演員成爲頂級演員時，沒有任何問題（在這個小演示中）。但是，當它成爲一個兒童演員，也沒有收到任何消息，並且以下記錄： [default-akka.actor.default-dispatcher-6] [akka://default/user/Grpc] Message [AkkaMessage.package$GlobalStart] from

0熱度

2回答

訪問mixin中的Akka Actor上下文

我想定義一個可以與Akka actor混合的特性，該特性可以在一定的持續時間之後調度接收超時。這裏是什麼，我想要做一個素描...... trait BidderInActivityClearingSchedule[T <: Tradable, A <: Auction[T, A]] extends ClearingSchedule[T, A] { this: AuctionAc

1熱度

1回答

使用演員監督，如何在發生故障時

我下面從akka.io容錯http://doc.akka.io/docs/akka/current/java/fault-tolerance.html .I代碼reference.My要求如下采取這種代碼重試相同的消息與定義的間隔時間定義的數字：讓我們假設演員在消息上崩潰，並由其主管重新啓動。然後他開始在他的郵箱中處理下一個消息。這導致崩潰的消息是「dropped'.But我要處理的時間的

1熱度

1回答

Akka序列化綁定太有限了？

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