remote-actors

6熱度

2回答

每當一個actor在scala中接收到一條消息時，我們可以通過使用關鍵字'sender'（這是AbstractActor特性的一個對象）來訪問該actor的發送者。我的問題這個'發件人'在收到郵件時變得可以訪問。還有，我們可以重寫這個實現，其中與發送者一起還可以訪問其他數據，例如ipaddress，數據來自的端口。據我所知，沒有辦法可以從消息來源的地方獲得ip地址和端口。有什麼辦法可以從這個

0熱度

2回答

我們如何覆蓋scala actors的反應結構？

的檢測斯卡拉演員收到消息的類型通常的方法是通過 loop{ react{ case x: String => } } 不過，我想知道我們如何可以覆蓋這個實現的反應構造，使我們可以做到信息的隱含日誌記錄收到。我想實現下面提到的用例 - > 1.在消息與任何case類匹配之前，我想在控制檯/文件上寫一條日誌語句來顯示消息的發生。 2.我們可以通過p

7熱度

1回答

如何發送消息到鄰居jvm中的akka系統？

我在一個JVM中啓動了帶有HelloActor的akka系統，並試圖從另一個JVM中的客戶端向它發送消息。沒有任何工作。我應該如何正確地做到這一點？下面是代碼：簡單的服務器 package akkaSample.severalSystems import akka.actor.{Props, Actor, ActorSystem} import com.typesaf

2熱度

1回答

沒有一個新的ActorSystem遠程創建一個Akka演員

我已經多次通過文檔（http://doc.akka.io/docs/akka/2.1.4/scala/remoting.html），並通過這裏的例子（https://github.com/akka/akka/tree/master/akka-samples/akka-sample-remote）和其他人，我仍然無法弄清楚如何做我的想做。我找到的最接近的答案是這樣的：how to start rem

6熱度

2回答

Akka遠程參與者，沒有默認構造函數的超類

我想使用akka遠程參與者發送消息，其中case類是在其構造函數中採用參數的超類的子類。下面是重現該問題的最低限度例如： package com.tuvistavie.testremote import akka.actor.{ Actor, ActorSystem, Props, ActorLogging } import com.typesafe.config.ConfigFactor

0熱度

1回答

斯卡拉在同一臺機器上的遠程演員

我是新來的scala，並試圖使用Actor模型。我一直在用同一臺機器上的演員工作。現在，我想使用遠程演員來更進一步。由於我只有一個盒子一起玩，我打算啓動一個進程階將作爲遠程演員 remote.scala看起來像 import scala.actors._ import scala.actors.remote._ import scala.actors.remote.RemoteActor

0熱度

1回答

無法綁定到Akka Actor系統的遠程IP地址

我在初始化遠程IP地址上的actor系統時遇到了問題。我正在使用akka演員和戲劇！框架。代碼和遠程參與者系統都在遠程機架空間服務器上。當我嘗試在其他服務器上創建遠程參與者系統時，它無法綁定到該IP地址。我不認爲這是一個網絡或防火牆問題，因爲Rackspace說他們打開了服務器之間的所有連接。這是錯誤消息我得到： [error] application - ! Internal server

3熱度

2回答

Akka 2.1遠程：跨系統共享演員

我在學習有關Akka 2.1中的遠程演員，並試圖修改counter example provided by Typesafe。我從控制檯實現了一個quick'n'dirty UI來發送滴答。並要求（並顯示結果）當前計數退出。這個想法是啓動一個主節點，它將運行Counter actor和某個客戶端節點，該節點將通過遠程處理向其發送消息。不過，我想通過配置和代碼的最小改變來實現這一點。所以通過改變

0熱度

1回答

斯卡拉system.shutdown不工作

我正在發送一個演員的消息來殺死另一個演員。接收者actor執行context.system.shutdown。儘管actor完全接收消息並執行case語句中指定的代碼，但它不會關閉。出了什麼問題？接收方actor的接收方法。 def receive = { ... case "KILL" => context.system.shutdown }

2熱度

3回答

等待阿卡角色系統變得可用

我使用AKKA 2.1和Scala 2.10。我需要多臺機器來啓動actor系統並實例化一些actor。之後，每個系統都需要訪問所有其他系統，並使用「actorFor（...）」來收集對其演員的引用。但是，我需要一個actor系統等待其他系統在連接之前啓動的方式，否則我會遇到錯誤。如果演員系統A在B離線時連接到B，則我的程序將失敗。但是，如果A連接到B並在B上存在遠程參與者引用之前獲得它，那