RabbitMQ集群部署和高可用

Posted 2022-10-31 hhhshct

RabbitMQ 安装和使用

1、安装依赖环境

在 http://www.rabbitmq.com/which-erlang.html 页面查看安装rabbitmq需要安装erlang对应的版本

在 https://github.com/rabbitmq/erlang-rpm/releases 页面找到需要下载的erlang版本，`erlang-*.centos.x86_64.rpm`就是centos版本的。

复制下载地址后，使用wget命令下载，wget -P /home/download https://github.com/rabbitmq/erlang-rpm/releases/download/v21.2.3/erlang-21.2.3-1.el7.centos.x86_64.rpm

安装 Erlang sudo rpm -Uvh /home/download/erlang-21.2.3-1.el7.centos.x86_64.rpm

安装时如果提示‘libcrypto.so.10(OPENSSL_1.0.2)(64bit) is needed’则需要下载 openssl-libs-1.0.2k-16.el7.x86_64.rpm,地址http://rpmfind.net/linux/centos/7.6.1810/os/x86_64/Packages/openssl-libs-1.0.2k-16.el7.x86_64.rpm,然后升级一下 rpm -ivh openssl-libs-1.0.2k-16.el7.x86_64.rpm --force

安装 socat  sudo yum install -y socat

2、安装RabbitMQ

在官方下载页面http://www.rabbitmq.com/download.html)找到CentOS7版本的下载链接，下载rpm安装包

wget -P /home/download https://github.com/rabbitmq/rabbitmq-server/releases/download/v3.7.9/rabbitmq-server-3.7.9-1.el7.noarch.rpm

可以在https://github.com/rabbitmq/rabbitmq-server/tags下载历史版本

添加环境配置 vi /etc/rabbitmq/rabbitmq-env.conf ，没有目录时先创建对应的目录， 添加 NODENAME=rabbit@localhost

安装 sudo rpm -Uvh /home/download/rabbitmq-server-3.7.9-1.el7.noarch.rpm

3、基本操作

启动服务  sudo systemctl start rabbitmq-server

查看状态 sudo systemctl status rabbitmq-server

停止服务 sudo systemctl stop rabbitmq-server

设置开机启动 sudo systemctl enable rabbitmq-server

开启Web管理插件 rabbitmq-plugins enable rabbitmq_management，rabbitmq有一个默认的guest用户，但只能通过localhost访问，所以需要添加一个能够远程访问的用户

添加用户 rabbitmqctl add_user admin admin

为用户分配操作权限 rabbitmqctl set_user_tags admin administrator

 为用户分配资源权限 rabbitmqctl set_permissions -p / admin ".*" ".*" ".*"

4、防火墙添加端口

sudo firewall-cmd --zone=public --add-port=4369/tcp --permanent
sudo firewall-cmd --zone=public --add-port=5672/tcp --permanent
sudo firewall-cmd --zone=public --add-port=25672/tcp --permanent
sudo firewall-cmd --zone=public --add-port=15672/tcp --permanent

重启防火墙 sudo firewall-cmd --reload

多机多节点集群部署

1、准备三台安装好RabbitMQ 的机器，ip分别为192.168.5.125、192.168.5.135、192.168.5.145

2、修改hosts文件，sudo vim /etc/hosts，三台机器分别都添加如下配置，可以通过sudo scp /etc/hosts root@192.168.5.135:/etc/复制到node2

192.168.5.125 node1

192.168.5.135 node2

192.168.5.145 node3

3、修改对应主机的hostname hostnamectl set-hostname 名字(重启后仍有效)

4、将192.168.5.125上的/var/lib/rabbitmq/.erlang.cookie文件复制到另外两台机器上

5、给每台机器的防火墙添加端口

6、 启动每台机器的RabbitMQ，sudo systemctl start rabbitmq-server或者 rabbitmq-server -detached

7、 将192.168.5.135加入到集群，停止RabbitMQ 应用 rabbitmqctl stop_app， 重置RabbitMQ 设置  rabbitmqctl reset 加入到集群  rabbitmqctl join_cluster rabbit@node1 --ram

启动RabbitMQ 应用 rabbitmqctl start_app

8、查看集群状态，看到`running_nodes,[rabbit@node1,rabbit@node2]`表示节点启动成功  rabbitmqctl cluster_status

9、在管理端界面界面查看

镜像队列模式集群

 镜像队列属于RabbitMQ 的高可用方案，见：https://www.rabbitmq.com/ha.html#mirroring-arguments

通过前面的步骤搭建的集群属于普通模式集群，是通过共享元数据实现集群

开启镜像队列模式需要在管理页面添加策略，添加方式：

1. 进入管理页面 选择默认虚拟主机"/" -> Admin -> Policies（在页面右侧）-> Add / update a policy

2. 在表单中填入：

name：ha-all  策略名称，如果使用已有的名称，保存后将会修改原来的信息

Apply to：Queues 策略应用到什么对象上

Pattern：^ 策略应用到对象时，对象名称的匹配规则（正则表达式）

Priority: 0 优先级，数值越大，优先级越高，相同优先级取最后一个

Definition：策略定义的类容，对于镜像队列的配置来说，只需要包含3个部分: `ha-mode` 、`ha-params` 和 `ha-sync-mode`。其中，`ha-sync-mode`是同步的方式，自动还是手动，默认是自动。`ha-mode` 和 `ha-params` 组合使用。组合方式如下：

　　|all | (empty) | 队列镜像到集群类所有节点 |

　　| exactly | count | 队列镜像到集群内指定数量的节点。如果集群内节点数少于此值，队列将会镜像到所有节点。如果大于此值，而且一个包含镜像的节点停止，则新的镜像不会在其它节点创建。 |

　　| nodes | nodename | 队列镜像到指定节点，指定的节点不在集群中不会报错。当队列申明时，如果指定的节点不在线，则队列会被创建在客户端所连接的节点上。 |

镜像队列模式相比较普通模式，镜像模式会占用更多的带宽来进行同步，所以镜像队列的吞吐量会低于普通模式，但普通模式不能实现高可用，某个节点挂了后，这个节点上的消息将无法被消费，需要等待节点启动后才能被消费。

除了镜像队列模式，还可以借助插件 shovel、federation来实现高可用，但是不常用，下面是两种方式的区别