一、RabbitMQ概念

RabbitMQ是流行的開源消息隊列系統(tǒng)，是AMQP（Advanced Message Queuing Protocol高級消息隊列協(xié)議）的標準實現(xiàn)，用erlang語言開發(fā)。RabbitMQ據(jù)說具有良好的性能和時效性，同時還能夠非常好的支持集群和負載部署，非常適合在較大規(guī)模的分布式系統(tǒng)中使用。

Rabbit模式大概分為以下三種：單一模式、普通模式、鏡像模式

單一模式：最簡單的情況，非集群模式，即單實例服務(wù)。

普通模式：默認的集群模式。

queue創(chuàng)建之后，如果沒有其它policy，則queue就會按照普通模式集群。對于Queue來說，消息實體只存在于其中一個節(jié)點，A、B兩個節(jié)點僅有相同的元數(shù)據(jù)，即隊列結(jié)構(gòu)，但隊列的元數(shù)據(jù)僅保存有一份，即創(chuàng)建該隊列的rabbitmq節(jié)點（A節(jié)點），當A節(jié)點宕機，你可以去其B節(jié)點查看，./rabbitmqctl list_queues 發(fā)現(xiàn)該隊列已經(jīng)丟失，但聲明的exchange還存在。

當消息進入A節(jié)點的Queue中后，consumer從B節(jié)點拉取時，RabbitMQ會臨時在A、B間進行消息傳輸，把A中的消息實體取出并經(jīng)過B發(fā)送給consumer。

所以consumer應(yīng)盡量連接每一個節(jié)點，從中取消息。即對于同一個邏輯隊列，要在多個節(jié)點建立物理Queue。否則無論consumer連A或B，出口總在A，會產(chǎn)生瓶頸。

該模式存在一個問題就是當A節(jié)點故障后，B節(jié)點無法取到A節(jié)點中還未消費的消息實體。

如果做了消息持久化，那么得等A節(jié)點恢復，然后才可被消費；如果沒有持久化的話，隊列數(shù)據(jù)就丟失了。

鏡像模式：把需要的隊列做成鏡像隊列，存在于多個節(jié)點，屬于RabbitMQ的HA方案。

該模式解決了上述問題，其實質(zhì)和普通模式不同之處在于，消息實體會主動在鏡像節(jié)點間同步，而不是在consumer取數(shù)據(jù)時臨時拉取。

該模式帶來的副作用也很明顯，除了降低系統(tǒng)性能外，如果鏡像隊列數(shù)量過多，加之大量的消息進入，集群內(nèi)部的網(wǎng)絡(luò)帶寬將會被這種同步通訊大大消耗掉。

所以在對可靠性要求較高的場合中適用，一個隊列想做成鏡像隊列，需要先設(shè)置policy，然后客戶端創(chuàng)建隊列的時候，rabbitmq集群根據(jù)“隊列名稱”自動設(shè)置是普通集群模式或鏡像隊列。具體如下：

隊列通過策略來使能鏡像。策略能在任何時刻改變，rabbitmq隊列也近可能的將隊列隨著策略變化而變化；非鏡像隊列和鏡像隊列之間是有區(qū)別的，前者缺乏額外的鏡像基礎(chǔ)設(shè)施，沒有任何slave，因此會運行得更快。

為了使隊列稱為鏡像隊列，你將會創(chuàng)建一個策略來匹配隊列，設(shè)置策略有兩個鍵“ha-mode和 ha-params（可選）”。

了解集群中的基本概念：

RabbitMQ的集群節(jié)點包括內(nèi)存節(jié)點、磁盤節(jié)點。顧名思義內(nèi)存節(jié)點就是將所有數(shù)據(jù)放在內(nèi)存，磁盤節(jié)點將數(shù)據(jù)放在磁盤。不過，如前文所述，如果在投遞消息時，打開了消息的持久化，那么即使是內(nèi)存節(jié)點，數(shù)據(jù)還是安全的放在磁盤。

一個rabbitmq集群中可以共享user，vhost，queue，exchange等，所有的數(shù)據(jù)和狀態(tài)都是必須在所有節(jié)點上復制的，一個例外是，那些當前只屬于創(chuàng)建它的節(jié)點的消息隊列，盡管它們可見且可被所有節(jié)點讀取。rabbitmq節(jié)點可以動態(tài)的加入到集群中，一個節(jié)點它可以加入到集群中，也可以從集群環(huán)集群會進行一個基本的負載均衡。

集群中有兩種節(jié)點：

1 內(nèi)存節(jié)點：只保存狀態(tài)到內(nèi)存（一個例外的情況是：持久的queue的持久內(nèi)容將被保存到disk）

2 磁盤節(jié)點：保存狀態(tài)到內(nèi)存和磁盤。

內(nèi)存節(jié)點雖然不寫入磁盤，但是它執(zhí)行比磁盤節(jié)點要好。集群中，只需要一個磁盤節(jié)點來保存狀態(tài)就足夠了如果集群中只有內(nèi)存節(jié)點，那么不能停止它們，否則所有的狀態(tài)，消息等都會丟失。

二、RabbitMQ的安裝

1.ubuntu16.04中安裝RabbitMQ

1).首先必須要有Erlang環(huán)境支持

安裝之前要裝一些必要的庫:

# 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

如果沒有問題，那就直接安裝了，不用設(shè)置什么東西

查看運行狀態(tài)

# service rabbitmq-server status

手動安裝

1).首先創(chuàng)建一個文件夾用來下載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).查看運行狀態(tài)（打開另外一個終端）

# cd ~/rabbitmqsoft/rabbitmq_server-2.7.0/
# sbin/rabbitmqctl status

到底為止，Ubuntu系統(tǒng)下安裝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 

完成后啟動服務(wù)：

#service rabbitmq-server start

可以查看服務(wù)狀態(tài)：

#service rabbitmq-server status

三、RabbitMQ的配置

1.修改配置文件

通過查看服務(wù)狀態(tài)：

#service rabbitmq-server status

這里可以看到log文件的位置，轉(zhuǎn)到文件位置，打開文件：

這里顯示的是沒有找到配置文件，我們可以自己創(chuàng)建這個文件

#cd /etc/rabbitmq/
#vim rabbitmq.config

編輯內(nèi)容如下：

[{rabbit, [{loopback_users, []}]}].

這里的意思是開放使用，rabbitmq默認創(chuàng)建的用戶guest，密碼也是guest，這個用戶默認只能是本機訪問，localhost或者127.0.0.1，從外部訪問需要添加上面的配置。

保存配置后重啟服務(wù)：

#service rabbitmq-server stop
#service rabbitmq-server start

2.安裝插件

#/sbin/rabbitmq-plugins enable rabbitmq_management 

重啟rabbitmq服務(wù)

#service rabbitmq-server restart 

到此,就可以通過http://ip:15672 使用guest,guest 進行登陸web頁面了

四、RabbitMQ用戶角色及權(quán)限控制

1.RabbitMQ的用戶角色分類：

none、management、policymaker、monitoring、administrator

2.RabbitMQ各類角色描述：

none

不能訪問 management plugin

management

用戶可以通過AMQP做的任何事外加：

列出自己可以通過AMQP登入的virtual hosts 

查看自己的virtual hosts中的queues, exchanges 和 bindings

查看和關(guān)閉自己的channels 和 connections

查看有關(guān)自己的virtual hosts的“全局”的統(tǒng)計信息，包含其他用戶在這些virtual hosts中的活動。

policymaker

management可以做的任何事外加：

查看、創(chuàng)建和刪除自己的virtual hosts所屬的policies和parameters

monitoring 

management可以做的任何事外加：

列出所有virtual hosts，包括他們不能登錄的virtual hosts

查看其他用戶的connections和channels

查看節(jié)點級別的數(shù)據(jù)如clustering和memory使用情況

查看真正的關(guān)于所有virtual hosts的全局的統(tǒng)計信息

administrator  

policymaker和monitoring可以做的任何事外加:

創(chuàng)建和刪除virtual hosts

查看、創(chuàng)建和刪除users

查看創(chuàng)建和刪除permissions

關(guān)閉其他用戶的connections

3.創(chuàng)建用戶并設(shè)置角色：

可以創(chuàng)建管理員用戶，負責整個MQ的運維，例如：

$sudo rabbitmqctl add_user user_admin passwd_admin 

賦予其administrator角色：

$sudo rabbitmqctl set_user_tags user_admin administrator 

可以創(chuàng)建RabbitMQ監(jiān)控用戶，負責整個MQ的監(jiān)控，例如：

$sudo rabbitmqctl add_user user_monitoring passwd_monitor 

賦予其monitoring角色：

$sudo rabbitmqctl set_user_tags user_monitoring monitoring 

可以創(chuàng)建某個項目的專用用戶，只能訪問項目自己的virtual hosts

$sudo rabbitmqctl add_user user_proj passwd_proj 

賦予其monitoring角色：

$sudo rabbitmqctl set_user_tags user_proj management 

創(chuàng)建和賦角色完成后查看并確認：

$sudo rabbitmqctl list_users 

4.RabbitMQ權(quán)限控制

默認virtual host："/"

默認用戶：guest

guest具有"/"上的全部權(quán)限，僅能有l(wèi)ocalhost訪問RabbitMQ包括Plugin，建議刪除或更改密碼?？赏ㄟ^將配置文件中l(wèi)oopback_users置孔來取消其本地訪問的限制：

[{rabbit, [{loopback_users, []}]}]

用戶僅能對其所能訪問的virtual hosts中的資源進行操作。這里的資源指的是virtual hosts中的exchanges、queues等，操作包括對資源進行配置、寫、讀。配置權(quán)限可創(chuàng)建、刪除、資源并修改資源的行為，寫權(quán)限可向資源發(fā)送消息，讀權(quán)限從資源獲取消息。比如：

exchange和queue的declare與delete分別需要exchange和queue上的配置權(quán)限

exchange的bind與unbind需要exchange的讀寫權(quán)限

queue的bind與unbind需要queue寫權(quán)限exchange的讀權(quán)限

發(fā)消息(publish)需exchange的寫權(quán)限

獲取或清除(get、consume、purge)消息需queue的讀權(quán)限

對何種資源具有配置、寫、讀的權(quán)限通過正則表達式來匹配，具體命令如下：

set_permissions [-p <vhostpath>] <user> <conf> <write> <read>

其中，<conf> <write> <read>的位置分別用正則表達式來匹配特定的資源，如'^(amq\.gen.*|amq\.default)$'可以匹配server生成的和默認的exchange，'^$'不匹配任何資源

需要注意的是RabbitMQ會緩存每個connection或channel的權(quán)限驗證結(jié)果、因此權(quán)限發(fā)生變化后需要重連才能生效。

為用戶賦權(quán)：

$sudo rabbitmqctl set_permissions -p /vhost1 user_admin '.*' '.*' '.*' 

該命令使用戶user_admin具有/vhost1這個virtual host中所有資源的配置、寫、讀權(quán)限以便管理其中的資源

查看權(quán)限:

$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>.* 

以上所述是小編給大家介紹的linux安裝RabbitMQ詳細教程，希望對大家有所幫助，如果大家有任何疑問請給我留言，小編會及時回復大家的。在此也非常感謝大家對腳本之家網(wǎng)站的支持！

最新評論