akka-remote-actor

    5熱度

    1回答

    我正在體驗我正在製作的工具的akka​​遠程功能。實際上,我能夠在不同端口的同一臺主機上運行核心和遠程系統。請注意,我的遠程服務器通過路由器運行,如akka文檔中所述。 現在我試圖使用幾個天藍色的虛擬機來做出更好的實驗,但我遇到了一些問題。 核心應用有以下配置(我已經改變了出於安全原因,一些名字): akka.actor.deployment { /querierActor/querie

    0熱度

    1回答

    用Spark做我的第一步,我面臨着從應用程序代碼提交作業到集羣的問題。挖掘日誌,我注意到一些週期性WARN消息上主日誌: 15/10/08 13:00:00 WARN remote.ReliableDeliverySupervisor: Association with remote system [akka.tcp://[email protected]:64014] has failed, a

    0熱度

    2回答

    我下面這個教程 http://alvinalexander.com/scala/simple-akka-actors-remote-example 我關注的,因爲它是,但我的程序不運行它給我的錯誤,我很困惑此行: val remote = context.actorFor("akka://[email protected]:5150/user/RemoteActor") 我必須寫什麼來代替「用

    0熱度

    1回答

    在羣集環境中,我們通過DistributedPubSub調解器發送郵件。所以,當發送消息時,我們有一些機器在羣集中無法訪問。這些機器在「autodowning」過期之前再次可達,那麼這些機器確實會收到消息。 這是否意味着DistributedPubSub調解器可以爲羣集中不可到達的成員存儲消息,並在它們再次變爲可達時傳遞它們?

    1熱度

    1回答

    我有2個應用程序說app1和app2。在機器1上,app1和app2都運行,但在機器2上只運行app2,因爲大部分工作都由app2完成。這些應用程序使用Akka。 使用akka遠程處理,我希望能夠將消息從機器1上的app1傳遞給機器2上的app2。當app1和2在同一臺機器上時,它們能夠互相交互。 然而,當機器1名試圖應用程序1與APP2機2它得到下面誤差上連接... EndpointWriter

    0熱度

    1回答

    您好我想包裝AskTimeOutException併發送正確的消息.... class Application @Inject()(system: ActorSystem) extends Controller { def index = Action { Ok("Welcome")} val ref: ActorSelection = system.actorSelectio

    2熱度

    1回答

    在我的項目中,我想使用遠程演員,並已成功嘗試並測試它們作爲Scala-SBT項目。 但是,當我試圖在Android中做同樣的事情。以下錯誤出現了 com.typesafe.config.ConfigException$Missing: No configuration setting found for key 'akka.version' 這裏是它加載配置代碼並使用Scala中,SBT項目工

    0熱度

    1回答

    對於akka集羣,是否可以查詢集羣中當前有哪些成員?如果種子節點出現故障並最終恢復正常,是否可以找出其他成員將其用作種子節點的其他成員?

    -1熱度

    1回答

    道具我創建這個演員: ActorRef eventActor = system.actorOf(Props.create(EventActor.class,1),name); 現在,我要檢索的道具1,但我不能。你可以幫我嗎??