rabbitmq集群搭建_rabbitmq创建队列

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

一普通集群

以如下两台服务器为例

ip: 172.16.9.8 hostname: rabbitmq1 (master)

ip: 172.16.9.9 hostname: rabbitmq2 (slave)

1. 修改host文件

编辑/etc/hosts文件，添加

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. 服务器配置

主服务执行：

rabbitmqctl stop_app
rabbitmqctl reset
rabbitmqctl start_app

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

rabbitmqctl stop_app
rabbitmqctl reset
rabbitmqctl join_cluster --ram rabbit@rabbitmq1  （--ram表示内存节点）
rabbitmqctl start_app

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

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

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

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

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

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

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使用方式如下：

 set_policy [-p vhostpath] {name} {pattern} {definition} [priority]

原文地址：https://cloud.tencent.com/developer/article/2151086

rabbitmq集群搭建_rabbitmq创建队列

相关推荐