AMQP - kabao2003’s blog

だいたいここAMQP 0-9-1 Model Explained — RabbitMQを読めばわかる。

以下メモ。

producerからmessageを受け取って、consumerにroutingする。
MQのキューマネージャみたいなものか？

producerからの、受け口。
以下のような属性項目をもっている。

受け口であるExchangeから、Queueへの転送のやり方。Direct/Fanout/Topic/Headersの4種類ある。

名前

RabbitMQ再起動後も同じExchangeを残すか、残さないか

誰も使わなくなったらExchangeを消すか、消さないか

任意の引数。使い道はbrokerに依存するっぽい。

ExchangeがmessageをQueueに配送するために使用する、ルールのようなもの。
exchange Eに対して、メッセージをqueue Qに配送するよう指示するためには、QがEにバインドされている必要がある。
exchangeのtypeによっては、ルーティングキーを使う場合もある。

キュー。以下の属性をもつ。

名前。アプリケーション側から自由に名づけてもよいし、brokerに任せて自動で名づけてもらうこともできる。

再起動後も同じQueueを残すかどうか。
durable queueのみがdurable exchangeにバウンドできる。queueがdurableであっても、messageがdurableとは限らない。

1コネクションのみで使用され、そのコネクションが閉じたら削除されるようにする。

最後のコンシューマがunsubscribeしたら自動削除する。

任意の引数。これもbroker依存っぽい。

TCPのコネクションにほぼ対応する概念。

同一Connection中で複数のChannelを持つことができる。複数スレッドのときには、1スレッドに1channelを対応させるようなイメージ。

環境（SI用語で言う「面」かな）のようなものを実現する。

MQで、キューマネージャが2個あって、マネージャ接続させてローカルのマシンからリモートのマシンに転送する場合に、リモートキュー、トランスミッションキュー、チャネル、宛先ローカルキューとなっているのが、AMQPだとExchange、Queueになっているようなイメージと、とりあえず一旦理解した。