我需要与多个远程参与者系统进行通信

I need to communicate with multiple remote actor systems

我正在尝试使用 akka.Net 开发一个插件架构,每个包含一个或多个插件的 dll 都被加载到它自己的 AppDomain 中,并且一个新的 actor 系统被初始化准备好接收来自"Host".

我试图让它与多个插件一起工作,但我变得很困惑。

主机配置如下所示:

akka {
    actor {
        provider = ""Akka.Remote.RemoteActorRefProvider, Akka.Remote""
    }
    remote {
        helios.tcp {
            transport-class = ""Akka.Remote.Transport.Helios.HeliosTcpTransport, Akka.Remote""
            applied-adapters = []
            transport-protocol = tcp
            port = 50003
            hostname = localhost
        }
    }
}

插件配置如下:

akka {
    actor {
        provider = ""Akka.Remote.RemoteActorRefProvider, Akka.Remote""
    }
    remote {
        helios.tcp {
            transport-class = ""Akka.Remote.Transport.Helios.HeliosTcpTransport, Akka.Remote""
            applied-adapters = []
            transport-protocol = tcp
            port = 50004
            hostname = localhost
    }
}

(有很多)

我的问题是如何从主机获取消息到所有插件?

最好的建议是使用Akka.Cluster。这是一个有据可查的示例:https://github.com/petabridge/akkadotnet-code-samples/tree/master/Cluster.WebCrawler

编辑 - 删除了使用动态端口的建议。最好使用静态的,这样可以正确处理节点重启。

让每个插件配置使用特定于插件的端口 (akka.remote.helios.tcp.port = 1231),然后定义一个集群路由器,该路由器与执行特定角色的参与者系统对话。

/api/broadcaster {
  router = broadcast-group
  routees.paths = ["user/api"]
  cluster {
      enabled = on
      max-nr-of-instances-per-node = 1
      allow-local-routees = on
      use-role = crawler
  }
}

此路由器部署在某个节点上的路径 user/api/broadcaster 上,可以(通过 Broadcast 路由策略)与集群中任何节点上部署在路径 user/api 上的任何参与者进行通信(通过 Broadcast 路由策略)使用 crawler 角色,无需查找 IP 地址、端口或任何其他废话。

您可以通过 Akka.NET 的配置中的以下部分配置节点的集群信息:

cluster {
  #manually populate other seed nodes here, i.e. "akka.tcp://lighthouse@127.0.0.1:4053"
  seed-nodes = ["akka.tcp://webcrawler@127.0.0.1:4053"]
  roles = [crawler]
}

种子节点 - 必须是众所周知的、静态定义的端口和 IP 地址。阅读这篇文章,了解为什么这很重要。

角色 - 定义此特定节点功能的逗号分隔字符串。它们更像是标签。您可以在集群路由器(如我之前展示的路由器)中使用它们来阐明您想要与之通信的节点类型。