RabbitMQ集群

转载:https://www.cnblogs.com/knowledgesea/p/6535766.html

一、Rabbitmq集群模式

  • 单一模式:即单机情况不做集群,就单独运行一个rabbitmq而已。

  • 普通模式:默认模式,以两个节点(rabbit01、rabbit02)为例来进行说明。对于Queue来说,消息实体只存在于其中一个节点rabbit01(或者rabbit02),rabbit01和rabbit02两个节点仅有相同的元数据,即队列的结构。当消息进入rabbit01节点的Queue后,consumer从rabbit02节点消费时,RabbitMQ会临时在rabbit01、rabbit02间进行消息传输,把A中的消息实体取出并经过B发送给consumer。所以consumer应尽量连接每一个节点,从中取消息。即对于同一个逻辑队列,要在多个节点建立物理Queue。否则无论consumer连rabbit01或rabbit02,出口总在rabbit01,会产生瓶颈。当rabbit01节点故障后,rabbit02节点无法取到rabbit01节点中还未消费的消息实体。如果做了消息持久化,那么得等rabbit01节点恢复,然后才可被消费;如果没有持久化的话,就会产生消息丢失的现象。

  • 镜像模式:把需要的队列做成镜像队列,存在与多个节点属于RabbitMQ的HA方案该模式解决了普通模式中的问题,其实质和普通模式不同之处在于,消息实体会主动在镜像节点间同步,而不是在客户端取数据时临时拉取。该模式带来的副作用也很明显,除了降低系统性能外,如果镜像队列数量过多,加之大量的消息进入,集群内部的网络带宽将会被这种同步通讯大大消耗掉。所以在对可靠性要求较高的场合中适用。

二、搭建Rabbitmq集群

1、集群环境

  • 两台Centos7的机器,hostname分别为:F , G .

  • IP地址分别为:F—172.18.8.229 , G—172.18.8.224。

  • 修改hosts文件如下,下面是G这台机器的hosts文件内容,F也需要如下配置:

[root@G bin]# cat /etc/hosts
127.0.0.1 G  localhost localhost.localdomain localhost4 localhost4.localdomain4 
::1       G  localhost localhost.localdomain localhost6 localhost6.localdomain6 

172.18.8.224 G
172.18.8.229 F
  • 保证两台机器都能够相互ping通,如下图:

2、安装RabbitMQ服务

官方文档如下:http://www.rabbitmq.com/install-rpm.html。rabbitmq依赖erlang环境,

  • 先安装erlang环境。

  • 下载rabbitmq的rpm包ivh即可。

安装启动过程中如果出现error,那可参考下面几个方案试试:

  • vim /etc/rabbitmq/enable_plugins :删除文件中的内容。

  • 查看hosts文件是否配置完善,相互是否可以ping通

  • 查看相关端口是否被占用,如若占用kill掉

  • 如果已经集群,那么要查看所有集群中的/var/lib/rabbitmq/.erlang.cookie是否一致。

  • 如果不存在上述文件,echo $HOME ,打开此文件夹,查看cookie文件是否一致。

  • 重启电脑,防止缓存数据配置未更新过来。

这里安装启动成功之后,来几个常用的操作。

复制代码
[root@G bin]# ./rabbitmq-server -deched  --后台启动服务
[root@G bin]# ./rabbitmqctl start_app  --启动服务
[root@G bin]# ./rabbitmqctl stop_app  --关闭服务
[root@G bin]# ./rabbitmq-plugins enable rabbitmq_management --启动web管理插件
[root@G bin]# ./rabbitmqctl add_user zlh zlh  --添加用户,密码
[root@G bin]# ./rabbitmqctl set_user_tags zlh administrator --设置zlh为administrator权限
复制代码

如果你看到如下操作,即表明启动成功啦,并且web管理页面的插件也启动成功,如果下面的6为0,则需要启动web管理插件

那具体rabbitmqctl 的命令详细还要看官网文档:http://www.rabbitmq.com/man/rabbitmqctl.1.man.html

三、搭建Rabbitmq的一般模式集群

 在上述的两台机器上安装rabbitmq完成之后,你可以看到你的机器中有如下1个文件。路径在$HOME中或者在/var/lib/rabbitmq中,文件名称为.erlang.cookie,他是一个隐藏文件。那么这文件存储的内容是什么,是做什么用的呢?

这样说吧:RabbitMQ的集群是依赖erlang集群,而erlang集群是通过这个cookie进行通信认证的,因此我们做集群的第一步就是配置cookie。

1、Cookie配置

必须使集群中也就是F,G这两台机器的.erlang.cookie文件中cookie值一致,且权限为owner只读。

机器G中的Cookie:

 

机器F中的Cookie:

修改文件权限如下:

[root@F ~]# chmod 600 .erlang.cookie

2、查看集群状态

复制代码
[root@F bin]# ./rabbitmqctl cluster_status
Cluster status of node rabbit@F ...
[{nodes,[{disc,[rabbit@G]},{ram,[rabbit@F]}]},
 {running_nodes,[rabbit@G,rabbit@F]},
 {cluster_name,<<"rabbit@F">>},
 {partitions,[]},
 {alarms,[{rabbit@G,[]},{rabbit@F,[]}]}]
复制代码

3、停止当前机器中rabbitmq的服务

[root@F bin]# ./rabbitmqctl stop_app

4、把G中的rabbitmq加入到集群中来

[root@F bin]# ./rabbitmqctl join_cluster --ram rabbit@G

5、开启当前机器的rabbitmq服务

[root@F bin]# ./rabbitmqctl start_app

6、打开网页管理页面查看nodes

如此便可以啦,你可以做下测试,验证下我们序言中说的普通模式的说明,那必须是杠杠对的。

四、搭建Rabbitmq的镜像高可用模式集群

这一节要参考的文档是:http://www.rabbitmq.com/ha.html,首先镜像模式要依赖policy模块,这个模块是做什么用的呢?policy中文来说是政策,策略的意思,那么他就是要设置,那些Exchanges或者queue的数据需要复制,同步,如何复制同步?对就是做这些的。这里有点内容的,我先上例子慢慢说:

[root@G ~]# ./rabbitmqctl set_policy ha-all "^" '{"ha-mode":"all"}'

参数意思为:

  • ha-all:为策略名称。

  • ^:为匹配符,只有一个^代表匹配所有,^zlh为匹配名称为zlh的exchanges或者queue。

  • ha-mode:为匹配类型,他分为3种模式:all-所有(所有的queue),exctly-部分(需配置ha-params参数,此参数为int类型比如3,众多集群中的随机3台机器),nodes-指定(需配置ha-params参数,此参数为数组类型比如["3rabbit@F","rabbit@G"]这样指定为F与G这2台机器。)。

参考示例如下

当然在web管理界面也能配置:

配置完看队列如下,其中表示ha-haall的说明用我的ha-haall策略啦,属于镜像模式,没有表示的就是普通模式:

 

原文地址:https://www.cnblogs.com/qtiger/p/15763526.html