如何在Akka集群中透明地创建参与者

Question

我有一个演员系统，如下图所示。

Master
|
|--Monitor
|
|--Supervisor
      |
      |--Device #1
      |--Device #2
      |-- ...
      |--Device #N

主演员启动监控演员和监控演员。

Monitor actor会发出一条消息，告诉自己每30秒检查一次设备资源清册。对于资源清册中存在的每个设备，它会向Supervisor actor发送一条消息以注册该设备。

主管参与者在收到来自监视器参与者的消息以注册设备时启动设备参与者。

代码可以在github上找到。

在单个JVM实例中，一切都运行得很好，但当涉及到集群模式时，我开始感到困惑。

正如我所期望的，使用以下配置，前面的actor树应该在集群机器中透明地运行。所有的参与者都应该在集群中创建，我不应该关心参与者是在哪台机器上创建的。

在实例#1中：

akka {
  actor {
    provider = "cluster"
  }
  remote {
    log-remote-lifecycle-events = off
    netty.tcp {
      hostname = "127.0.0.1"
      port = 2551
    }
  }

  cluster {
    seed-nodes = [
      "akka.tcp://example@127.0.0.1:2551",
    ]
  }
}

在实例#2上：

akka {
  actor {
    provider = "cluster"
  }
  remote {
    log-remote-lifecycle-events = off
    netty.tcp {
      hostname = "127.0.0.1"
      port = 2552
    }
  }

  cluster {
    seed-nodes = [
      "akka.tcp://example@127.0.0.1:2551",
    ]
  }
}

我所期望的是：

Master (On node 1)
|
|--Monitor (On node 2)
|
|--Supervisor (On node 2)
      |
      |--Device #1 (On node 1)
      |--Device #2 (On node 1)
      |-- ...
      |--Device #N (On node 2)

但是，它最终在集群中运行两个相同的actor树：每个节点分别运行一个actor树，如下图所示：

Node 1             |   Node2
                   | 
Master             |   Master
|                  |   |
|--Monitor         |   |--Monitor  
|                  |   | 
|--Supervisor      |   |--Supervisor 
    |              |       |      
    |--Device #1   |       |--Device #1
    |--Device #2   |       |--Device #2
    |-- ...        |       |-- ... 
    |--Device #N   |       |--Device #N 

我还尝试在集群中以单例参与者的身份运行主参与者，但它最终在启动主参与者的节点上运行单参与者树。

所以，我的问题是，我如何通过调用context.actor（DeviceActor.props（deviceId））来创建跨集群的演员，而不需要仔细设计带有集群单例和集群分片的演员树？

Answer 1

你所描述的是Akka集群分片的确切定义。

当您需要将参与者分布在集群中的多个节点上，并希望能够使用其逻辑标识符与他们交互，但不必关心他们在集群中的物理位置（这也可能随时间而改变）时，集群分片非常有用。

设置它非常简单，特别是如果您已经有了集群。监视器将是一个集群单例，因此集群上只有一个活动的，并且每个设备都是由设备ID标识的实体。