RabbitMQ 相關概念和方法詳解

名詞解釋

• ConnectionFactory: 與 RabbitMQ 服務器鏈接的管理器。
• Connection: 與 RabbitMQ 服務器的鏈接。
• Channel: 與 Exchange 的鏈接。
• Exchange: 接收生產者的消息，並根據消息的 RoutingKey 和 Exchange 綁定的 BindingKey 分配消息。
• Queue: 存儲消費者的消息。
• RoutingKey: 指定當前消息被誰接收。
• BindingKey: 指定當前 Exchange 下，什麼樣的 RoutingKey 會被下派到當前綁定的 Queue 中。

exchange_declare 方法詳解

def exchange_declare(self, callback=None, exchange=None, exchange_type='direct', passive=False, durable=False, auto_delete=False, internal=False, nowait=False, arguments=None):

• callback 若是 nowait=True 且 Exchange.DeclareOk 時，調用這個回調方法。
• exchange 交換器名稱。
• exchange_type 交換器類型，常見的如 fanout direct topic。
• passive 若是爲 true , 則執行聲明或者檢查交換器是否存在。
• durable 設置是否持久化。durable 設置爲 true 表示持久化，反之非持久化。持久化能夠將交換器存盤，在服務器重啓的時候不會丟失消息。
• auto_delete 設置是否自動刪除。auto_delete 設置爲 true 則表示自動刪除。自動刪除的前提是至少有一個隊列或者交換器綁定，以後全部與這個交換器綁定的隊列或者交換器都與此解綁。注意不能錯誤地把這個參數理解爲："當與此交換器鏈接的客戶端都斷開時，RabbitMQ 會自動刪除本交換器"。
• internal 設置是不是內置的。若是設置爲 true，則表示是內置的交換器，客戶端程序沒法直接發送消息到這個交換器中，只能經過交換器路由到交換器這種方式。
• nowait 若是設置爲 false, 則不指望 RabbitMQ 服務器有一個 Exchange.DeclareOk 這樣響應。
• arguments 其餘一些結構化參數。好比：alternate-exchange。

exchange_bind 方法詳解

def exchange_bind(self, callback=None, destination=None, source=None, routing_key='', nowait=False, arguments=None):

• callback 若是 nowait=True 且 Exchange.DeclareOk 時，調用這個回調方法。
• destinaction 一種交換器。
• source 消息從 source 交換器轉發到 destination 交換器，從某種程度上看 destination 交換器能夠是一種隊列。
• routing_key 用來綁定隊列和交換器的路由鍵。
• nowait 若是設置爲 false, 則不指望 RabbitMQ 服務器有一個 Exchange.DeclareOk 這樣響應。
• arguments 其餘一些結構化參數。

queue_declare 方法詳解

def queue_declare(self, queue='', passive=False, durable=False, exclusive=False, auto_delete=False, arguments=None):

• queue 隊列名稱。
• passive 若是爲 true , 則執行聲明或者檢查隊列是否存在。
• durable 設置是否持久化。爲 true 則設置隊列爲持久化。持久化的隊列會存盤，在服務器重啓的時候能夠保證不丟失相關的信息。
• exclusive 設置是否排他。爲 true 則設置隊列爲排他的。若是一個隊列被聲明爲排他隊列，該隊列對首次聲明它的鏈接可見，並在鏈接斷開時自動刪除。這裏須要注意三點：
  • 排他隊列是基於鏈接（Connection）可見的，同一個鏈接的不一樣信道（Channel）是能夠同時訪問同一個鏈接建立的排他隊列。
  • "首次" 是指若是一個鏈接已經聲明瞭一個排他隊列，其餘鏈接是不容許創建同名的排他隊列，這個與普通隊列不一樣。
  • 即便該隊列是持久化的，一旦鏈接關閉或者客戶端退出，該隊列都會被自動刪除，這種隊列適用於一個客戶端同時發送和讀取消息的應用場景。
• auto_delete 設置是否自動刪除。爲 true 則設置隊列爲自動刪除。自動刪除的前提是：至少有一個消費者鏈接到這個隊列，以後全部與這個隊列鏈接的消費者都斷開時，纔會自動刪除。不能把這個參數錯誤的理解爲："當鏈接到此隊列的全部客戶端斷開時，這個隊列自動刪除"，由於生產者客戶端建立這個隊列，或者沒有消費者客戶端與這個隊列鏈接時，都不會自動刪除這個隊列。
• arguments 設置隊列的其餘一些參數，如 x-message-ttl、x-expires、x-max-length。

queue_bind 方法詳解

def queue_bind(self, queue, exchange, routing_key=None, arguments=None):

• queue 隊列名稱。
• exchange 交換器的名稱。
• routing_key 用來綁定隊列和交換器的路由鍵。
• arguments 定義綁定的一些參數。

basic_publish 方法詳解

def basic_publish(self, exchange, routing_key, body, properties=None, mandatory=False, immediate=False):

• exchange 交換器的名稱，指明消息須要發送到哪一個交換器。若是設置爲空字符串，則消息會被髮生到 RabbitMQ 默認的交換器中。
• routing_key 路由鍵，交換器根據路由鍵將消息存儲到相應的隊列之中。
• properties 消息的基本屬性集，其包含 14 個屬性成員，分別有 contentType、deliveryMode、proiotity等。
• body 消息體 payload，真正須要發送的消息。
• mandatory 當參數設置爲 true 時，交換器沒法根據自身的類型和路由鍵找到一個符合條件的隊列，那麼 RabbitMQ 會調用 Basic.Return 命令消息返回給生產者。當參數設置爲 false 時，出現上述狀況，則消息直接丟失。
• immediate 當參數設置爲 true 時，若是交換器在將消息路由到隊列時發現隊列上並不存在任何消費者，那麼這條消息將不會存入隊列中。當與路由鍵匹配的全部隊列都沒有消費者時，該消息會經過 Basic.Return 返回至生產者。

basic_consume 方法詳解

def basic_consume(self, consumer_callback, queue='', no_ack=False, exclusive=False, consumer_tag=None, arguments=None):

• consumer_callback 設置消費者的回調函數。用來處理 RabbitMQ 推送過來的消息，好比：DefaultConsumer，使用時須要客戶端重寫其中的方法。
• queue 隊列的名稱。
• no_ack 設置是否自動確認。建議設置成 false，即不自動確認。
• exclusive 設置是否排他。
• consumer_tag 消費者標籤，用來區分多個消費者。
• arguments 設置消費者的其餘參數。

exchange_type 模式

fanout 模式

• 任何發送到 fanout exchange 的消息都會被轉發到與 exchange 綁定的全部的 queue 上。
• 不須要指定 routing_key, 即便指定了也是無效的。
• 須要提早將 exchange 與 queue 進行綁定， 一個 exchange 能夠綁定到多個 queue, 一個 queue 也能夠同多個 exchange 進行綁定。
• 接收到消息的 exchange 沒有與任何 queue 綁定， 則消息就會被拋棄。

direct 模式

• 發送到 direct exchange 的消息都會被轉發到 routing_key 中指定的 queue。
• 不須要將 exchange 進行任何綁定操做。固然也能夠進行綁定操做，能夠將不一樣的 routing key 與不一樣的 queue 進行綁定，不一樣的 queue 與不一樣 exchange 進行綁定。
• 消息須要傳遞一個 routing_key。
• 若是消息中不存在 routing_key 中綁定的隊列名，則該消息就會被拋棄。
• 若是一個 exchange 聲明爲 direct，而且綁定中指定了 routing_key，那麼發生消息時。須要同時指明該 exchange 和 routing_key。

topic 模式

• 這種模式比較複雜，簡單來講，就是每一個隊列都有其關心的主題，全部的消息都帶有一個 routing_key，exchange 會將消息轉發到全部關注主題能與 routing_key 模糊匹配的隊列。
• 須要 routing_key 要提早綁定 exchange 與 queue。
• 在進行綁定的時候，要提供一個該隊列關心的主題，如："#.log.#" 表示該隊列關心所涉及 log 的消息（一個 routing_key 爲 "MQ.log.error" 的消息會被轉發到該隊列）。
• "#" 表示 0 個或若干個關鍵字，"" 表示一個關鍵字。如 "log." 能與 "log.warn.timeout" 匹配，可是 "log.#" 能與上述匹配。
• 若是 exchange 沒有發現可以與 routing_key 匹配的 Queue，則會拋棄此消息。