16.4. メッセージ再分配の有効化

ブローカークラスターがオンデマンドメッセージの負荷分散を使用する場合、メッセージ再分配 を設定して、メッセージを消費するコンシューマーを持たないキューでメッセージがストックにならないようにすることができます。

本セクションでは、以下の情報を提供します。

16.4.1. メッセージ再分配について

ブローカークラスターは負荷分散を使用して、メッセージの負荷をクラスター全体に分散します。クラスター接続で負荷分散を設定する場合、message-load-balancing を ON_DEMAND に設定すると、ブローカーは一致するコンシューマーを持つ他のブローカーにのみメッセージを転送します。この動作により、メッセージがメッセージを消費するコンシューマーを持たないキューに移動されないようにします。ただし、メッセージがブローカーに転送された後にキューにアタッチされたコンシューマーがブローカーに転送されると、これらのメッセージはキュー内でストックになり、消費されません。この問題は、不足と呼ばれることもあります。

メッセージ再分配は、一致するコンシューマーを持つクラスター内のコンシューマーのないキューからメッセージを自動的に再分配することで、不足を防ぎます。

16.4.1.1. メッセージフィルターを使用したメッセージ再分配の制限

メッセージ再分配は、コンシューマーによるフィルター (セレクターとも呼ばれる) の使用をサポートしません。フィルターのあるコンシューマーの一般的なユースケースは、相関 ID を使用したリクエストリプライパターンです。例として以下のシナリオを見てみましょう。

  1. brokerA と brokerB の 2 つのブローカーで設定されるクラスターがある。各ブローカーは redistribution-delay が 0 に設定され、message-load-balancing が ON_DEMAND に設定された状態で設定されます。
  2. brokerA および brokerB には、それぞれ myQueue という名前のキューがあります。
  3. リクエストに基づいて、プロデューサーは、brokerA のキュー myQueue にルーティングされるメッセージを送信します。メッセージには、myCorrelID という名前の相関 ID プロパティーがあり、値は 10 です。
  4. コンシューマーは、myCorrelID=5 のフィルターで brokerA のキュー myQueue に接続します。このフィルターはメッセージの相関 ID 値と一致しません。

  5. 別のコンシューマーは、myCorrelID=10 のフィルターで brokerB のキュー myQueue に接続します。このフィルターはメッセージの相関 ID 値と一致します。

    この場合、brokerB のコンシューマーのフィルターはメッセージに一致しますが、キュー myQueue のコンシューマーが brokerA に存在するため、メッセージは brokerA から brokerB に再分配されません。

上記のシナリオでは、リクエストがプロデューサーに送信される 前 にコンシューマーを作成して、目的のクライアントがメッセージを受信するようにできます。このメッセージは、メッセージの相関 ID と一致するフィルターを持つコンシューマーに即座にルーティングされます。再分配は必要ありません。

関連情報