rabbitmq集群搭建_rabbitmq创建队列

2022-11-04 13:03:13 浏览数 (2)

大家好,又见面了,我是你们的朋友全栈君。

一 普通集群

以如下两台服务器为例

ip: 172.16.9.8 hostname: rabbitmq1 (master)

ip: 172.16.9.9 hostname: rabbitmq2 (slave)

1. 修改host文件

编辑/etc/hosts文件,添加

代码语言:javascript复制
172.16.9.8   rabbitmq1 
172.16.9.9   rabbitmq2
两台机器分别设置hostname
hostnamectl set-hostname rabbitmq1(对应的名字)

2. 复制cookie内容

打开文件然后需要先把172.16.9.8 服务器的 /var/lib/rabbitmq/.erlang.cookie中的内容复制到172.16.9.9上

cd /var/lib/rabbimq scp .erlang.cookie root@172.16.9.9:/var/lib/rabbitmq/.erlang.cookie 赋予权限 chmod 600 .erlang.cookie chown rabbitmq:rabbitmq /var/lib/rabbitmq/.erlang.cookie

3. 服务器配置

主服务执行:

代码语言:javascript复制
rabbitmqctl stop_app
rabbitmqctl reset
rabbitmqctl start_app

如果启动不成功,因为修改了hosts文件,可以重启试试 节点服务执行:

代码语言:javascript复制
rabbitmqctl stop_app
rabbitmqctl reset
rabbitmqctl join_cluster --ram rabbit@rabbitmq1  (--ram表示内存节点)
rabbitmqctl start_app

和主服务配置脚本的唯一区别是多了第三行的内容,其中–ram指的是作为内存节点,要是想做为磁盘节点的话,就不用加–ram这个参数了

4.只要在节点列表里包含了本身,它就成为一个磁盘节点。在RabbitMQ集群里,必须至少有一个磁盘节点存在。

现在先执行主节点上的脚本,等待执行完成之后再执行服务节点的脚本,顺序不要错了

执行完之后分别在每台机器上查看节点状态

代码语言:javascript复制
 rabbitmqctl cluster_status

往任意一台集群节点里写入消息队列,会复制到另一个节点上。

对于Queue来说,消息实体只存在于其中一个节点,A、B两个节点仅有相同的元数据,即队列结构。当消息进入A节点的Queue中后,consumer从B节点拉取时,RabbitMQ会临时在A、B间进行消息传输,把A中的消息实体取出并经过B发送给consumer。

所以consumer应尽量连接每一个节点,从中取消息。即对于同一个逻辑队列,要在多个节点建立物理Queue。否则无论consumer连A或B,出口总在A,会产生瓶颈。

该模式存在一个问题就是当A节点故障后,B节点无法取到A节点中还未消费的消息实体。如果做了消息持久化,那么得等A节点恢复,然后才可被消费;如果没有持久化的话,然后就没有然后了……

二 设置镜像队列策略

上面配置RabbitMQ默认集群模式,并不能保证队列的高可用性,尽管交换机、绑定这些可以复制到集群里的任何一个节点,但是队列内容不会复制,虽然该模式解决一部分节点压力,但队列节点宕机直接导致该队列无法使用,只能等待重启,所以要想在队列节点宕机或故障也能正常使用,就要复制队列内容到集群里的每个节点,需要创建镜像队列并使用负载均衡器。

在普通集群的中任意节点启用策略,策略会自动同步到集群节点

代码语言:javascript复制
rabbitmqctl set_policy -p vhost名称  ha-all "^" '{"ha-mode":"all"}'

这行命令在名称为“/”的vhost创建了一个策略,策略名称为ha-all,策略模式为 all 即复制到所有节点,包含新增节点,策略正则表达式为 “^” 表示所有匹配所有队列名称。

例如rabbitmqctl set_policy -p ewmsinfo ha-all “^message” ‘{“ha-mode”:”all”}’

注意:”^message” 这个规则要根据自己修改,这个是指同步”message”开头的队列名称,配置时使用的应用于所有队列,所以表达式为”^”

set_policy使用方式如下:

代码语言:javascript复制
 set_policy [-p vhostpath] {name} {pattern} {definition} [priority]

版权声明:本文内容由互联网用户自发贡献,该文观点仅代表作者本人。本站仅提供信息存储空间服务,不拥有所有权,不承担相关法律责任。如发现本站有涉嫌侵权/违法违规的内容, 请发送邮件至 举报,一经查实,本站将立刻删除。

0 人点赞