大家好,又见面了,我是你们的朋友全栈君。
一 普通集群
以如下两台服务器为例
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
代码语言:javascript复制如果启动不成功,因为修改了hosts文件,可以重启试试 节点服务执行:
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]
版权声明:本文内容由互联网用户自发贡献,该文观点仅代表作者本人。本站仅提供信息存储空间服务,不拥有所有权,不承担相关法律责任。如发现本站有涉嫌侵权/违法违规的内容, 请发送邮件至 举报,一经查实,本站将立刻删除。