我有以下要求:我想要一个将消息转发到 0-* 演员(目的地)的路由器或演员。
目的地通过注册和注销消息(如侦听器)在路由器上注册和注销自己。
我的想法是,在“RoutingActor”中有一个 Map,它包含目的地的引用。但是如果我确实以这种方式实现它,我就不能使用“AkkaSystem.actorOf(RoutingActor.class)”,因为我可能会得到不同的演员,对吧?
那么,这里的正确解决方案是什么?我想构建一个路由器/调度程序,它可以在运行时从这些目标 Actor 更改消息目标。
谢谢