1

eventStream への複数のサブスクライバーを持つ単一の ActorSystem があります。アプリケーションは毎秒数千のメッセージを生成する可能性があり、一部のメッセージは残りのメッセージよりも重要です。したがって、それらはすべての前に処理する必要があります。

すべての ActorSystem には単一の eventStream が添付されていることがわかりました。そのため、専用の eventStream で重要なメッセージを受信するには、同じアクター クラスを 2 つ (またはそれ以上) の ActorSystems に登録する必要があるようです。

これは好ましいアプローチですか、それともこのタスクにはいくつかのトリックがありますか? 分類子は、メッセージの優先度を微調整することもできますか?

4

1 に答える 1

2

EventStream はイベントを保持するデータ構造ではなく、イベントをサブスクライバーにルーティングするだけなので、リスナー アクターには PriorityMailbox を使用する必要があります。優先メールボックスの使用方法については、ドキュメントを参照してください: http://doc.akka.io/docs/akka/ 2.0.3/scala/dispatchers.html#メールボックス

于 2012-08-29T22:01:27.397 に答える