私は現在、20 個のコンシューマーのスレッドプールを使用しpublish-subscribe-channelて、 が割り当てられている にメッセージを配信しています。task-executor
- これらの受信メッセージは、エンティティの更新について説明しています。
- 多くのエンティティに関する最新情報を次々と受け取ります
- 同じエンティティに関連する更新は、キューに入れられた順序で処理する必要があります
明らかに、メッセージの同時処理を許可することにより、メッセージの処理順序の保証がなくなります。
無関係なメッセージの同時処理を可能にするが、関連するメッセージのシリアル処理を保証する適切なトポロジは何ですか?