一、RabbitMQ概念

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

Rabbit模式大概分為以下三種：?jiǎn)我荒Ｊ健⑵胀Ｊ?、鏡像模式

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

普通模式：默認(rèn)的集群模式。

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

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

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

該模式存在一個(gè)問題就是當(dāng)A節(jié)點(diǎn)故障后，B節(jié)點(diǎn)無法取到A節(jié)點(diǎn)中還未消費(fèi)的消息實(shí)體。

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

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

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

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

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

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

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

了解集群中的基本概念：

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

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

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

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

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

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

二、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

安裝好之后運(yùn)行:

# sudo apt-get install erlang

完成后在控制臺(tái)輸入命令：

erl

可以查看erlang安裝版本情況

2).安裝RabbitMQ（可以用兩種方式）

自動(dòng)安裝

# sudo apt-get install rabbitmq-server

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

查看運(yùn)行狀態(tài)

# service rabbitmq-server status

手動(dòng)安裝

1).首先創(chuàng)建一個(gè)文件夾用來下載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).運(yùn)行

# sbin/rabbitmq-server

4).查看運(yùn)行狀態(tài)（打開另外一個(gè)終端）

# 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

安裝過程中會(huì)有提示，一路輸入“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 

完成后啟動(dòng)服務(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)建這個(gè)文件

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

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

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

這里的意思是開放使用，rabbitmq默認(rèn)創(chuàng)建的用戶guest，密碼也是guest，這個(gè)用戶默認(rèn)只能是本機(jī)訪問，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 進(jìn)行登陸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)計(jì)信息，包含其他用戶在這些virtual hosts中的活動(dòng)。

policymaker

management可以做的任何事外加：

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

monitoring 

management可以做的任何事外加：

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

查看其他用戶的connections和channels

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

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

administrator  

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

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

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

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

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

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

可以創(chuàng)建管理員用戶，負(fù)責(zé)整個(gè)MQ的運(yùn)維，例如：

$sudo rabbitmqctl add_user user_admin passwd_admin 

賦予其administrator角色：

$sudo rabbitmqctl set_user_tags user_admin administrator 

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

$sudo rabbitmqctl add_user user_monitoring passwd_monitor 

賦予其monitoring角色：

$sudo rabbitmqctl set_user_tags user_monitoring monitoring 

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

$sudo rabbitmqctl add_user user_proj passwd_proj 

賦予其monitoring角色：

$sudo rabbitmqctl set_user_tags user_proj management 

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

$sudo rabbitmqctl list_users 

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

默認(rèn)virtual host："/"

默認(rèn)用戶：guest

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

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

用戶僅能對(duì)其所能訪問的virtual hosts中的資源進(jìn)行操作。這里的資源指的是virtual hosts中的exchanges、queues等，操作包括對(duì)資源進(jìn)行配置、寫、讀。配置權(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)限

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

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

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

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

為用戶賦權(quán)：

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

該命令使用戶user_admin具有/vhost1這個(gè)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詳細(xì)教程，希望對(duì)大家有所幫助，如果大家有任何疑問請(qǐng)給我留言，小編會(huì)及時(shí)回復(fù)大家的。在此也非常感謝大家對(duì)腳本之家網(wǎng)站的支持！

最新評(píng)論