在scala中運行並行程序

Question

我能夠創建角色並在本地運行它們。但是現在我想讓演員在網絡上連接的計算機上運行代碼。假設我想創建演員來查找數字的階乘。

object FactorialAll extends Actor{ 
    def receive = { 
    case (n:Int)=> 
     for(i<-1 to n){ 
      var factorActor = context.actorOf(Prop[FactorActor],"factorActor") 
      factorActor ! Factorial(i) 
     } 
    case Result(n:Int,fact:BigInt)=> 
     println("factorial of " + n + " is "+fact) 
    } 
} 

我們發送一些int給這個Actor。

如何創建並運行FactorActor實例以在網絡上運行。

Answer 1

要只是將消息發送到遠程的演員，你需要阿卡遠程處理：http://doc.akka.io/docs/akka/current/scala/remoting.html

然後，你可以得到遠程演員和發送信息，如：

val selection = 
    context.actorSelection("akka.tcp://actorSystemName@host:1234/user/actorName") 

selection ! "fooBar"