在经典编程中,如果我想通知观察者有关更改的信息,我会使用 obeserver 模式。
Akka 中的等效模式是什么?
用例:
最佳答案
//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文档。
关于akka - 如何使用 Akka 在 Actor 之间创建类似观察者的交流,我们在Stack Overflow上找到一个类似的问题: https://stackoverflow.com/questions/29162891/