https://wiki.linuxsa.org/index.php?action=history&feed=atom&title=Rabbitmq_cluster_on_centos7
Rabbitmq cluster on centos7 - 版本历史
2026-04-17T15:51:26Z
本wiki上该页面的版本历史
MediaWiki 1.43.1
https://wiki.linuxsa.org/index.php?title=Rabbitmq_cluster_on_centos7&diff=915&oldid=prev
Evan：/* docker */
2019-10-22T09:00:12Z
<p><span class="autocomment">docker</span></p>
<p><b>新页面</b></p><div>=Note=<br />
Note: 另外一个docker <br />
<br />
[[Rabbitmq cluster on docker-compose]]<br />
<br />
=前提是rabbitmq安装=<br />
[[Centos7安装Rabbitmq]]<br />
<br />
=介绍=<br />
运行模式大概有3种：<br />
<br />
单一模式：非集群模式，单台。<br />
<br />
普通模式：RabbitMQ默认的集群模式。<br />
<br />
对于Queue来说，消息实体只存在于其中一个节点，A、B两个节点仅有相同的元数据，即队列结构。当消息进入A节点的Queue中后，consumer从B节点拉取时，RabbitMQ会临时在A、B间进行消息传输，把A中的消息实体取出并经过B发送给consumer。<br />
<br />
所以consumer应尽量连接每一个节点，从中取消息。即对于同一个逻辑队列，要在多个节点建立物理Queue。否则无论consumer连A或B，出口总在A，会产生瓶颈。<br />
<br />
该模式存在一个问题就是当A节点故障后，B节点无法取到A节点中还未消费的消息实体。<br />
<br />
如果做了消息持久化，那么得等A节点恢复，然后才可被消费；如果没有持久化会丢失消息。<br />
<br />
镜像模式：Queue同时存在多个节点，可通过改模式实现HA高可用<br />
该模式解决了上述问题，其实质和普通模式不同之处在于，消息实体会主动在镜像节点间同步，而不是在consumer取数据时临时拉取。<br />
<br />
该模式带来的副作用也很明显，除了降低系统性能外，如果镜像队列数量过多，加之大量的消息进入，集群内部的网络带宽将会被这种同步通讯大大消耗掉。<br />
<br />
<br />
rabbitmq-server-3.7.7-1.el7<br />
<br />
=配置hosts文件=<br />
<pre><br />
echo '192.168.0.202 mq01<br />
192.168.0.202 mq02' >>/etc/hosts<br />
<br />
hostnamectl --static set-hostname mq01<br />
hostnamectl --static set-hostname mq02<br />
<br />
#注意 这个格式是不对的 不能并列 只能有一个 <br />
#192.168.0.201 master zoo1<br />
192.168.0.202 mq01<br />
192.168.0.203 mq02<br />
</pre><br />
<br />
三台主机上安装的 RabbitMQ 都保证都可以正常启动,才可以进行以下操作<br />
<br />
停止RabbitMQ 服务<br />
systemctl stop rabbitmq-server <br />
<br />
<br />
=拷贝erlang.cookie =<br />
<pre><br />
#要先启动 不然没有cookie 文件 <br />
systemctl start rabbitmq-server<br />
<br />
[root@node1 ~]cat /var/lib/rabbitmq/.erlang.cookie <br />
RDZZRBEWSOOIYHOABHTI<br />
将cookie中的内容复制到mq02的cookie文件中。<br />
<br />
<br />
这里将 node1 的该文件复制到 node2、node3，由于这个文件权限是 400为方便传输，先修改权限，非必须操作，所以需要先修改 node2、node3 中的该文件权限为 777<br />
#这操作太low <br />
scp /var/lib/rabbitmq/.erlang.cookie node2:/var/lib/rabbitmq/<br />
<br />
chmod 400 /var/lib/rabbitmq/.erlang.cookie<br />
chown -R rabbitmq:rabbitmq /var/lib/rabbitmq/.erlang.cookie<br />
<br />
注意事项<br />
cookie在所有节点上必须完全一样，同步时一定要注意。<br />
erlang是通过主机名来连接服务，必须保证各个主机名之间可以ping通。可以通过编辑/etc/hosts来手工添加主机名和IP对应关系。如果主机名ping不通，rabbitmq服务启动会失败<br />
</pre><br />
<br />
<br />
==启动rabbitmq服务==<br />
systemctl restart rabbitmq-server # on all node <br />
<br />
在node2 mq02上停止rabbitmq应用程序，并重置（重置只是清除节点的配置，如果没有配置过，则可以省略），然后加入node1集群<br />
<br />
[root@mq02 rabbitmq]# rabbitmqctl stop_app<br />
Stopping node rabbit@mq02 ...<br />
<br />
reset节点<br />
[root@mq02 rabbitmq]# rabbitmqctl reset<br />
Resetting node rabbit@mq02 ...<br />
<br />
<br />
==加入集群 ==<br />
<pre><br />
[root@mq02 ~]# rabbitmqctl join_cluster rabbit@mq01 <br />
Clustering node rabbit@mq02 with rabbit@mq01 ...<br />
<br />
启动rabbitmq应用<br />
[root@mq02 ~]# rabbitmqctl start_app<br />
Starting node rabbit@mq02 ...</pre><br />
<br />
<br />
==查看集群状态==<br />
<pre><br />
node2上查看集群状态<br />
rabbitmqctl cluster_status<br />
<br />
[root@mq02 ~]# rabbitmqctl cluster_status<br />
Cluster status of node rabbit@mq02 ...<br />
[{nodes,[{disc,[rabbit@mq01,rabbit@mq02]}]},<br />
{running_nodes,[rabbit@mq01,rabbit@mq02]},<br />
{cluster_name,<<"rabbit@mq01">>},<br />
{partitions,[]},<br />
{alarms,[{rabbit@mq01,[]},{rabbit@mq02,[]}]}]<br />
<br />
<br />
node1上查看集群状态<br />
[root@mq01 ~]# rabbitmqctl cluster_status<br />
Cluster status of node rabbit@mq01 ...<br />
[{nodes,[{disc,[rabbit@mq01,rabbit@mq02]}]},<br />
{running_nodes,[rabbit@mq02,rabbit@mq01]},<br />
{cluster_name,<<"rabbit@mq01">>},<br />
{partitions,[]},<br />
{alarms,[{rabbit@mq02,[]},{rabbit@mq01,[]}]}]</pre><br />
<br />
==更改节点类型==<br />
<br />
节点有两种类型：磁盘节点和内存节点，集群中必须至少有一个磁盘节点，否则队列元数据无法写入到集群中，当磁盘节点宕掉时，集群将无法写入新的队列元数据信息。<br />
<br />
<br />
从上面集群状态可以看出，mq01和mq02 均为磁盘节点，可以通过命令<br />
<br />
还有很多好的 如下 URL <br />
<br />
http://blog.51cto.com/zengestudy/1885054<br />
<br />
运行各节点<br />
rabbitmqctl stop<br />
rabbitmq-server -detached <br />
<br />
=other=<br />
<pre><br />
组成集群<br />
[root@mq01 ~] rabbitmqctl stop_app<br />
<br />
[root@mq02 ~]# rabbitmqctl stop_app # 停止rabbitmq服务<br />
n[root@mq02 ~]# rabbitmqctl join_cluster rabbit@mq01 # node2和node1构成集群, node2必须能通过node1的主机名ping通<br />
[root@mq02 ~]# rabbitmqctl start_app # 开启rabbitmq服务<br />
<br />
<br />
<br />
<br />
查看日志<br />
less /var/log/rabbitmq/rabbit@localhost.log <br />
<br />
在node2 mq02上停止rabbitmq应用程序，并重置（重置只是清除节点的配置，如果没有配置过，则可以省略），然后加入node1集群<br />
[root@mq02 rabbitmq]# rabbitmqctl stop_app #<br />
Stopping node rabbit@mq02 ...<br />
<br />
reset节点<br />
<br />
[root@mq02 rabbitmq]# rabbitmqctl reset<br />
Resetting node rabbit@mq02 ... <br />
<br />
</pre><br />
<br />
=trouble shooting=<br />
<br />
rabbitmqctl reset<br />
<br />
23:49:15.657 [error] Error when reading /var/lib/rabbitmq/.erlang.cookie: eacces<br />
<br />
<br />
<br />
=see also=<br />
[http://blog.51cto.com/zengestudy/1885054 good-RabbitMQ集群创建]<br />
<br />
[https://segmentfault.com/a/1190000010702020 CentOs7.3 搭建 RabbitMQ 3.6 Cluster 集群服务与使用]<br />
<br />
[http://blog.51cto.com/wangwq/1951185 RabbitMQ集群搭建]<br />
<br />
[https://segmentfault.com/a/1190000010300803 RabbitMQ 源码 集群安装]<br />
<br />
[https://blog.linuxeye.cn/451.html RabbitMQ集群和高可用配置]<br />
<br />
[https://blog.linuxeye.cn/436.html RabbitMQ启动脚本]<br />
<br />
[https://www.jianshu.com/p/79ca08116d57 消息队列之 RabbitMQ]<br />
<br />
[https://www.cnblogs.com/knowledgesea/p/6535766.html Rabbitmq集群高可用部署详细good]<br />
<br />
[https://www.jianshu.com/p/db0f5496f0d2 RabbitMQ HA集群搭建]<br />
<br />
[https://www.ibm.com/developerworks/cn/opensource/os-cn-RabbitMQ/index.html 高可用 RabbitMQ 集群自动化部署解决方案]<br />
<br />
[http://www.ywnds.com/?p=4741 RabbitMQ两种集群模式配置管理（五）]<br />
<br />
[https://my.oschina.net/louxin/blog/483402 Rabbitmq集群搭建笔记]<br />
<br />
[https://blog.csdn.net/qq_34021712/article/details/72633520 rabbitmq集群搭建(多机)]<br />
<br />
<br />
<br />
<br />
[https://blog.csdn.net/winy_lm/article/details/81128181 Rabbitmq镜像集群部署]<br />
<br />
==docker 不要的了==<br />
<br />
[https://www.cnblogs.com/xmai/p/7493062.html RabbitMQ:Docker环境下搭建rabbitmq集群]<br />
<br />
<br />
[https://segmentfault.com/a/1190000004394741 docker搭建rabbitmq集群 has elk reis zk elk etc]<br />
<br />
[http://www.ywnds.com/?p=7674 Docker：搭建RabbitMQ集群]<br />
<br />
[[category:ops]]</div>
Evan