RabbitMQ安裝與配置
RabbitMQ
RabbitMQ 是一個由 Erlang 語言開發的 AMQP 的開源實現。AMQP ：Advanced Message Queue，高級消息隊列協議。它是應用層協議的一個開放標準，為面向消息的中間件設計，基於此協議的客戶端與消息中間件可傳遞消息，並不受產品、開發語言等條件的限制。
消息隊列是什麽
消息（Message）是指在應用間傳送的數據。消息可以非常簡單，比如只包含文本字符串，也可以更復雜，可能包含嵌入對象。消息隊列（Message Queue）是一種應用間的通信方式，消息發送後可以立即返回，由消息系統來確保消息的可靠傳遞。消息發布者只管把消息發布到 MQ 中而不用管誰來取，消息使用者只管從 MQ 中取消息而不管是誰發布的。這樣發布者和使用者都不用知道對方的存在。
為何用消息隊列
從上面的描述中可以看出消息隊列是一種應用間的異步協作機制，那什麽時候需要使用 MQ 呢？以常見的訂單系統為例，用戶點擊【下單】按鈕之後的業務邏輯可能包括：扣減庫存、生成相應單據、發紅包、發短信通知。在業務發展初期這些邏輯可能放在一起同步執行，隨著業務的發展訂單量增長，需要提升系統服務的性能，這時可以將一些不需要立即生效的操作拆分出來異步執行，比如發放紅包、發短信通知等。這種場景下就可以用 MQ ，在下單的主流程（比如扣減庫存、生成相應單據）完成之後發送一條消息到 MQ 讓主流程快速完結，而由另外的單獨線程拉取MQ的消息（或者由 MQ 推送消息），當發現 MQ 中有發紅包或發短信之類的消息時，執行相應的業務邏輯。以上是用於業務解耦的情況，其它常見場景包括最終一致性、廣播、錯峰流控等等。
RabbitMQ特點
RabbitMQ 是一個由 Erlang 語言開發的 AMQP 的開源實現。AMQP ：Advanced Message Queue，高級消息隊列協議。它是應用層協議的一個開放標準，為面向消息的中間件設計，基於此協議的客戶端與消息中間件可傳遞消息，並不受產品、開發語言等條件的限制。RabbitMQ 最初起源於金融系統，用於在分布式系統中存儲轉發消息，在易用性、擴展性、高可用性等方面表現不俗。具體特點包括：
- 可靠性（Reliability）
RabbitMQ 使用一些機制來保證可靠性，如持久化、傳輸確認、發布確認。 - 靈活的路由（Flexible Routing）
在消息進入隊列之前，通過 Exchange 來路由消息的。對於典型的路由功能，RabbitMQ 已經提供了一些內置的 Exchange 來實現。針對更復雜的路由功能，可以將多個 Exchange 綁定在一起，也通過插件機制實現自己的 Exchange 。 - 消息集群（Clustering）
多個 RabbitMQ 服務器可以組成一個集群，形成一個邏輯 Broker 。 - 高可用（Highly Available Queues）
隊列可以在集群中的機器上進行鏡像，使得在部分節點出問題的情況下隊列仍然可用。 - 多種協議（Multi-protocol）
RabbitMQ 支持多種消息隊列協議，比如 STOMP、MQTT 等等。 - 多語言客戶端（Many Clients）
RabbitMQ 幾乎支持所有常用語言，比如 Java、.NET、Ruby 等等。 - 管理界面（Management UI）
RabbitMQ 提供了一個易用的用戶界面，使得用戶可以監控和管理消息 Broker 的許多方面。 - 跟蹤機制（Tracing）
如果消息異常，RabbitMQ 提供了消息跟蹤機制，使用者可以找出發生了什麽。 - 插件機制（Plugin System）
RabbitMQ 提供了許多插件，來從多方面進行擴展，也可以編寫自己的插件。
安裝RabbitMQ
通過yum等軟件倉庫都可以直接安裝RabbitMQ，但版本一般都較為保守。RabbitMQ官網提供了新版的rpm包（http://www.rabbitmq.com/download.html），但是安裝的時候會提示需要erlang版本>=19.3，然而默認yum倉庫中的版本較低。其實RabbitMQ在github上有提供新的erlang包（https://github.com/rabbitmq/erlang-rpm）也可以直接加到yum源中
#cat /etc/yum.repos.d/rabbitmq-erlang.repo
[rabbitmq-erlang]
name=rabbitmq-erlang
baseurl=https://dl.bintray.com/rabbitmq/rpm/erlang/20/el/7
gpgcheck=1
gpgkey=https://dl.bintray.com/rabbitmq/Keys/rabbitmq-release-signing-key.asc
repo_gpgcheck=0
enabled=1
#yum clean all
#yum makecache然後下載RabbitMQ的RPM包(http://www.rabbitmq.com/download.html)
這裏是centos7的版本
#wget https://dl.bintray.com/rabbitmq/all/rabbitmq-server/3.7.4/rabbitmq-server-3.7.4-1.el7.noarch.rpm
#yum install rabbitmq-server-3.7.4-1.el7.noarch.rpm
yum會自動去源裏安裝依賴包安裝到這裏就完成了
基本操作
$ sudo chkconfig rabbitmq-server on # 添加開機啟動RabbitMQ服務
$ sudo /sbin/service rabbitmq-server start # 啟動服務
$ sudo /sbin/service rabbitmq-server status # 查看服務狀態
$ sudo /sbin/service rabbitmq-server stop # 停止服務
# 查看當前所有用戶
$ sudo rabbitmqctl list_users
# 查看默認guest用戶的權限
$ sudo rabbitmqctl list_user_permissions guest
# 由於RabbitMQ默認的賬號用戶名和密碼都是guest。為了安全起見, 先刪掉默認用戶
$ sudo rabbitmqctl delete_user guest
# 添加新用戶
$ sudo rabbitmqctl add_user username password
# 設置用戶tag
$ sudo rabbitmqctl set_user_tags username administrator
# 賦予用戶默認vhost的全部操作權限
$ sudo rabbitmqctl set_permissions -p / username ".*" ".*" ".*"
# 查看用戶的權限
$ sudo rabbitmqctl list_user_permissions username
更多關於rabbitmqctl的使用，可以參考幫助手冊。
開啟Web管理接口
如果只從命令行操作RabbitMQ，多少有點不方便。幸好RabbitMQ自帶了web管理界面，只需要啟動插件便可以使用。
$ sudo rabbitmq-plugins enable rabbitmq_management然後通過瀏覽器訪問：IP:15672
輸入用戶名和密碼訪問web管理界面了。
配置RabbitMQ
關於RabbitMQ的配置，可以下載RabbitMQ的配置文件模板到/etc/rabbitmq/rabbitmq.config, 然後按照需求更改即可。關於每個配置項的具體作用，可以參考官方文檔。更新配置後，別忘了重啟服務
#!/bin/bash
rpm -vih epel-release-latest-6.noarch.rpm
yum install -y erlang
rpm -vih rabbitmq-server-3.3.4-1.noarch.rpm
mkdir -p /data/rabbitmq
mkdir -p /data/weblogs/rabbitmq
chown -R rabbitmq:rabbitmq /data/weblogs/rabbitmq/
chown -R rabbitmq:rabbitmq /data/rabbitmq/
cat >> /etc/rabbitmq/rabbitmq-env.conf<<EOF
RABBITMQ_MNESIA_BASE=/data/rabbitmq/mnesia
RABBITMQ_LOG_BASE=/data/weblogs/rabbitmq
EOF
/usr/sbin/rabbitmq-plugins enable rabbitmq_management
cp /usr/share/doc/rabbitmq-server-3.3.4/rabbitmq.config.example /etc/rabbitmq/rabbitmq.config
sed -i ‘9a\ {loopback_users, []}‘ /etc/rabbitmq/rabbitmq.confi開啟用戶遠程訪問
默認情況下，RabbitMQ的默認的guest用戶只允許本機訪問， 如果想讓guest用戶能夠遠程訪問的話，只需要將配置文件中的loopback_users列表置為空即可，如下：
{loopback_users, []}另外關於新添加的用戶，直接就可以從遠程訪問的，如果想讓新添加的用戶只能本地訪問，可以將用戶名添加到上面的列表, 如只允許admin用戶本機訪問。
{loopback_users, ["admin"]}更新配置，需要重啟
[root@localhost access]# systemctl status rabbitmq-server
● rabbitmq-server.service - RabbitMQ broker
Loaded: loaded (/usr/lib/systemd/system/rabbitmq-server.service; enabled; vendor preset: disabled)
Active: active (running) since Wed 2018-10-31 21:50:01 CST; 13h ago
Main PID: 30926 (beam.smp)
Status: "Initialized"
CGroup: /system.slice/rabbitmq-server.service
├─30926 /usr/lib64/erlang/erts-9.3.3.4/bin/beam.smp -W w -A 128 -P 1048576 -t 5000000 -stbt db -zdbbl 1280000 -K true -- -root /usr/lib64/erlang -progname erl -- -home /var/...
├─31097 /usr/lib64/erlang/erts-9.3.3.4/bin/epmd -daemon
├─31322 erl_child_setup 1024
├─31358 inet_gethost 4
└─31359 inet_gethost 4
Oct 31 21:50:00 localhost.localdomain rabbitmq-server[30926]: ## ##
Oct 31 21:50:00 localhost.localdomain rabbitmq-server[30926]: ## ## RabbitMQ 3.7.4. Copyright (C) 2007-2018 Pivotal Software, Inc.
Oct 31 21:50:00 localhost.localdomain rabbitmq-server[30926]: ########## Licensed under the MPL. See http://www.rabbitmq.com/
Oct 31 21:50:00 localhost.localdomain rabbitmq-server[30926]: ###### ##
Oct 31 21:50:00 localhost.localdomain rabbitmq-server[30926]: ########## Logs: /data/weblogs/rabbitmq/[email protected]
Oct 31 21:50:00 localhost.localdomain rabbitmq-server[30926]: /data/weblogs/rabbitmq/rabbit@localhost_upgrade.log
Oct 31 21:50:00 localhost.localdomain rabbitmq-server[30926]: Starting broker...
Oct 31 21:50:01 localhost.localdomain rabbitmq-server[30926]: systemd unit for activation check: "rabbitmq-server.service"
Oct 31 21:50:01 localhost.localdomain systemd[1]: Started RabbitMQ broker.
Oct 31 21:50:01 localhost.localdomain rabbitmq-server[30926]: completed with 0 plugins.
這裏可以看到log文件的位置，轉到文件位置，打開文件：防火墻配置：
/sbin/iptables -I INPUT -p tcp --dport 5672 -j ACCEPT
/sbin/iptables -I INPUT -p tcp --dport 15672 -j ACCEPTRabbitMQ安裝與配置