docker-compose安装rabbitmq集群(主从集群---》镜像集群)
yls
2020/5/11
创建docker-compose.yml 文件
version: '3'
services:
rabbitmq1:
image: rabbitmq:3.8.3-management
container_name: rabbitmq1
restart: always
hostname: rabbitmq1
ports:
- 15683:15672
- 5683:5672
volumes:
- ./data1:/var/lib/rabbitmq
- ./rabbitmq.sh:/home/rabbitmq.sh
- ./etc/hosts:/etc/hosts
environment:
- RABBITMQ_DEFAULT_USER=root
- RABBITMQ_DEFAULT_PASS=root
- RABBITMQ_ERLANG_COOKIE=CURIOAPPLICATION
networks:
rabbit:
ipv4_address: 192.168.6.2
rabbitmq2:
image: rabbitmq:3.8.3-management
container_name: rabbitmq2
restart: always
hostname: rabbitmq2
ports:
- 15684:15672
- 5684:5672
volumes:
- ./data2:/var/lib/rabbitmq
- ./rabbitmq.sh:/home/rabbitmq.sh
- ./etc/hosts:/etc/hosts
environment:
- RABBITMQ_DEFAULT_USER=root
- RABBITMQ_DEFAULT_PASS=root
- RABBITMQ_ERLANG_COOKIE=CURIOAPPLICATION
networks:
rabbit:
ipv4_address: 192.168.6.3
rabbitmq3:
image: rabbitmq:3.8.3-management
container_name: rabbitmq3
restart: always
hostname: rabbitmq3
ports:
- 15692:15672
- 5692:5672
volumes:
- ./data3:/var/lib/rabbitmq
- ./rabbitmq.sh:/home/rabbitmq.sh
- ./etc/hosts:/etc/hosts
environment:
- RABBITMQ_DEFAULT_USER=root
- RABBITMQ_DEFAULT_PASS=root
- RABBITMQ_ERLANG_COOKIE=CURIOAPPLICATION
networks:
rabbit:
ipv4_address: 192.168.6.4
networks:
rabbit:
external:
name: rabbitmqnet
创建 rabbitmqnet 子网
docker network create --subnet 192.168.6.1/24 rabbitmqnet
创建 rabbitmq.sh 脚本
如果想用ram存储就用第一个shell文件,用硬盘存储就用第二个shell文件
rabbitmqctl stop_app
rabbitmqctl reset
rabbitmqctl join_cluster --ram rabbitmq@rabbitmq1
rabbitmqctl start_app
rabbitmqctl stop_app
rabbitmqctl reset
rabbitmqctl join_cluster rabbitmq@rabbitmq1
rabbitmqctl start_app
配置docker-compose.yml文件同步目录下的 ./etc/hosts 文件（集群节点间需能互相访问，故每个集群节点的hosts文件应包含集群内所有节点的信息以保证互相解析）
192.168.6.2 rabbitmq1
192.168.6.3 rabbitmq2
192.168.6.4 rabbitmq3
注意：一定不要加rabbit@ ，我之前配成 192.168.6.4 rabbit@rabbitmq1 ，白白浪费好多时间
若不配置或者配错hosts文件，会出现如下错误
sudo rabbitmqctl join_cluster --ram rabbit@rabbitmq11
Clustering node rrabbit@rabbitmq1 with rabbit@rabbitmq-node1...
Error: unable to connect to nodes rabbit@rabbitmq1]: nodedown
DIAGNOSTICS
===========
attempted to contact: [rabbit@rabbitmq1]
rabbit@rabbitmq-node1:
* unable to connect to epmd (port 4369) on rabbitmq1: nxdomain (non-existing domain)
current node details:
- node name: 'rabbitmqctl-526rabbitmq1'
- home dir: /var/lib/rabbitmq
- cookie hash: 50YO3zK+HJHos0tab1vHjg==
docker-compose up -d 运行容器
docker exec -it rabbitmq1 bash 分别进入从节点容器（本文中从节点是 rabbitmq3,rabbitmq2），启动脚本
chmod +777 /home/rabbitmq.sh
./home/rabbitmq.sh
主从集群已经搭建好，查看集群状态 rabbitmqctl cluster_status
主从集群的不足： 默认情况下，队列只位于主节点上，尽管他们可以从所有节点看到和访问，也就是说整个集群与主节点共存亡。
因此，当主节点宕机时，无法进行自动的故障转移，下面的队列镜像集群可以解决这个问题。
下面开始搭队列镜像集群
镜像集群就是在主从集群的基础上，添加相应策略，将主节点消息队列中的信息备份到其它节点上，主节点宕机时，对整个集群不产生影响，使集群可以高可用。
添加策略（可以在创建队列之前添加，也可以创建队列之后添加）
参考官方文档： https://www.rabbitmq.com/parameters.html#policies
策略模板（[]表示可选参数，<>表示必穿参数）
rabbitmqctl set_policy [-p <vhost>] [--priority <priority>] [--apply-to <apply-to>] <name> <pattern> <definition>
| 参数 | 说明 |
|---|---|
| -p vhost | 对指定的vhost进行设置 |
| name | policy的名称 |
| pattern | queue的匹配模式（正则表达式） |
| definition | 镜像定义：包含三个部分ha-mode,ha-params,ha-sync-mode |
| ha-mode:指明镜像队列的模式。all: 集群中所有节点进行镜像；exactly:在指定个数节点进行镜像，节点个数由ha-params指定;nodes:在指定节点进行镜像，节点名称由ha-params指定 | |
| ha-params: ha-mode模式需要用到的参数 | |
| ha-sync-mode: 消息的同步方式（automatic,manual） | |
| priority | policy的优先级，当有多个策略指定同一个队列时，优先级高的策略生效 |
添加策略实例
rabbitmqctl set_policy ha-11 '^11' '{"ha-mode":"all","ha-sync-mode":"automatic"}'
说明：策略正则表达式为 "^" 表示匹配所有队列名称， ^11 :表示匹配hello开头的队列
查看当前策略
rabbitmqctl list_policies
删除策略
rabbitmqctl clear_policy ha-11
以上策略的添加，删除，查看都可以在web UI 界面操作。