RabbitMQ安裝及使用

系列文章目錄

文章目錄

系列文章目錄
前言
一、下載
二、安裝
三、插件安裝
四、配置
五、權限
六、集群模式

前言

前些天發現了一個巨牛的人工智能學習網站，通俗易懂，風趣幽默，忍不住分享一下給大家。點擊跳轉到網站，這篇文章男女通用，看懂了就去分享給你的碼吧。
在這里插入圖片描述

一、下載

由于RabbitMQ是基于Erlang語言開發，所以在安裝RabbitMQ之前，需要先安裝Erlang。好在RabbitMQ官網已經為我們提供了Erlang的安裝包

Erlang下載地址：http://www.rabbitmq.com/releases/erlang/

本人使用的操作系統為：CentOS7

下載的Erlang安裝包為：erlang-19.0.4-1.el7.centos.x86_64.rpm

RabbitMQ下載地址：https://www.rabbitmq.com/download.html

下載的RabbitMQ安裝包為：rabbitmq-server-3.6.8-1.el7.noarch.rpm

二、安裝

將下載的兩個文件上傳到/usr/local目錄，先安裝Erlang

yum install erlang-19.0.4-1.el7.centos.x86_64.rpm

測試Erlang是否安裝成功

erl -version

出現以下信息則表示安裝成功：Erlang (SMP,ASYNC_THREADS,HIPE) (BEAM) emulator version 8.0.3

安裝RabbitMQ

yum install rabbitmq-server-3.6.8-1.el7.noarch.rpm

運行RabbitMQ

cd /usr/sbin
./rabbitmq-server start

出現以下信息，則表示啟動成功：

RabbitMQ 3.6.8. Copyright ? 2007-2016 Pivotal Software, Inc.

## ## Licensed under the MPL. See http://www.rabbitmq.com/
## ##
########## Logs: /var/log/rabbitmq/rabbit@mq01.log
###### ## /var/log/rabbitmq/rabbit@mq01-sasl.log
##########
Starting broker...
completed with 0 plugins.

后臺啟動可使用：

./rabbitmq-server -detached

停止服務可使用：

./rabbitmqctl stop

三、插件安裝

查看目前RabbitMQ已安裝的插件

cd /usr/sbin
./rabbitmq-plugins list

安裝web管理端

./rabbitmq-plugins enable rabbitmq_management

安裝成功后，啟動MQ

通過瀏覽器訪問地址：http://192.168.120.129:15672/#/

由于guest用戶被限制，只能通過localhost訪問，因此我們需要新建一個用戶，并授予管理員權限。

新建一個用戶名為admin,密碼為admin的用戶，并授予管理員（administrator）權限

./rabbitmqctl add_user admin admin
./rabbitmqctl set_user_tags admin administrator

安裝mqtt

./rabbitmq-plugins enable rabbitmq_mqtt

安裝websocket

./rabbitmq-plugins enable rabbitmq_web_stomp
./rabbitmq-plugins enable rabbitmq_web_stomp_examples

四、配置

如果需要修改RabbitMQ的默認配置，先查找配置文件樣例位置

find / -name "rabbitmq.config.example"

然后將樣例配置復制到制定目錄

cp /usr/share/doc/rabbitmq-server-3.6.8/rabbitmq.config.example /etc/rabbitmq/rabbitmq.config

修改樣例文件，并保存，重啟MQ生效。

五、權限

主要是set_permissions的使用，先看下命令的格式：

set_permissions [-p vhost] {user} {conf} {write} {read}
首先需要注意以下幾點的理解：

1.這里的權限，只是針對一般用戶的訪問權限，注意和角色的區分。舉個例子來說，非管理用戶（普通用戶），角色設置為none，然后在這里配置conf、write、read的權限。

2.conf、write、read采用正則表達式，這里的正則主要是針對exchange和queue。主要2種特殊的表達式：

^$：表示完全不匹配（即沒有權限）

.*：表示匹配所有（即所有權限）

如果使用RabbitMQ作為消息推送服務，需要授予用戶只讀訪問Stomp主題權限，同時授予另一個用戶對同一主題的讀寫訪問權限。

這樣的話主題訂閱者就不能發布消息，從而解決安全性問題。

但是如果直接這樣授權：

rabbitmqctl set_permissions read-only-user '.*' '^$' '.*'

會報如下錯誤：

 ERROR message:access_refused content-type:text/plain version:1.0,1.1,1.2 content-length:114 ACCESS_REFUSED - access to queue 'stomp-subscription-APK3zkvXFqxvSiZ9ztmxYQ' in vhost '/' refused for user 'test'Whoops! Lost connection to ws://221.0.200.202:15674/ws

這樣配置存在一個問題，將阻止任何寫入，阻止任何寫入將導致沒有權限連接到RabbitMQ的服務

需要對可讀用戶權限做如下調整：

rabbitmqctl set_permissions read-only-user '^stomp-subscription.*$' '^stomp-subscription.*$' '.*'

六、集群模式

RabbitMQ集群模式分為兩種：普通模式，鏡像模式（HA）

普通模式：默認的集群模式
對于Queue來說，消息實體只存在于其中一個節點，A、B兩個節點僅有相同的元數據，即隊列結構。

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

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

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

如果做了消息持久化，那么得等A節點恢復，然后才可被消費；如果沒有持久化的話，然后就沒有然后了……

鏡像模式：把需要的隊列做成鏡像隊列，存在于多個節點，屬于RabbitMQ的HA方案
該模式解決了上述問題，其實質和普通模式不同之處在于，消息實體會主動在鏡像節點間同步，而不是在consumer取數據時臨時拉取。

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

所以在對可靠性要求較高的場合中適用。

服務器信息：
　我們準備了兩臺服務器，系統為Centos7，對應的ip跟hostname分別為

192.168.1.242    mq01
192.168.1.243    mq02

在安裝好的兩臺節點服務器中，分別修改/etc/hosts文件，指定mq01，mq02的hosts，如：

192.168.1.242    mq01
192.168.1.243    mq02

注意：hostname文件也要正確，分別是mq01、mq02，如果修改hostname建議在安裝rabbitmq前修改。

設置 Erlang Cookie：
Rabbitmq的集群是依賴于erlang的集群來工作的，所以必須先構建起erlang的集群環境。Erlang的集群中各節點是通過一個magic cookie來實現的，這個cookie存放在 /var/lib/rabbitmq/.erlang.cookie 中，文件是400的權限。所以必須保證各節點cookie保持一致，否則節點之間就無法通信。

查看文件權限的命令為：

ls -l /var/lib/rabbitmq/.erlang.cookie

這里將 mq01的 /var/lib/rabbitmq/.erlang.cookie文件復制到 mq02，由于這個文件權限是 400，所以需要先修改該文件權限為 777：

chmod 777 /var/lib/rabbitmq/.erlang.cookie

使用scp或其他方式將該文件復制到mq02服務器的相同目錄，并覆蓋。

然后將mq01的 /var/lib/rabbitmq/.erlang.cookie文件權限修改回來

chmod 400 /var/lib/rabbitmq/.erlang.cookie

組成集群
重啟RabbitMQ服務：

rabbitmqctl stop
rabbitmq-server -detached

將mq02與mq01組成集群:

./rabbitmqctl stop_app
./rabbitmqctl join_cluster rabbit@mq01
./rabbitmqctl stop
./rabbitmq-server -detached

如果要使用內存節點，則可以使用–ram：

rabbitmqctl join_cluster --ram rabbit@mq01

查看集群是否配置成功：

rabbitmqctl cluster_status

HA集群模式配置
　上面配置RabbitMQ默認集群模式，但并不保證隊列的高可用性，盡管交換機、綁定這些可以復制到集群里的任何一個節點，但是隊列內容不會復制，雖然該模式解決一部分節點壓力，但隊列節點宕機直接導致該隊列無法使用，只能等待重啟，所以要想在隊列節點宕機或故障也能正常使用，就要復制隊列內容到集群里的每個節點，需要創建鏡像隊列。

設置鏡像隊列策略
在任意一個節點上執行：

rabbitmqctl set_policy ha-all "^" '{"ha-mode":"all"}'

將所有隊列設置為鏡像隊列，即隊列會被復制到各個節點，各個節點狀態保持一直。

如果要為制定的vhost創建策略則使用-p：

rabbitmqctl set_policy -p hrsystem ha-allqueue"^" '{"ha-mode":"all"}'

這行命令在vhost名稱為hrsystem創建了一個策略，策略名稱為ha-allqueue,策略模式為 all 即復制到所有節點，包含新增節點，
策略正則表達式為 “^” 表示所有匹配所有隊列名稱。
例如rabbitmqctl set_policy -p hrsystem ha-allqueue “^message” ‘{“ha-mode”:“all”}’
注意：“^message” 這個規則要根據自己修改，這個是指同步"message"開頭的隊列名稱，我們配置時使用的應用于所有隊列，所以表達式為"^"

安裝并配置 HAProxy
在服務器上安裝 HAProxy，然后修改
/etc/haproxy/haproxy.cfg：

listen rabbitmq_cluster 0.0.0.0:5672mode tcp
balance roundrobinserver   node1 192.168.1.242:5672 check inter 2000 rise 2 fall 3  
server   node2 192.168.1.243:5672 check inter 2000 rise 2 fall 3