RabbitMQ 集群與高可用配置

集群概述

通過 Erlang 的分布式特性（通過 magic cookie 認證節點）進行 RabbitMQ 集群，各 RabbitMQ 服務為對等節點，即每個節點都提供服務給客戶端連接，進行消息發送與接收。

這些節點通過 RabbitMQ HA 隊列（鏡像隊列）進行消息隊列結構復制。本方案中搭建 3 個節點，並且都是磁盤節點（所有節點狀態保持一致，節點完全對等），只要有任何一個節點能夠工作，RabbitMQ 集群對外就能提供服務。

環境

· CentOS 6.8，64位

· Erlang otp_src_20.0

· RabbitMQ 3.6.10

· HAProxy

RabbitMQ 集群安裝在 2個節點上：192.168.185.88、192.168.185.89；

HAProxy 安裝在 192.168.185.72 上，用於對外提供 RabbitMQ 均衡。

所需安裝包下載。

配置步驟

1. 安裝 erlang、rabbitmq

在192.168.185.88、192.168.185.89兩個節點上安裝erlang和rabbitmq，安裝方法見文檔<<Centos 6.8安裝erlang&rabbitmq的方法>>

然後開啟 RabbitMQ 監控插件：

2. 修改 /etc/hosts

加入集群 3 個節點的描述：

3. 設置 Erlang Cookie

Erlang Cookie 文件：$HOME/.erlang.cookie。這裏將 RabbitMQ_185-88 的該文件復制到 RabbitMQ_185-89，由於這個文件權限是 400，所以需要先修改 node2、node3 中的該文件權限為 777：

然後將 node1 中的該文件拷貝到 node2、node3，最後將權限和所屬用戶/組修改回來：

4. 使用 -detached 參數運行各節點

5. 組成集群

將RabbitMQ_185-89 與 RabbitMQ_185-88 組成集群：

此時 RabbitMQ_185-89 與 RabbitMQ_185-88 也會自動建立連接；如果要使用內存節點，則可以使用

RabbitMQ_185-89 # rabbitmqctl join_cluster --ram [email protected] 加入集群。

集群配置好後，可以在 RabbitMQ 任意節點上執行

# rabbitmqctl cluster_status

來查看是否集群配置成功。

6. 設置鏡像隊列策略

在任意一個節點上執行：

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

完成這 6 個步驟後，RabbitMQ 高可用集群就已經搭建好了，最後一個步驟就是搭建均衡器。

7. 安裝並配置 HAProxy

在 192.168.185.72 上安裝 HAProxy，然後修改 /etc/haproxy/haproxy.cfg：

---- EOF ----

附件：haproxy.Conf

global

log 127.0.0.1 local0

maxconn 4096 #最大連接數

stats socket /tmp/haproxy.socket uid haproxy mode 770 level admin

daemon #後臺運行haproxy

nbproc 1 #啟動1個haproxy實例

pidfile /etc/haproxy/haproxy.pid #將所有進程PID寫入pid文件

defaults #默認設置

#log global

log 127.0.0.1 local3 #日誌文件的輸出定向

#默認的模式:tcp|http|health

mode tcp #所處理的類別,默認采用http模式

option tcplog #日誌類別,采用http日誌格式`

option dontlognull

retries 3 #3次連接失敗就認為服務器不可用，主要通過後面的check檢查

option redispatch #當serverid對應的服務器掛掉後，強制定向到其他健康服務器

option abortonclose #當服務器負載很高時，自動結束掉當前隊列中處理比較久的鏈接

maxconn 2000 #默認最大連接數

timeout connect 5000 #連接超時時間

timeout client 50000 #客戶端連接超時時間

timeout server 50000 #服務器端連接超時時間

# Haproxy統計頁面

listen haproxy_stats

bind 0.0.0.0:8100 #偵聽IP:Port

mode http

log 127.0.0.1 local0 info #err|warning|info|debug]

stats refresh 5s

stats uri /haproxy-stats

stats realm Haproxy\ Statistics

stats auth admin:admin

stats hide-version

stats admin if TRUE #手工啟用/禁用後端服務器

###############################rabbitmq代理配置##############

listen haproxy_rabbitmq_cluster #rabbitmq代理配置

mode http

bind 0.0.0.0:5672 #該端口為客戶端使用的端口

balance roundrobin

server RabbitMQ_185-88 192.168.185.88:5672 check inter 5000 rise 2 fall 3

server RabbitMQ_185-89 192.168.185.89:5672 check inter 5000 rise 2 fall 3

###############################rabbitmq web代理配置##############

listen haproxy_rabbitmq_cluster_web #rabbitmq web代理配置

mode http

bind 0.0.0.0:15672 #該端口為客戶端使用的端口

balance roundrobin

server RabbitMQ_185-88 192.168.185.88:15672 check inter 5000 rise 2 fall 3

server RabbitMQ_185-89 192.168.185.89:15672 check inter 5000 rise 2 fall 3

端口測試：

訪問頁面：

本文出自 “赤月之瞳的IT空間” 博客，請務必保留此出處http://niming2008.blog.51cto.com/2933179/1953333

RabbitMQ 集群與高可用配置