ルータを使用しているときに俳優の参照を取得する

Question

セッションに「セッション化」できるイベントストリームを処理しようとしています。プールの1人のアクターが1つのセッションのすべてのイベントを処理する予定のアクターのプールを使用する予定です（理由はセッション状態を維持する必要があるためです）。これを達成するためには、特定のセッションに割り当てられた特定のアクタのActorRefを保持する必要があります。私が使用して俳優のプールを使用していますただし、：

val randomActor = _system.actorOf(Props[SessionProcessorActor].withRouter(RandomPool(100)), name = "RandomPoolActor") 

そこで、この場合には、randomActorはないプール内の個々の俳優に、プール全体にActorRefを提供します。どのようにして私は上記のことを達成することができますか？

私が考えることの1つの方法は、プールからのアクタが初期化された後に参照を返すことです（おそらくRandomPoolActor $ abなどのように見えます）。しかし、このメソッドにはいくつかの問題があります。その1つは、tellの代わりにaskパターンを使用しなければならないため、同じセッションのイベントを見逃すことはありません。

これを達成する他の方法はありますか？採用する他のパターン？

Answer 1

ConsistentHashingPoolあなたが探しているものに似た何かをすることができます。 ConsistentHashingRouterは、すべてのメッセージがhashKeyに基づいて同じアクターで終了することを保証します。このキーは、あなたのシナリオであなたのsessionIdになります。これを達成するためにActorRefsまたは他の参照を保持する必要はありません。

コードにhashKeyを定義する方法は複数あります。 ConsistentHashableを拡張するケースクラスを作成することをお勧めします。完了したらconsistentHashKeyメソッドを実装する必要があります。例：

case class HashableEnvelope(yourMsgClass: YourMsgClass) extends ConsistentHashable { 
    override def consistentHashKey = yourMsgClass.sessionId 
} 

その後、あなたはこのようなあなたのプールを定義することができます言及する

val pool = system.actorOf(Props[SessionProcessorActor].withRouter(ConsistentHashingPool(100))) 

もう一つは、ルータが同じハッシュキーを持つすべてのメッセージが同じ役者になってしまいますことを確実にするということですただし、特定のアクタが特定のhashKeyのメッセージのみを受け取ることは保証されません。複数のハッシュキーを受け取ることができます。それは問題ではないはずですが、ちょうどあなたのSessionProcessorActorはちょうど1つではなく、いくつかのhashKeysを処理できるはずです。

整合性のあるハッシュアルゴリズムは、どのメッセージが各アクタに行くかを決定します。あなたはそれがどのように動作するのかをウィキペディアで読むことができます：https://en.wikipedia.org/wiki/Consistent_hashing。 （デフォルトは10）、コンフィギュレーション内の仮想ノードの数を増やす必要があり、より均等な方法でメッセージを配布するには：

akka.actor.deployment.default.virtual-nodes-factor = 1000 

あなたが持っているどのように多くのsessionIdsや俳優に応じて、そのメッセージが表示されます分散なっていますより均等に。