akka

0熱度

1回答

什麼是發送到快照存儲的郵件的傳遞保證，如DeleteSnapshot,SaveSnapshot等？它是至少一次還是最多一次？換句話說，如果我打電話給SaveSnapshot()，我保證會收到SaveSnapshotSuccess/Failure，或者只有在快照實際接收並接受或拒絕它們時纔會收到它們？

0熱度

1回答

演員中的阻止操作不佔用所有默認調度員

我最近正在學習Akka Actor。我讀了演員中調度員的文件。我對演員中的阻止操作感到好奇。文檔中最後的topic描述瞭如何解決該問題。我試圖重現文檔中的示例實驗。這裏是我的代碼： package dispatcher import akka.actor.{ActorSystem, Props} import com.typesafe.config.ConfigFactory obje

0熱度

1回答

如何處理定製的阿卡水槽內的未來？

我想實現一個定製的Akka接收器，但是我找不到處理它內部未來的方法。 class EventSink(...) { val in: Inlet[EventEnvelope2] = Inlet("EventSink") override val shape: SinkShape[EventEnvelope2] = SinkShape(in) override def

0熱度

1回答

我想創建一個簡單的單例集羣並從遠程節點發送消息

在這裏，我創建了一個單身演員。主節點和種子節點是相同的。從一個不同的項目中，我嘗試添加到羣集中並想發送消息。我能夠加入羣集，但無法發送消息。我的主人和種子節點： package Demo import akka.actor._ import akka.cluster.singleton.{ClusterSingletonManager, ClusterSingletonMa

0熱度

1回答

訪問Actor中的AKKA郵箱對象

我正在使用我的Akka actor的自定義郵箱。我的類看起來是這樣的： MyActor extends Actor with RequiresMessageQueue[DRMailbox]{ ... } 我如何可以訪問阿卡演員DRMailbox對象？我已在DRMailbox中實施了一些方法，我想與我的Akka演員分享。

0熱度

1回答

通過Akka演員參考其他演員

我有一個演員，我與另一個演員（家長）創建。我還從父代中產生了其他幾個Actor。樹的樣子： ParentActor -- ServiceActor -- ProcessActor1 -- ProcessActor2 現在我想通過解決此ServiceActor實例ProcessActor情況，但問題是，ServiceActor可能窒息在某個時候被殺死。我在父母身上處理這個問題，併爲Serv

2熱度

1回答

在akka中定義額外路徑

我對akka很新穎。我有一個html，css，jv模板，我需要把它放到我們的服務器上。 package com.example import akka.http.scaladsl.marshallers.xml.ScalaXmlSupport.defaultNodeSeqMarshaller import akka.http.scaladsl.server.{ HttpApp, Route }

0熱度

1回答

同一個演員的不同調度員

看着我的日誌文件，我看到了同一個演員的不同調度員。那個演員是一次創造的，所以它怎麼可能？這是否意味着演員由於崩潰而重新啓動？例如： [錯誤] [2017年8月7日19：20：22.618] [我-SYS-akka.actor.default-調度-21] [阿卡：//我-SYS /用戶/ com.domain.FooActor] some_exception [錯誤] [2017年8月7日19：

0熱度

1回答

阿卡演員的選擇與語境孩子

所以好像我有兩個可能獲得兒童演員實例的保持：通過使用context.actorSelection，它返回一個Future[ActorRef] context.actorSelection(actorNameString).resolveOne(2.seconds) 通過使用context.child，它返回一個Option[ActorRef] context.child(actorNameStr

0熱度

1回答

不要立刻停止孩子Akka演員時，父母演員停止

我有一個演員p: ParentActor，我想要做一些清理工作，當它通過使用postStop方法停止。其中一項工作涉及向兒童演員c: ChildActor發送消息。之後，應該停止c，然後p。但是，一旦context.stop(p)被稱爲c似乎立即停止並且無法接收消息。下面是想我做的一個例子： class ParentActor extends Actor { ... over