特定のアクタを見ているアクタにメッセージをブロードキャストしますか？

Question

特定の俳優を見ているすべての俳優にメッセージをブロードキャストするにはどうすればよいですか？

コンテキストの場合、多くのAuctionParticipantActorタイプで監視されているAuctionActor（リモートアクタの可能性があります）があるとします。私はAuctionParicipantActorタイプにさまざまなメッセージをブロードキャストするようにAuctionActorを希望します。

AuctionActorは、すべての参加者ActorRefインスタンスのコレクションを保持し、すべての参加者にメッセージを送信する必要があるときにこのコレクションをループする可能性があります。あなたはディエゴ・Martinoiaで述べたようにPubSubに行きたくない場合は、私はBroadcastingLogicとRoutersを使用することをお勧めし

Answer 1

...これは非効率ですし、私はよりよい解決策を期待しています。これは、ActorRefのコレクションで言及した方向に向いていますが、Akkaの機能を使用して、AuctionActorのコレクションを反復するよりも効率的です。

アッカDocs

から、ルータは、メッセージを受信し、routeesへ上すぐにそれらを渡すことで、非常に効率的になるように設計されています。

通常のアクターはメッセージのルーティングに使用できますが、アクターのシングルスレッド処理はボトルネックになります。ルータは、並行ルーティングを可能にする通常のメッセージ処理パイプラインに対する最適化により、より高いスループットを達成することができる。

それは次のようになりますあなたの場合は

：トピックは俳優の名前であることをPubSubの分散

class AuctionActor extends Actor { 
    var router = Router(BroadcastRoutingLogic(), Vector[ActorRefRoutee]()) 

    def receive = { 
    case AddParticipant(ref) => 
     router = router.addRoutee(ref) 
    case RemoveParticipant(ref) => 
     router = router.removeRoutee(ref) 
    case update: ImportantUpdate => 
     router.route(update, self) 
    } 
}