Region Actor があり、各地域に一定数の人がいるとします。人々のリストが時間の経過とともに変化する可能性があることを知って、どのように全員にメッセージをブロードキャストしますか?ルーター。
私の質問は次のとおりです。EventBus があることは知っています。イベント バスにメンバーをサブスクライブすることはできますが、投稿されたすべてのメッセージを受信するのではなく、地域のメッセージを受信するようにしたいと考えています。
現在 akka では、特定の数のルートを持つルーターを作成する必要があります。例:
Router router = new router(person1, person2)
これは悪いことです。なぜなら、最初はこの地域に誰もいないからです。私は自分の地域に参加する人を知りません。
一種の動的ルーターを作成する方法はありますか: 例:
Region region = new region()
region.router = new Router()
Person person1 = new Person()
region.router.subscribe(person1);
region.router.tell("hello",null);