通過 Erlang 的分布式特性(magic cookie 認證節點)進行 RabbitMQ 集群,各 RabbitMQ 服務為對等節點,即每個節點都提供服務給客戶端連接,進行消息發送與接收。
這些節點通過 RabbitMQ HA 隊列(鏡像隊列)進行消息隊列結構復制。本文中搭建 3 個節點,并且都是磁盤節點(所有節點狀態保持一致,節點完全對等),只要有任何一個節點能夠工作,RabbitMQ 集群對外就能提供服務。
[root@node1 ~]# vi /etc/hosts
192.168.1.1 node1
192.168.1.2 node2
192.168.1.3 node3
在 192.168.1.1、192.168.1.2、192.168.1.3 三個節點上安裝,然后開啟 RabbitMQ 監控插件。
[root@node1 ~]# wget http://www.rabbitmq.com/releases/erlang/erlang-18.1-1.el7.centos.x86_64.rpm
[root@node1 ~]# wget http://www.rabbitmq.com/releases/rabbitmq-server/v3.6.3/rabbitmq-server-3.6.3-1.noarch.rpm
[root@node1 ~]# rpm -ivh erlang-18.1-1.el7.centos.x86_64.rpm
[root@node1 ~]# rpm -ivh rabbitmq-server-3.6.3-1.noarch.rpm
[root@node1 ~]# rabbitmq-plugins enable rabbitmq_management
Erlang Cookie 文件:/var/lib/rabbitmq/.erlang.cookie。這里將 node1 的該文件復制到 node2、node3,由于這個文件權限是 400,所以需要先修改 node2、node3 中的該文件權限為 777,然后將 node1 中的該文件拷貝到 node2、node3,最后將權限和所屬用戶/組修改回來。
[root@node1 ~]# chmod 777 /var/lib/rabbitmq/.erlang.cookie
[root@node1 ~]# scp -r /var/lib/rabbitmq/.erlang.cookie root@node2:/var/lib/rabbitmq/.erlang.cookie
[root@node1 ~]# scp -r /var/lib/rabbitmq/.erlang.cookie root@node3:/var/lib/rabbitmq/.erlang.cookie
[root@node1 ~]# chmod 400 /var/lib/rabbitmq/.erlang.cookie
[root@node1 ~]# chown rabbitmq /var/lib/rabbitmq/.erlang.cookie
[root@node1 ~]# chgrp rabbitmq /var/lib/rabbitmq/.erlang.cookie
[root@node1 ~]# rabbitmqctl stop
[root@node1 ~]# rabbitmq-server -detached
將 node2、node3 與 node1 組成集群
[root@node2 ~]# rabbitmqctl stop_app
[root@node2 ~]# rabbitmqctl join_cluster rabbit@node1
[root@node2 ~]# rabbitmqctl start_app
#---------------------------------------------------------------------------------#
[root@node3 ~]# rabbitmqctl stop_app
[root@node3 ~]# rabbitmqctl join_cluster rabbit@node1
[root@node3 ~]# rabbitmqctl start_app
此時 node2 與 node3 也會自動建立連接;如果要使用內存節點,則可以使用下面的命令加入集群。[root@node2 ~]# rabbitmqctl join_cluster *--ram* rabbit@node1
集群配置好后,可以在 RabbitMQ 任意節點上執行下面的命令來查看是否集群配置成功。
rabbitmqctl cluster_status
在任意一個節點上執行下面的命令[root@node1 ~]# rabbitmqctl set_policy ha-all "^" '{"ha-mode":"all"}'
將所有隊列設置為鏡像隊列,即隊列會被復制到各個節點,各個節點狀態保持一直。完成這 6 個步驟后,RabbitMQ 高可用集群就已經搭建好了,最后一個步驟就是搭建均衡器。
提示:
RabbitMQ的配置文件為:/etc/rabbitmq/rabbitmq.config
RabbitMQ的環境配置文件為:/etc/rabbitmq/rabbitmq-env.conf
在 192.168.1.4 上安裝 HAProxy,然后修改 /etc/haproxy/haproxy.cfg。
[root@snails ~]# haproxy -vv
[root@snails ~]# vi /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
listen private_monitoring :8100
mode http
option httplog
stats enable
#設置haproxy監控地址為http://localhost:8100/rabbitmq-stats
stats uri /rabbitmq-stats
stats refresh 5s
[root@snails ~]# /usr/sbin/haproxy -D -f /etc/haproxy/haproxy.cfg -p /var/run/haproxy.pid
免責聲明:本站發布的內容(圖片、視頻和文字)以原創、轉載和分享為主,文章觀點不代表本網站立場,如果涉及侵權請聯系站長郵箱:is@yisu.com進行舉報,并提供相關證據,一經查實,將立刻刪除涉嫌侵權內容。