RabbitMQ 安裝和配置05

服務器主機名與IP列表：

mq136      172.28.2.136
mq137      172.28.2.137
mq164      172.28.2.164
mq165      172.28.2.165

在各節點服務器上做好hosts解析

1. cat >>/etc/hosts/<<EOF 

2. mq136      172.28.2.136 

3. mq137      172.28.2.137 

4. mq164      172.28.2.164 

5. mq165      172.28.2.165 

6. EOF 

1、簡介
RabbitMQ是流行的開源消息隊列系統，用erlang語言開發。Erlang的分佈式通信安全策略，能夠歸結爲 All or None。。RabbitMQ是AMQP（高級消息隊列協議）的標準實現。RabbitMQ的結構圖以下：

幾個概念說明：

Broker：簡單來講就是消息隊列服務器實體。
Exchange：消息交換機，它指定消息按什麼規則，路由到哪一個隊列。
Queue：消息隊列載體，每一個消息都會被投入到一個或多個隊列。
Binding：綁定，它的做用就是把exchange和queue按照路由規則綁定起來。
Routing Key：路由關鍵字，exchange根據這個關鍵字進行消息投遞。
vhost：虛擬主機，一個broker裏能夠開設多個vhost，用做不一樣用戶的權限分離。
producer：消息生產者，就是投遞消息的程序。
consumer：消息消費者，就是接受消息的程序。
channel：消息通道，在客戶端的每一個鏈接裏，可創建多個channel，每一個channel表明一個會話任務。

消息隊列的使用過程大概以下：

（1）客戶端鏈接到消息隊列服務器，打開一個channel。
（2）客戶端聲明一個exchange，並設置相關屬性。
（3）客戶端聲明一個queue，並設置相關屬性。
（4）客戶端使用routing key，在exchange和queue之間創建好綁定關係。
（5）客戶端投遞消息到exchange。

exchange接收到消息後，就根據消息的key和已經設置的binding，進行消息路由，將消息投遞到一個或多個隊列裏。

exchange也有幾個類型，徹底根據key進行投遞的叫作Direct交換機，例如，綁定時設置了routing key爲」abc」，那麼客戶端提交的消息，只有設置了key爲」abc」的纔會投遞到隊列。對key進行模式匹配後進行投遞的叫作Topic交換機，符號」#」匹配一個或多個詞，符號」*」匹配正好一個詞。例如」abc.#」匹配」abc.def.ghi」，」abc.*」只匹配」abc.def」。還有一種不須要key的，叫作Fanout交換機，它採起廣播模式，一個消息進來時，投遞到與該交換機綁定的全部隊列。

RabbitMQ支持消息的持久化，也就是數據寫在磁盤上，爲了數據安全考慮，我想大多數用戶都會選擇持久化。消息隊列持久化包括3個部分：
（1）exchange持久化，在聲明時指定durable => 1
（2）queue持久化，在聲明時指定durable => 1
（3）消息持久化，在投遞時指定delivery_mode => 2（1是非持久化）

若是exchange和queue都是持久化的，那麼它們之間的binding也是持久化的。若是exchange和queue二者之間有一個持久化，一個非持久化，就不容許創建綁定。

下面咱們再瞭解下消息隊列RabbitMQ集羣,因爲RabbitMQ是用erlang開發的，RabbitMQ 徹底依賴 Erlang 的 Cluster，而Erlang集羣很是方便，所以配置RabbitMQ集羣變得很是簡單。

RabbitMQ的集羣節點包括內存節點、磁盤節點。顧名思義內存節點就是將全部數據放在內存，磁盤節點將數據放在磁盤。不過，如前文所述，若是在投遞消息時，打開了消息的持久化，那麼即便是內存節點，數據仍是安全的放在磁盤。

良好的設計架構能夠以下：在一個集羣裏，有3臺以上機器，其中1臺使用磁盤模式，其它使用內存模式。其它幾臺爲內存模式的節點，無疑速度更快，所以客戶端（consumer、producer）鏈接訪問它們。而磁盤模式的節點，因爲磁盤IO相對較慢，所以僅做數據備份使用。