akka - 如何使用 Akka 在 Actor 之间创建类似观察者的交流

Question

在经典编程中，如果我想通知观察者有关更改的信息，我会使用 obeserver 模式。

Akka 中的等效模式是什么？

用例:

Actor (PropertyServiceActor) 正在从数据库中读取和缓存属性

不同的actor可以注册到PropertyServiceActor

如果属性发生变化，PropertyServiceActor 会通知注册的参与者有关更改

Answer 1

看看BroadcastGroup

//Create group
val paths = List("/user/workers/w1", "/user/workers/w2", "/user/workers/w3")
val observers: ActorRef =  context.actorOf(BroadcastGroup(paths).props(), "observers")

要通知所有观察者，只需将消息发送至 observers Actor 引用您也可以通过发送 akka.routing.AddRoutee 添加和删除观察者和 akka.routing.RemoveRoutee .

您可以找到更多 routing文档。