メッセージキューの概要

パブリッシャーは、メッセージを取引所に送信するコンポーネントです。 公開先の交換と、送信するメッセージの形式がわかります。

交換機はパブリッシャーからメッセージを受信し、キューに送信します。 RabbitMQ は複数の種類の交換をサポートしていますが、Commerceではトピック交換のみを使用します。 トピックにはルーティングキーが含まれます。ルーティングキーには、ドットで区切られたテキスト文字列が含まれます。 トピック名の形式は string1.string2 です。たとえば、customer.created または customer.sent.email です。

ブローカーでは、メッセージ転送のルールを設定する際にワイルドカードを使用できます。 アスタリスク（*）を使用すると 1 文字列を置き換え、シャープ記号（#）を使用すると 0 個以上の文字列を置き換えることができます。 例えば、customer.* は customer.create と customer.delete に対してフィルタリングしますが、customer.sent.email に対してはフィルタリングしません。 ただし、customer.# は customer.create、customer.delete、customer.sent.email に対してフィルタリングします。

キューは、メッセージを格納するバッファです。

消費者がメッセージを受信します。 使用するキューがわかります。 メッセージのプロセッサを特定のキューにマップできます。

パブリッシャー は、メッセージを宛先（キューまたはトピック）に送信するコンポーネントです。 公開先と、送信するメッセージの形式がわかります。

STOMP の 宛先 は、AMQP の交換と同様の役割を果たし、パブリッシャーからメッセージを受信してルーティングします。 STOMP は、ドット（例：customer.created または inventory.updated）を使用した階層的な命名パターンを使用して、直接宛先アドレスを使用します。

Adobe Commerceでは、STOMP 宛先に対して、ポイントツーポイントのメッセージ配信を提供する ANYCAST アドレッシングモードを使用します。 ANYCAST モードでは、使用可能なコンシューマーのプールから 1 つのコンシューマーにのみメッセージが配信されるため、複数のコンシューマー・インスタンス間でのロード・バランシングと作業分散が可能になります。

キュー は、メッセージを格納するバッファーです。 ANYCAST アドレッシングを使用すると、キューは、複数のコンシューマーが同じ宛先に接続されている場合でも、メッセージが 1 つのコンシューマーにのみ配信されるようにします。

コンシューマー は、宛先からメッセージを受信します。 購読する宛先を把握し、様々な確認モード（自動、クライアントまたはクライアント個別）でメッセージを処理できます。