Akka.NET - 是否可以将 AtLeastOnceDeliveryReceiveActor 与发布/订阅模式混合使用？

Question

我想问一下是否可以实现发布/订阅模式 (http://getakka.net/articles/clustering/distributed-publish-subscribe.html)，其中订阅者是 AtLeastOnceDeliveryReceiveActor (http://getakka.net/articles/persistence/at-least-once-delivery.html)

我无法让它工作，因为 AtLeastOnceDeliveryReceiveActor 没有 Receive 方法，而只是命令。当我获得对演员的引用并使用 Tell 方法发送消息时，Command 会收到它，但如果我'想在 Publish 方法中使用调解器，然后 Command 没有收到该消息。

提前致谢。

Answer 1

ReceivePersistentActor 的Command 与Receive 处理程序一样工作（唯一的区别是确认参与者的持久性/恢复生命周期）。话虽如此，您可能会构建一个至少一次交付的发布/订阅总线......但是我建议您只需将您的参与者逻辑与现有的持久队列/日志集成（例如Kafka、RabbitMQ、Azure Service Bus 等等），而不是尝试在 Akka 中重新创建它。我想这对大多数人来说不会那么痛苦。