如何使用 AKKA 动态创建远程 Actor 并控制它们

Question

我想做的是：

1) 在服务器上创建一个主actor，它可以在 10 台不同的机器上动态创建 10 个远程actor

2) 主actor将任务分配给10个远程actor

3) 当每个远程actor完成他们的工作时，他们将结果发送给主actor

4) 主actor关闭整个系统

我的问题是：

1) 我不知道如何配置主actor，下面是我的服务器部分代码：

class MasterAppliation extends Bootable{
    val hostname = InetAddress.getLocalHost.getHostName
    val config = ConfigFactory.parseString(
          s"""
            akka{
            actor{
                provider = "akka.remote.RemoteActorRefProvider"
                deployment {
                    /remotemaster {
                        router = "round-robin"
                        nr-of-instances = 10
                        target {
                            nodes = ["akka.tcp://remotesys@host1:2552", "akka.tcp://remotesys@host2:2552", ....... akka.tcp://remotesys@host10:2552"]
                        }
                }
            }
            remote{
                enabled-transports = ["akka.remote.netty.tcp"]
                netty.tcp{
                hostname = "$hostname"
                port = 2552
                }
            }     
          }""")

    val system = ActorSystem("master", ConfigFactory.load(config))        
    val master = system.actorOf(Props(new master), name = "master") 
    def dosomething = master ! Begin()
    def startup() {}
    def shutdown() {
        system.shutdown()
    }
}

class master extends Actor {   
   val addresses = for(i <- 1 to 10) 
       yield AddressFromURIString(s"akka://remostsys@host$i:2552")

   val routerRemote = context.actorOf(Props[RemoteMaster].withRouter(
           RemoteRouterConfig(RoundRobinRouter(12), addresses)))

   def receive = {
     case Begin=>{
       for(i <- 1 to 10) routerRemote ! Work(.....)     
     }
     case Result(root) ........      
   }
}


object project1 {
  def main(args: Array[String]) {                
    new MasterAppliation
  }
}

2) 我不知道如何在远程客户端上创建远程参与者。我读了this tutorial。我需要 编写类似于服务器部分的客户端部分，这意味着我需要创建一个负责创建远程参与者的对象？但这也意味着当我运行客户端部分时，远程参与者已经创建！我真的很困惑。

3) 我不怎么关闭整个系统。在上面的教程中，我发现有一个名为shutdown()的函数，但我从未见过有人调用它。

这是我第一次用 Scala 和 AKKA 编写分布式程序。所以我真的需要你的帮助。 非常感谢。

Answer 1

第一次设置整个东西是一件痛苦的事，但如果你这样做一次，你就会有一个很好的骨架，你会定期使用它。

我在用户集群不远程处理问题下方的评论中写了。

这是我的做法： 我建立了一个包含三个子项目的 sbt 根项目。

• 常见的
• 前端
• 后端

在common 中，您放置了两个项目共有的所有内容，例如他们共享的消息，在前端创建并部署到后端的参与者类。

把reference.conf 放到共同项目中，这是我的：

akka {
loglevel = INFO
actor {
    provider = "akka.cluster.ClusterActorRefProvider"
    debug {
        lifecycle = on
    }
}

 cluster {
      seed-nodes = [
        "akka.tcp://application@127.0.0.1:2558",
        "akka.tcp://application@127.0.0.1:2559"
      ]
  }

}

现在在前端：

akka {


    remote {
        log-remote-lifecycle-events = off
        netty.tcp {
            hostname = "127.0.0.1"
            port = 2558
        }
    }

    cluster {
      auto-down = on
      roles = [frontend]
    }
}

和后端

akka {

    remote {
        log-remote-lifecycle-events = off
        netty.tcp {
            hostname = "127.0.0.1"
            port = 0
        }
    }

    cluster {
      auto-down = on
      roles = [backend]
    }
}

这将像这样工作： 您首先启动将控制集群的前端部分。 然后，您可以启动任意数量的自动加入的后端（查看端口，它是 0，因此将随机选择）。

现在您需要将整个逻辑添加到前端主程序： 创建名称为application的actor系统：

val system = ActorSystem("application")

在后端主要做同样的事情。

现在将您的代码写在前面，这样它将使用路由器创建您的工作人员，这是我的示例代码：

context.actorOf(ServiceRuntimeActor.props(serviceName)
        .withRouter(
          ClusterRouterConfig(ConsistentHashingRouter(),
            ClusterRouterSettings(
              totalInstances = 10, maxInstancesPerNode = 3,
            allowLocalRoutees = false, useRole = Some("backend"))
          )
        ),
        name = shortServiceName)

只需将您的 ServiceRuntimeActor 更改为您的工作人员的姓名即可。它会将工作人员部署到您已启动的所有后端，并将其限制为每个节点最多 3 个，总共最多 10 个。

希望这会有所帮助。