queue - アーキテクチャの問題：ActiveMQと長いキュー

Question

app1からapp2に数千のメッセージを送信するためにAMQを使用します。App2はこれらすべてのメッセージをhttp接続を介してクライアントに送信しますが、AMQがメッセージを1つずつ送信するため、一部のクライアントがメッセージをゆっくりと消費し、他のすべてのクライアントが待機する場合、問題が発生します。

そのような問題を解決する方法についてのアイデアに本当に感謝します

Answer 1

App2 が HTTP 経由でメッセージを送信する方法を詳しく説明する必要があります。基本的に、その部分はクライアントに依存しないように設計する必要があるため、少なくとも 1 つのクライアントにメッセージを送信したら、次のメッセージを準備する必要があります。

おそらく、各メッセージがクライアントごとに一意のキューに入れられるAPP2の内部キューデータ構造が必要です。その後、各クライアントは独自の速度で各キューを消費できます。

要件とクライアントの総数によっては、クライアントごとに 1 つのキューを ActiveMQ サーバーに配置し、Pub/Subパターンでメッセージを各クライアント キューに配置することもできます。クライアントの数が限られている場合、これはおそらく達成できます。