Akka.Net (C#)向集群中的所有参与者发布消息

Question

我试图在集群中使用pub/sub模式。有关这方面的文件非常贫乏。

我正在寻找的场景是: 1.演员订阅事件。2.在代码的任何地方，向参与者系统中该事件的所有订阅者发布一条消息，而不选择参与者。

从“现有”文档中，可以使用以下方法: DistributedPubSub.Get(Context.System).Mediator；

然而，一旦我启动一个中介，我就会得到一个“关联”异常。

1. 我遗漏了什么？
2. 有人能告诉我一个工作演示吗？

谢谢

Answer 1

您真的希望向、中的所有参与者、集群中的每个节点发送相同的消息吗？

我对Akka.NET并不熟悉，但如果我要这么做，我可能会尝试创建一个参与者，该参与者可以倾听流言，了解参与节点的情况，如果可能的话，还可以记录单个参与者的记录，否则，可以找到一种方法来查询各个节点中包含的参与者。一旦你有了对这些参与者的引用，向他们发送信息就足够了。

不必担心集群中发现所有参与者的内置方式，您可以将其构建为每个节点的一部分，指定一个参与者(可能部署到一个路由器的节点上)来维护所有本地参与者的注册中心。当查询时，可能会提供对这些参与者的引用，或者该节点可以充当向本地参与者广播消息的代理/网关。

通常，如果您讨论的是路由器后面的节点，那么您应该能够将您的消息包装在广播消息中，以获得对路由器的预期效果。