java - 是否可以知道 Akka 的 "Distributed Publish Subscribe in Cluster"中收到了哪个主题的消息？

Question

我有一个 Akka 系统，其中的 Actor 代表传感器。每次传感器进行观察时，其相应的 Actor 都会在内部发布/订阅主题上发布此观察结果。这使得扩展观察的使用变得容易(由一个 Actor 保存在数据库中，由另一个 Actor 发布到 MQTT 代理，等等)

让接收者知道其收到的消息涉及哪个主题的一个可能的解决方案是在消息中包含该主题。然而，这对我来说似乎是糟糕的设计。是否可以在 Akka 的 Actor 中查看当前消息是在哪个主题上收到的？

据我所知，Akka 关于集群中的分布式发布订阅 ( http://doc.akka.io/docs/akka/current/java/distributed-pub-sub.html ) 的文档并未提及这一点。

Answer 1

据我所知，这不是分布式发布/订阅的内置功能。我通常会通过制作某种信封来解决这个问题:

case class PubSubEnvelope[MessageType](topic: String, payload: MessageType)

为了额外的安全性，也许您希望为 MessageType 创建某种父类(super class)型，以便可以约束它，并为 topic 创建一些类似枚举的结构字符串。