消息发布接收流程：
--发送消息---
1、生产者和Broker建立TCP连接。
2、生产者和Broker建立通道。
3、生产者通过通道消息发送Broker，由Exchange将消息进行转发。
4、Exchange将消息转发到指定的Queue（队列）
---接收消息----
1、消费者和Broker建立TCP连接2、消费者和Broker建立通道
3、消费者监听指定的Queue（队列）I
4、当有消息到达Queue时Broker默认将消息推送给消费者。
5、消费者接收到消息。
安装rabbitmq
配置 erlang yum源
cat /etc/yum.repos.d/rabbitmq_erlang.repo
[rabbitmq_erlang]
name=rabbitmq_erlang
baseurl=https://packagecloud.io/rabbitmq/erlang/el/7/$basearch
repo_gpgcheck=1
gpgcheck=1
enabled=1
# PackageCloud's repository key and RabbitMQ package signing key
gpgkey=https://packagecloud.io/rabbitmq/erlang/gpgkey
https://dl.bintray.com/rabbitmq/Keys/rabbitmq-release-signing-key.asc
sslverify=1
sslcacert=/etc/pki/tls/certs/ca-bundle.crt
metadata_expire=300
[rabbitmq_erlang-source]
name=rabbitmq_erlang-source
baseurl=https://packagecloud.io/rabbitmq/erlang/el/7/SRPMS
repo_gpgcheck=1
gpgcheck=0
enabled=1
# PackageCloud's repository key and RabbitMQ package signing key
gpgkey=https://packagecloud.io/rabbitmq/erlang/gpgkey
https://dl.bintray.com/rabbitmq/Keys/rabbitmq-release-signing-key.asc
sslverify=1
sslcacert=/etc/pki/tls/certs/ca-bundle.crt
metadata_expire=300
安装mq 依赖
yum -y install erlang
yum -y install socat*
安装rabbitmq
rpm -ivh rabbitmq-server-3.7.18-1.el7.noarch.rpm
复制配置文件
cp /usr/share/doc/rabbitmq-server-3.7.18/rabbitmq.config.example /etc/rabbitmq/rabbitmq.config
修改配置文件
61 {loopback_users, []}
开启管理插件
rabbitmq-plugins enable rabbitmq_management
启动rabbitmq
systemctl start rabbitmq-server
解决管理端guest不能登录的问题：
vim /usr/lib/rabbitmq/lib/rabbitmq_server-3.7.18/ebin/rabbit.app
39 {loopback_users, [<<"guest">>]},
改为
39 {loopback_users, []},
web界面登录
集群搭建
集群中 erlang.cookie需要一致
节点规划：
mq1 192.168.0.103 master
mq2 192.168.0.104 slave
mq3 192.168.0.105 slave
同步cookile
scp /var/lib/rabbitmq/.erlang.cookie root@mq2:/var/lib/rabbitmq/
scp /var/lib/rabbitmq/.erlang.cookie root@mq3:/var/lib/rabbitmq/
后台启动节点
rabbitmq-server -detached
（后台启动无法启动WEB插件，不能访问WEB界面）
mq2、mq3执行以下命令
关闭 rabbitmqctl stop_app
加入集群 rabbitmqctl join_cluster rabbit@mq1
启动 rabbitmqctl start_app（这种方式启动，会加载WEB插件，可以正常访问WEB 界面）
查看集群节点信息
[root@mq3 ~]# rabbitmqctl cluster_status
Cluster status of node rabbit@mq3 ...
[{nodes,[{disc,[rabbit@mq1,rabbit@mq2,rabbit@mq3]}]},
{running_nodes,[rabbit@mq1,rabbit@mq2,rabbit@mq3]},
{cluster_name,<<"rabbit@mq3">>},
{partitions,[]},
{alarms,[{rabbit@mq1,[]},{rabbit@mq2,[]},{rabbit@mq3,[]}]}]
WEB 页面查看集群节点信息
普通集群
主节点正常时，主节点的消息队列会自动同步到从节点，消费者可以监听从节点来消费消息
当主节点宕机时，无法实现故障自动切换，两个从节点只作为备份，主节点的消息队列只存在主节点，从节点无法提供服务
镜像集群：
使用镜像集群，添加集群策略，可以实现消息队列的镜像同步，消息队列不仅仅只存在主节点上，当主节点宕机的时候，可以实现故障自动转移，同时选举一个从节点做为主节点来提供服务。
添加策略
rabbitmqctl set_policy ha-all '^hello' '{"ha-mode":"all","ha-sync-mode":"automatic"}'
模拟主节点mq1宕机
rabbitmqctl stop_app
主节点会自动切换
当mq1恢复时，会加入集群作为一个从节点
