/*學院顯示頁 左上*/ var cpro_id = "u2659916";

由於想用Python實現一套分散式系統，來管理和監控CDN的內容與執行狀態，誤打誤撞認識了RabbitMQ，推薦的人很多，如餘鋒《我為什麼要選擇RabbitMQ》等等。

在MQ這個詞彙映入眼簾的時候，我花了好幾個小時去閱讀什麼是MQ，即Message Queue(訊息佇列）。顧名思義，訊息佇列，裝滿訊息的佇列，佇列，資料結構名詞，具備先進先出特性的一種資料結構。訊息佇列無非是用來傳遞訊息的而已，那麼其意義何在，應用場景又在哪裡，具備什麼特性，及其獨特優勢是什麼，為什麼要用，這些都是浮現在我腦海中的一連串問題。

經過一大串搜尋，終於膚淺的理解訊息佇列是應用對應用的資訊傳遞的通訊方式。比如需要分析多臺伺服器的日誌，完全可以每臺伺服器都用一個程序往一個

MySQL資料庫的表裡面寫入資料，即所需要的資訊，然後再寫幾個程序，讀取表裡資料，進行資料分析不是挺好，不過很快，這種設計的醜陋之處就顯現出來了…… 你想要多個程式從一個隊列當中取資料來處理？沒問題，我們硬編碼程式的個數好了……什麼？還要能夠允許程式動態地增加和減少的時候動態進行壓力分配？這是很流行的《RabbitMQ+Python入門經典 兔子和兔子窩》裡面的例子。想想也是，當我的CDN傳輸來一大堆資料的時候，資料的分發，處理，所有的一切都會是問題。但是其實還是沒明白，Rabbit到底是怎麼樣實現這些東西的。

概念上說，RabbitMQ是AMPQ（高階訊息協議佇列）的標準實現，據說不熟悉AMQP，會看不懂RabbitMQ的文件。但是也只能建大的理解關鍵概念了。整個RabbitMQ的實現原理模型見下圖，其實就是一個帶路由任務分發佇列的生產者與消費者模型。如圖所示，即生產者生產出相應的資訊，傳送給路由器，路由器根據資訊中的關鍵Key資訊，將資訊分發到不同的訊息佇列中，再由消費者去不同的訊息佇列中讀取資料的過程。

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。

瞭解了RabbitMQ大概流程與優勢之後，我開始在自己的Fedora上進行RabbitMQ的試用。

點選可以下載各個版本的binary包，我下載了rabbitmq-server-3.3.0-1.noarch.rpm

進入下載路徑，/home/sun5495/Downloads/

[[email protected] Downloads]# sudo chmod 777 rabbitmq-server-3.3.0-1.noarch.rpm

更改可執行檔案許可權，增加執行許可權。

然後執行./rabbitmq-server-3.3.0-1.noarch.rpm,執行報錯，無法安裝。

原來是現需要安裝Erlang才可以，試用此命令 yum install erlang 搞定。

然後使用root使用者執行

rpm --import http://www.rabbitmq.com/rabbitmq-signing-key-public.asc 

yum install rabbitmq-server-3.3.0-1.noarch.rpm

安裝成功。

為了設定RBMQ開機啟動，使用管理員賬戶執行

chkconfig rabbitmq-server on

開啟和關閉server使用命令 

/sbin/service rabbitmq-server stop/start

結果開啟的時候報錯如下
    Starting rabbitmq-server (via systemctl):  Job for rabbitmq-server.service failed. See ‘systemctl status rabbitmq-server.service’ and ‘journalctl -xn’ for details. [FAILED]

使用journalctl -xn命令開啟日誌，查看了下貌似是Erlang的某個檔案拒絕訪問，然後還提出了一大堆建議。

嘗試一下

grep beam.smp /var/log/audit/audit.log | audit2allow -M mypol

semodule -i mypol.pp

/sbin/service rabbitmq-server start

居然奇蹟般成功。好吧，待我一會回來研究剛才做了什麼。

既然RabbitMQ安裝也執行成功了，那麼我就來嚐嚐RabbitMQ的鮮吧。就從官網上的例子一步一筆來做好了。

由於我使用的是Python，那麼就需要安裝一些支援RabbitMQ的庫來進行操作，其中包括

py-amqplib,txAMQP,pika這幾種，按照官網的tutorial，我也安裝了pika。

pip install pika

從最簡單的收發訊息開始。即一端傳送訊息，一端接收訊息。

傳送方即生產者，首先要建立與RabbitMQ伺服器的連線，

#!/usr/bin/env python
import pika

connection = pika.BlockingConnection(pika.ConnectionParameters(
               'localhost'))
channel = connection.channel()

此處伺服器連線本地localhost，也可以指定ip或者主機名。

其次傳送方需要宣告一個佇列，比如命名為sayhello

channel.queue_declare(queue='sayhello')

此時我們就可以傳送訊息了。由於第一個小案例比較簡單，沒有經過路由器，因此傳送訊息時，指定路由為空即可。

channel.basic_publish(exchange='',
                        routing_key='hello',
                                    body='hello world')
print "Sent ‘hello world'"

最後關閉連線即可。

connection.close()

接收方即消費者，需要從佇列上獲取資料，因此也需要繫結一個佇列

channel.queue_declare(queue='hello')

同時，由於接收方的工作方式是基於佇列的訊息執行一個回撥函式，當收到訊息時，Pika就會執行相應的回撥函式，因此我們需要定義此函式。

def callback(ch, method, properties, body):
    print " [x] Received %r" % (body,)

接下來我們需要初始化這個消費者，並對消費者進行啟動。

channel.basic_consume(callback,
                      queue='hello',
                      no_ack=True)
print ' [*] Waiting for messages. To exit press CTRL+C'
channel.start_consuming()

OK執行成功。

接下來就逐步的深入體驗RabbitMQ的獨特魅力。

/*學院顯示頁 內容下*/ var cpro_id = "u2659928";