RabbitMQ是目前非常热门的一款消息中间件，不管是互联网大厂还是中小企业都在大量使用。作为一名合格的开发者，有必要对RabbitMQ有所了解。

运行模式大概有3种：

单一模式：非集群模式，单台。

普通模式：RabbitMQ默认的集群模式。

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

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

该模式存在一个问题就是当A节点故障后，B节点无法取到A节点中还未消费的消息实体。

如果做了消息持久化，那么得等A节点恢复，然后才可被消费；如果没有持久化会丢失消息。

镜像模式：Queue同时存在多个节点，可通过改模式实现HA高可用 该模式解决了上述问题，其实质和普通模式不同之处在于，消息实体会主动在镜像节点间同步，而不是在consumer取数据时临时拉取。

该模式带来的副作用也很明显，除了降低系统性能外，如果镜像队列数量过多，加之大量的消息进入，集群内部的网络带宽将会被这种同步通讯大大消耗掉。

下面来通过配置RabbitMQ镜像模式来熟悉这3种运行模式

RabbitMQ集群安装在3个节点上：10.0.0.1、10.0.0.2、10.0.0.3

HAProxy安装在10.0.0.4上，用于对外提供RabbitMQ均衡

3个节点在/etc/hosts文件中分别添加如下内容：

10.0.0.1rabbit110.0.0.2rabbit210.0.0.3rabbit32. 安装erlang、rabbitmq

cdoneinstack/srcwgethttp://erlang.org/download/otp_src_18.3.tar.gztarxzfotp_src_18.3.tar.gzcdotp_src_18.3./configure--prefix=/usr/local/erlang--enable-shared-zlib--with-ssl--enable-threads--enable-smp-support--enable-kernel-poll--enable-hipe--without-javacmake&&makeinstallcd..wgethttp://www.rabbitmq.com/releases/rabbitmq-server/v3.5.7/rabbitmq-server-generic-unix-3.5.7.tar.gztarxzfrabbitmq-server-generic-unix-3.5.4.tar.gzmvrabbitmq_server-3.5.4rabbitmqsed-i's@^ERL_DIR=.*@ERL_DIR=/usr/local/erlang/bin/@'/usr/local/rabbitmq/sbin/rabbitmq-defaultssed-i's@^LOG_BASE=.*@LOG_BASE=/usr/local/rabbitmq/var/log/rabbitmq@'/usr/local/rabbitmq/sbin/rabbitmq-defaults#日志目录mkdir-p/usr/local/rabbitmq/var/{lib,log}/rabbitmq3. 一般用户（rabbitmq）运行RabbitMQ

useraddrabbitmqwgethttp://pkgs.fedoraproject.org/cgit/rpms/rabbitmq-server.git/plain/rabbitmq-script-wrappersed-i's@cd/var/lib/rabbitmq@cd/usr/local/rabbitmq/var/lib/rabbitmq@g'rabbitmq-script-wrapper#更改rabbitmq数据存储目录sed-i's@/usr/lib/rabbitmq/bin/@/usr/local/rabbitmq/sbin/@g'rabbitmq-script-wrapperchmod+xrabbitmq-script-wrappercprabbitmq-script-wrapper/usr/sbin/rabbitmqctlcprabbitmq-script-wrapper/usr/sbin/rabbitmq-servercprabbitmq-script-wrapper/usr/sbin/rabbitmq-pluginschown-Rrabbitmq.rabbitmq/usr/local/rabbitmq/var4. 日志割接

cat>>/etc/logrotate.d/rabbitmq-serverlocal/rabbitmq/var/log/rabbitmq/*.log{weeklymissingokrotate20compressdelaycompressnotifemptysharedscriptspostrotate/sbin/servicerabbitmq-serverrotate-logs>/dev/nullendscript}EOF5. 启动脚本

参考： 《RabbitMQ启动脚本》

Erlang Cookie文件：/home/rabbitmq/.erlang.cookie。这里将rabbit1的该文件复制到rabbit2、rabbit3，并设置400权限

chmod400/home/rabbitmq/.erlang.cookiechownrabbitmq.rabbitmq/home/rabbitmq/.erlang.cookie7. 修改配置文件

密码和集群配置：

cat>/usr/local/rabbitmq/etc/rabbitmq/rabbitmq.config'rabbit@rabbit1','rabbit@rabbit2','rabbit@rabbit3'],disc}},{tcp_listeners,[{"0.0.0.0",5672}]},{default_vhost,"/">>},{default_user,"linuxeye">>},{default_pass,"linuxeye@123">>},{loopback_users,["linuxeye"]},{default_permissions,[".*">>,".*">>,".*">>]}]}].EOF

启用rabbitmq_management

cat>/usr/local/rabbitmq/etc/rabbitmq/enabled_plugins8. 分别启动3个节点rabbitmq

使用rabbitmqctl cluster_status命令表示集群搭建成功

[root@rabbit2~]#rabbitmqctlcluster_statusClusterstatusofnoderabbit@rabbit2...[{nodes,[{disc,[rabbit@rabbit1,rabbit@rabbit2,rabbit@rabbit3]}]},{running_nodes,[rabbit@rabbit3,rabbit@rabbit1,rabbit@rabbit2]},{cluster_name,"rabbit@rabbit2">>},{partitions,[]}]9. 设置镜像队列策略

在任意一个节点上执行：

rabbitmqctlset_policyha-all"^"'{"ha-mode":"all"}'10. 配置HAProxy

配置好HAProxy后，浏览器访问http://10.0.0.4:15672, 看到如下证明rabbitmq镜像模式搭建成功