RabbitMQ 核心概念

摘要： RabbitMQ 特點 RabbitMQ 相較於其他訊息佇列，有一系列防止訊息丟失的措施，擁有強悍的高可用效能，它的吞吐量可能沒有其他訊息佇列大，但是其訊息的保障性出類拔萃，被廣泛用於金融類業務。與其他訊息佇列的比較以及強大的防止訊息丟失的能力我們將在後續文章再做介紹。 AMQP 協議...

RabbitMQ 特點

RabbitMQ 相較於其他訊息佇列，有一系列防止訊息丟失的措施，擁有強悍的高可用效能，它的吞吐量可能沒有其他訊息佇列大，但是其訊息的保障性出類拔萃，被廣泛用於金融類業務。與其他訊息佇列的比較以及強大的防止訊息丟失的能力我們將在後續文章再做介紹。

AMQP 協議

AMQP: Advanced Message Queuing Protocol 高階訊息佇列協議

AMQP定義:是具有現代特徵的二進位制協議。是一個提供統一訊息服務的應用層標準高階訊息佇列協議，是應用層協議的一個開放標準，為面向訊息的中介軟體設計。

Erlang語言最初在於交換機領域的架構模式，這樣使得RabbitMQ在Broker之間進行資料互動的效能是非常優秀的

Erlang的優點: Erlang有著和原生Socket一樣的延遲。

RabbitMQ是一個開源的訊息代理和佇列伺服器，用來通過普通協議在完全不同的應用之間共享資料, RabbitMQ是使用Erlang語言來編寫的，並且RabbitMQ是基於AMQP協議的。

RabbitMQ 訊息傳遞機制

Server:又稱Broker, 接受客戶端的連線，實現AMQP實體服務，這裡指 RabbitMQ 伺服器

Connection:連線，應用程式與Broker的網路連線。

Channel:網路通道，幾乎所有的操作都在 Channel 中進行，Channel是進行訊息讀寫的通道。客戶端可建立多個Channel:，每個Channel代表一個會話任務。

Message:訊息，伺服器和應用程式之間傳送的資料，由 Properties 和 Body 組成。Properties 可以對訊息進行修飾，比如訊息的優先順序、延遲等高階特性;，Body 則就 是訊息體內容。

Virtual host:虛似地址，用於迸行邏輯隔離。一個 Virtual Host 裡面可以有若干個 Exchange和 Queue ，同一個 VirtualHost 裡面不能有相同名稱的 Exchange 或 Queue。許可權控制的最小粒度是Virtual Host。

Binding:Exchange 和 Queue 之間的虛擬連線，binding 中可以包含 routing key。

Routing key:一 個路由規則，虛擬機器可用它來確定如何路由一個特定訊息，即交換機繫結到 Queue 的鍵。

Queue:也稱為Message Queue,訊息佇列，儲存訊息並將它們轉發給消費者。

Exchange

1. 簡介

Exchange 就是交換機，接收訊息，根據路由鍵轉發訊息到繫結的佇列。有很多的 Message 進入到 Exchange 中，Exchange 根據 Routing key 將 Message 分發到不同的 Queue 中。

2. 型別

RabbitMQ 中的 Exchange 有多種型別，型別不同，Message 的分發機制不同，如下：

• fanout：廣播模式。這種型別的 Exchange 會將 Message 分發到繫結到該 Exchange 的所有 Queue。

• direct：這種型別的 Exchange 會根據 Routing key（精確匹配，將Message分發到指定的Queue。

• Topic：這種型別的 Exchange 會根據 Routing key（模糊匹配，將Message分發到指定的Queue。

• headers: 主題交換機有點相似，但是不同於主題交換機的路由是基於路由鍵，頭交換機的路由值基於訊息的header資料。 主題交換機路由鍵只有是字串,而頭交換機可以是整型和雜湊值 .

3. 屬性

/**
* Declare an exchange, via an interface that allows the complete set of
* arguments.
* @see com.rabbitmq.client.AMQP.Exchange.Declare
* @see com.rabbitmq.client.AMQP.Exchange.DeclareOk
* @param exchange the name of the exchange
* @param type the exchange type
* @param durable true if we are declaring a durable exchange (the exchange will survive a server restart)
* @param autoDelete true if the server should delete the exchange when it is no longer in use
* @param internal true if the exchange is internal, i.e. can't be directly
* published to by a client.
* @param arguments other properties (construction arguments) for the exchange
* @return a declaration-confirm method to indicate the exchange was successfully declared
* @throws java.io.IOException if an error is encountered
*/
Exchange.DeclareOk exchangeDeclare(String exchange,
String type,boolean durable,
boolean autoDelete,boolean internal,
Map<String, Object> arguments) throws IOException;

• Name: 交換機名稱
• Type: 交換機型別direct、topic、 fanout、 headers

• Durability:是否需要持久化，true為持久化

• Auto Delete: 當最後一個繫結到Exchange. 上的佇列刪除後，自動刪除該Exchange
• Internal: 當前Exchange是否用於RabbitMQ內部使用，預設為False

• Arguments:擴充套件引數，用於擴充套件AMQP協議自制定化使用