linux安裝RabbitMQ

1、RabbitMQ概念
RabbitMQ是流行的開源消息隊列系統，是AMQP（Advanced Message Queuing Protocol高級消息隊列協議）的標準實現，用erlang語言開發。RabbitMQ聽說具備良好的性能和時效性，同時還可以很是好的支持集羣和負載部署，很是適合在較大規模的分佈式系統中使用。

消息中間件的工做過程能夠用生產者消費者模型來表示.即,生產者不斷的向消息隊列發送信息,而消費者從消息隊列中消費信息.具體過程以下:

從上圖可看出,對於消息隊列來講,生產者,消息隊列,消費者是最重要的三個概念,生產者發消息到消息隊列中去,消費者監聽指定的消息隊列,而且當消息隊列收到消息以後,接收消息隊列傳來的消息,而且給予相應的處理.消息隊列經常使用於分佈式系統之間互相信息的傳遞.

Rabbit模式大概分爲如下三種：單一模式、普通模式、鏡像模式
單一模式：最簡單的狀況，非集羣模式，即單實例服務。

普通模式：默認的集羣模式。
queue建立以後，若是沒有其它policy，則queue就會按照普通模式集羣。對於Queue來講，消息實體只存在於其中一個節點，A、B兩個節點僅有相同的元數據，即隊列結構，但隊列的元數據僅保存有一份，即建立該隊列的rabbitmq節點（A節點），當A節點宕機，你能夠去其B節點查看，./rabbitmqctl list_queues 發現該隊列已經丟失，但聲明的exchange還存在。
當消息進入A節點的Queue中後，consumer從B節點拉取時，RabbitMQ會臨時在A、B間進行消息傳輸，把A中的消息實體取出並通過B發送給consumer。
因此consumer應儘可能鏈接每個節點，從中取消息。即對於同一個邏輯隊列，要在多個節點創建物理Queue。不然不管consumer連A或B，出口總在A，會產生瓶頸。
該模式存在一個問題就是當A節點故障後，B節點沒法取到A節點中還未消費的消息實體。
若是作了消息持久化，那麼得等A節點恢復，而後纔可被消費；若是沒有持久化的話，隊列數據就丟失了。

鏡像模式：把須要的隊列作成鏡像隊列，存在於多個節點，屬於RabbitMQ的HA方案。
該模式解決了上述問題，其實質和普通模式不一樣之處在於，消息實體會主動在鏡像節點間同步，而不是在consumer取數據時臨時拉取。
該模式帶來的反作用也很明顯，除了下降系統性能外，若是鏡像隊列數量過多，加之大量的消息進入，集羣內部的網絡帶寬將會被這種同步通信大大消耗掉。
因此在對可靠性要求較高的場合中適用，一個隊列想作成鏡像隊列，須要先設置policy，而後客戶端建立隊列的時候，rabbitmq集羣根據「隊列名稱」自動設置是普通集羣模式或鏡像隊列。具體以下：
隊列經過策略來使能鏡像。策略能在任什麼時候刻改變，rabbitmq隊列也近可能的將隊列隨着策略變化而變化；非鏡像隊列和鏡像隊列之間是有區別的，前者缺少額外的鏡像基礎設施，沒有任何slave，所以會運行得更快。
爲了使隊列稱爲鏡像隊列，你將會建立一個策略來匹配隊列，設置策略有兩個鍵「ha-mode和 ha-params（可選）」。

瞭解集羣中的基本概念：
RabbitMQ的集羣節點包括內存節點、磁盤節點。顧名思義內存節點就是將全部數據放在內存，磁盤節點將數據放在磁盤。不過，如前文所述，若是在投遞消息時，打開了消息的持久化，那麼即便是內存節點，數據仍是安全的放在磁盤。
一個rabbitmq集羣中能夠共享user，vhost，queue，exchange等，全部的數據和狀態都是必須在全部節點上覆制的，一個例外是，那些當前只屬於建立它的節點的消息隊列，儘管它們可見且可被全部節點讀取。rabbitmq節點能夠動態的加入到集羣中，一個節點它能夠加入到集羣中，也能夠從集羣環集羣會進行一個基本的負載均衡。

集羣中有兩種節點：
1 內存節點：只保存狀態到內存（一個例外的狀況是：持久的queue的持久內容將被保存到disk）
2 磁盤節點：保存狀態到內存和磁盤。
內存節點雖然不寫入磁盤，可是它執行比磁盤節點要好。集羣中，只須要一個磁盤節點來保存狀態就足夠了若是集羣中只有內存節點，那麼不能中止它們，不然全部的狀態，消息等都會丟失。

RabitMQ的工做流程

對於RabbitMQ來講,除了這三個基本模塊之外,還添加了一個模塊,即交換機(Exchange).它使得生產者和消息隊列之間產生了隔離,生產者將消息發送給交換機,而交換機則根據調度策略把相應的消息轉發給對應的消息隊列.那麼RabitMQ的工做流程以下所示:

交換機的主要做用是接收相應的消息而且綁定到指定的隊列.交換機有四種類型,分別爲Direct,topic,headers,Fanout.
1).Direct是RabbitMQ默認的交換機模式,也是最簡單的模式.即建立消息隊列的時候,指定一個BindingKey.當發送者發送消息的時候,指定對應的Key.當Key和消息隊列的BindingKey一致的時候,消息將會被髮送到該消息隊列中.
2).topic轉發信息主要是依據通配符,隊列和交換機的綁定主要是依據一種模式(通配符+字符串),而當發送消息的時候,只有指定的Key和該模式相匹配的時候,消息纔會被髮送到該消息隊列中.
3).headers也是根據一個規則進行匹配,在消息隊列和交換機綁定的時候會指定一組鍵值對規則,而發送消息的時候也會指定一組鍵值對規則,當兩組鍵值對規則相匹配的時候,消息會被髮送到匹配的消息隊列中.
4).Fanout是路由廣播的形式,將會把消息發給綁定它的所有隊列,即使設置了key,也會被忽略.

2、RabbitMQ的安裝
1.ubuntu16.04中安裝RabbitMQ
1).首先必需要有Erlang環境支持
安裝以前要裝一些必要的庫:
# sudo apt-get install build-essential
# sudo apt-get install libncurses5-dev
# sudo apt-get install libssl-dev
# sudo apt-get install m4
# sudo apt-get install unixodbc unixodbc-dev
# sudo apt-get install freeglut3-dev libwxgtk2.8-dev
# sudo apt-get install xsltproc
# sudo apt-get install fop
# sudo apt-get install tk8.5

安裝好以後運行:
# sudo apt-get install erlang
完成後在控制檯輸入命令：
erl
能夠查看erlang安裝版本狀況
2).安裝RabbitMQ（能夠用兩種方式）

自動安裝
# sudo apt-get install rabbitmq-server
若是沒有問題，那就直接安裝了，不用設置什麼東西

查看運行狀態
# service rabbitmq-server status


手動安裝
1).首先建立一個文件夾用來下載RabbitMQ
# mkdir rabbitmqsoft
# cd rabbitmqsoft
2).獲取安裝包（這裏選擇2.7.0 unix版本）
# wget http://www.rabbitmq.com/releases/rabbitmq-server/v2.7.0/rabbitmq-server-generic-unix-2.7.0.tar.gz
--解壓
# tar -zxvf rabbitmq-server-generic-unix-2.7.0.tar.gz
# cd rabbitmq_server-2.7.0/
3).運行
# sbin/rabbitmq-server
4).查看運行狀態（打開另一個終端）
# cd ~/rabbitmqsoft/rabbitmq_server-2.7.0/
# sbin/rabbitmqctl status
到底爲止，Ubuntu系統下安裝RabbitMQ就完成了

1.centos7中安裝RabbitMQ
1).首先須要安裝erlang
#rpm -Uvh http://download.fedoraproject.org/pub/epel/7/x86_64/e/epel-release-7-8.noarch.rpm
#yum install erlang
安裝過程當中會有提示，一路輸入「y」便可。
2).完成後安裝RabbitMQ：
先下載rpm：
#wget http://www.rabbitmq.com/releases/rabbitmq-server/v3.6.6/rabbitmq-server-3.6.6-1.el7.noarch.rpm
下載完成後安裝：
#yum install rabbitmq-server-3.6.6-1.el7.noarch.rpm
完成後啓動服務：
#service rabbitmq-server start
能夠查看服務狀態：
#service rabbitmq-server status

3、RabbitMQ的配置
1.修改配置文件
經過查看服務狀態：
#service rabbitmq-server status

這裏能夠看到log文件的位置，轉到文件位置，打開文件：

這裏顯示的是沒有找到配置文件，咱們能夠本身建立這個文件
#cd /etc/rabbitmq/
#vim rabbitmq.config
編輯內容以下：
[{rabbit, [{loopback_users, []}]}].
這裏的意思是開放使用，rabbitmq默認建立的用戶guest，密碼也是guest，這個用戶默認只能是本機訪問，localhost或者127.0.0.1，從外部訪問須要添加上面的配置。

保存配置後重啓服務：
#service rabbitmq-server stop
#service rabbitmq-server start

2.安裝插件
#/sbin/rabbitmq-plugins enable rabbitmq_management
重啓rabbitmq服務
#service rabbitmq-server restart
到此,就能夠經過http://ip:15672 使用guest,guest 進行登錄web頁面了

4、RabbitMQ用戶角色及權限控制
1.RabbitMQ的用戶角色分類：
none、management、policymaker、monitoring、administrator
2.RabbitMQ各種角色描述：
none
不能訪問 management plugin

management
用戶能夠經過AMQP作的任何事外加：
列出本身能夠經過AMQP登入的virtual hosts  
查看本身的virtual hosts中的queues, exchanges 和 bindings
查看和關閉本身的channels 和 connections
查看有關本身的virtual hosts的「全局」的統計信息，包含其餘用戶在這些virtual hosts中的活動。

policymaker
management能夠作的任何事外加：
查看、建立和刪除本身的virtual hosts所屬的policies和parameters

monitoring  
management能夠作的任何事外加：
列出全部virtual hosts，包括他們不能登陸的virtual hosts
查看其餘用戶的connections和channels
查看節點級別的數據如clustering和memory使用狀況
查看真正的關於全部virtual hosts的全局的統計信息

administrator   
policymaker和monitoring能夠作的任何事外加:
建立和刪除virtual hosts
查看、建立和刪除users
查看建立和刪除permissions
關閉其餘用戶的connections

3.建立用戶並設置角色：
能夠建立管理員用戶，負責整個MQ的運維，例如：
$sudo rabbitmqctl add_user  user_admin  passwd_admin  
賦予其administrator角色：
$sudo rabbitmqctl set_user_tags user_admin administrator  

能夠建立RabbitMQ監控用戶，負責整個MQ的監控，例如：
$sudo rabbitmqctl add_user  user_monitoring  passwd_monitor  
賦予其monitoring角色：
$sudo rabbitmqctl set_user_tags user_monitoring monitoring  

能夠建立某個項目的專用用戶，只能訪問項目本身的virtual hosts
$sudo rabbitmqctl  add_user  user_proj  passwd_proj  
賦予其monitoring角色：
$sudo rabbitmqctl set_user_tags user_proj management  

建立和賦角色完成後查看並確認：
$sudo rabbitmqctl list_users  

4.RabbitMQ權限控制
默認virtual host："/"
默認用戶：guest
guest具備"/"上的所有權限，僅能有localhost訪問RabbitMQ包括Plugin，建議刪除或更改密碼。可經過將配置文件中loopback_users置孔來取消其本地訪問的限制：
[{rabbit, [{loopback_users, []}]}]

用戶僅能對其所能訪問的virtual hosts中的資源進行操做。這裏的資源指的是virtual hosts中的exchanges、queues等，操做包括對資源進行配置、寫、讀。配置權限可建立、刪除、資源並修改資源的行爲，寫權限可向資源發送消息，讀權限從資源獲取消息。好比：
exchange和queue的declare與delete分別須要exchange和queue上的配置權限
exchange的bind與unbind須要exchange的讀寫權限
queue的bind與unbind須要queue寫權限exchange的讀權限
發消息(publish)需exchange的寫權限
獲取或清除(get、consume、purge)消息需queue的讀權限
對何種資源具備配置、寫、讀的權限經過正則表達式來匹配，具體命令以下：
set_permissions [-p <vhostpath>] <user> <conf> <write> <read>
其中，<conf> <write> <read>的位置分別用正則表達式來匹配特定的資源，如'^(amq\.gen.*|amq\.default)$'能夠匹配server生成的和默認的exchange，'^$'不匹配任何資源

須要注意的是RabbitMQ會緩存每一個connection或channel的權限驗證結果、所以權限發生變化後須要重連才能生效。

爲用戶賦權：
$sudo rabbitmqctl  set_permissions -p /vhost1  user_admin '.*' '.*' '.*'  
該命令使用戶user_admin具備/vhost1這個virtual host中全部資源的配置、寫、讀權限以便管理其中的資源
查看權限:
$sudo rabbitmqctl list_user_permissions user_admin  
Listing permissions for user "user_admin" ...  
/vhost1<span style="white-space:pre"> </span>.*<span style="white-space:pre"> </span>.*<span style="white-space:pre"> </span>.*  

$sudo rabbitmqctl list_permissions -p /vhost1  
Listing permissions in vhost "/vhost1" ...  
user_admin<span style="white-space:pre">  </span>.*<span style="white-space:pre"> </span>.*<span style="white-space:pre"> </span>.*