RabbitMQ集群搭建

本帖內(nèi)容轉(zhuǎn)自博客:http://88250.b3log.org/rabbitmq-clustering-ha。部分內(nèi)容有調(diào)整。

集群概述

通過 Erlang 的分布式特性(通過 magic cookie 認(rèn)證節(jié)點)進(jìn)行 RabbitMQ 集群,各 RabbitMQ 服務(wù)為對等節(jié)點,即每個節(jié)點都提供服務(wù)給客戶端連接,進(jìn)行消息發(fā)送與接收。

這些節(jié)點通過 RabbitMQ HA 隊列(鏡像隊列)進(jìn)行消息隊列結(jié)構(gòu)復(fù)制。本方案中搭建 3 個節(jié)點,并且都是磁盤節(jié)點(所有節(jié)點狀態(tài)保持一致,節(jié)點完全對等),只要有任何一個節(jié)點能夠工作,RabbitMQ 集群對外就能提供服務(wù)。

系統(tǒng)版本:CentOS 6.5
RabbitMQ-Server:3.5.1
HAProxy:1.4.22

RabbitMQ 集群安裝在 3 個節(jié)點上:192.168.1.1、192.168.1.2、192.168.1.3;
HAProxy 安裝在 192.168.1.1 上,用于對外提供 RabbitMQ 均衡。

所需安裝包 下載。
配置步驟

  • 在所有節(jié)點上安裝rabbitmq 方法詳見本帖
    在 192.168.1.1、192.168.1.2、192.168.1.3 三個節(jié)點上安裝,然后開啟 RabbitMQ 監(jiān)控插件:
rabbitmq-plugins enable rabbitmq_management
  • 修改 /etc/hosts
    加入集群 3 個節(jié)點的描述:
    192.168.1.1 node1
    192.168.1.2 node2
    192.168.1.3 node3

  • 設(shè)置 Erlang Cookie
    Erlang Cookie 文件:/var/lib/rabbitmq/.erlang.cookie。這里將 node1 的該文件復(fù)制到 node2、node3,由于這個文件權(quán)限是 400,所以需要先修改 node2、node3 中的該文件權(quán)限為 777:

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

然后將 node1 中的該文件拷貝到 node2、node3,最后將權(quán)限和所屬用戶/組修改回來:

chmod 400 /var/lib/rabbitmq/.erlang.cookie
chown rabbitmq /var/lib/rabbitmq/.erlang.cookie
chgrp rabbitmq /var/lib/rabbitmq/.erlang.cookie
  • 使用 -detached 參數(shù)運行各節(jié)點
rabbitmqctl stop
rabbitmq-server -detached
  • 組成集群
    將 node2、node3 與 node1 組成集群:
node2 # rabbitmqctl stop_app 
node2 # rabbitmqctl join_cluster rabbit@node1
node2 # rabbitmqctl start_app
  
node3 # rabbitmqctl stop_app 
node3 # rabbitmqctl join_cluster rabbit@node1
node3 # rabbitmqctl start_app

此時 node2 與 node3 也會自動建立連接;如果要使用內(nèi)存節(jié)點,則可以使用

node2 # rabbitmqctl join_cluster --ram rabbit@node1 

加入集群。

集群配置好后,可以在 RabbitMQ 任意節(jié)點上執(zhí)行 rabbitmqctl cluster_status 來查看是否集群配置成功。

  • 設(shè)置鏡像隊列策略
    在任意一個節(jié)點上執(zhí)行:
rabbitmqctl set_policy ha-all "^" '{"ha-mode":"all"}'

將所有隊列設(shè)置為鏡像隊列,即隊列會被復(fù)制到各個節(jié)點,各個節(jié)點狀態(tài)保持一直。

完成這 6 個步驟后,RabbitMQ 高可用集群就已經(jīng)搭建好了,最后一個步驟就是搭建均衡器。

  • 安裝并配置 HAProxy
    在 192.168.1.1 上安裝 HAProxy,然后修改
    /etc/haproxy/haproxy.cfg:
listen rabbitmq_cluster 0.0.0.0:5672
 
mode tcp
balance roundrobin
 
server   node1 192.168.1.1:5672 check inter 2000 rise 2 fall 3  
server   node2 192.168.1.2:5672 check inter 2000 rise 2 fall 3
server   node2 192.168.1.3:5672 check inter 2000 rise 2 fall 3
最后編輯于
?著作權(quán)歸作者所有,轉(zhuǎn)載或內(nèi)容合作請聯(lián)系作者
【社區(qū)內(nèi)容提示】社區(qū)部分內(nèi)容疑似由AI輔助生成,瀏覽時請結(jié)合常識與多方信息審慎甄別。
平臺聲明:文章內(nèi)容(如有圖片或視頻亦包括在內(nèi))由作者上傳并發(fā)布,文章內(nèi)容僅代表作者本人觀點,簡書系信息發(fā)布平臺,僅提供信息存儲服務(wù)。

相關(guān)閱讀更多精彩內(nèi)容

友情鏈接更多精彩內(nèi)容