在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"