rabbitmq有3种模式，但集群模式是2种。详细如下：

单一模式：即单机情况不做集群，就单独运行一个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方案。
该模式解决了普通模式中的问题，其实质和普通模式不同之处在于，消息实体会主动在镜像节点间同步，而不是在客户端取数据时临时拉取。
该模式带来的副作用也很明显，除了降低系统性能外，如果镜像队列数量过多，加之大量的消息进入，集群内部的网络带宽将会被这种同步通讯大大消耗掉。
所以在对可靠性要求较高的场合中适用。

192.168.0.31 node1

192.168.0.32 node2

192.168.0.33 node3

3个节点都安装rabbitmq

安装请参考:http://www.cnblogs.com/hanxiaohui/p/8822443.html

RabbitMQ节点之间和命令行工具 (e.g. rabbitmqctl)是使用Cookie互通的，Cookie是一组随机的数字+字母的字符串。
当RabbitMQ服务器启动的时候，Erlang VM会自动创建一个随机内容的Cookie文件。如果是通过源安装RabbitMQ的话，Erlang Cookie 文件在/var/lib/rabbitmq/.erlang.cookie。
如果是通过源码安装的RabbitMQ，Erlang Cookie文件$HOME/.erlang.cookie

. rabbitmq-server -detached  #首先启动Node1上的rabbitmq

. 在家目录下产生.erlang.cookie 文件，权限400

. 复制.erlang.cookie 文件到node2,node3

.最后分别在确认三台机器上的.erlang.cookie的值是一致的.  #cat .erlang.cookie 内容要一致

3个节点都需要操作

rabbitmqctl stop  #关闭

rabbitmq-server -detached  #启动

node1:

lion@node1:~$ rabbitmqctl cluster_status

Cluster status of node rabbit@node1 ...

[{nodes,[{disc,[rabbit@node1]}]},

 {running_nodes,[rabbit@node1]},

 {cluster_name,<<"rabbit@node1">>},

 {partitions,[]},

 {alarms,[{rabbit@node1,[]}]}]

node2:

lion@node2:~$ rabbitmqctl cluster_status

Cluster status of node rabbit@node2 ...

[{nodes,[{disc,[rabbit@node2]}]},

 {running_nodes,[rabbit@node2]},

 {cluster_name,<<"rabbit@node2">>},

 {partitions,[]},

 {alarms,[{rabbit@node2,[]}]}]

node3:

lion@node3:~$ rabbitmqctl cluster_status

Cluster status of node rabbit@node3 ...

[{nodes,[{disc,[rabbit@node3]}]},

 {running_nodes,[rabbit@node3]},

 {cluster_name,<<"rabbit@node3">>},

 {partitions,[]},

 {alarms,[{rabbit@node3,[]}]}]

因为rabbitmq-server启动时，会一起启动节点和应用，它预先设置RabbitMQ应用为standalone模式。
要将一个节点加入到现有的集群中，你需要停止这个应用并将节点设置为原始状态，然后就为加入集群准备好了。
如果使用./rabbitmqctl stop，应用和节点都将被关闭。所以使用rabbitmqctl stop_app仅仅关闭应用。

node2:

lion@node2:~$ rabbitmqctl stop_app

Stopping node rabbit@node2 ...

lion@node2:~$ rabbitmqctl join_cluster rabbit@node1

Clustering node rabbit@node2 with rabbit@node1 ...

lion@node2:~$ rabbitmqctl start_app

Starting node rabbit@node2 ...

node3:

lion@node3:~$ rabbitmqctl stop_app

Stopping node rabbit@node3 ...

lion@node3:~$ rabbitmqctl join_cluster rabbit@node1

Clustering node rabbit@node3 with rabbit@node1 ...

lion@node3:~$ rabbitmqctl start_app

Starting node rabbit@node3 ...

此时 node2 与 node3 也会自动建立连接。

如果要使用内存节点，则可以使用以下命令：

lion@node2:~$ rabbitmqctl join_cluster --ram rabbit@node1

集群配置好后，可以在 RabbitMQ 任意节点上执行 rabbitmqctl cluster_status 来查看是否集群配置成功。

lion@node1:~$ rabbitmqctl cluster_status

Cluster status of node rabbit@node1 ...

[{nodes,[{disc,[rabbit@node1,rabbit@node2,rabbit@node3]}]},

 {running_nodes,[rabbit@node1]},

 {cluster_name,<<"rabbit@node1">>},

 {partitions,[]},

 {alarms,[{rabbit@node1,[]}]}]

集群中必须存活一个磁盘节点

./rabbitmqctl stop_app

./rabbitmqctl change_cluster_node_type {ram|disk}

./rabbitmqctl start_app

./rabbitmqctl forget_cluster_node rabbit@xxx

使用Rabbit镜像功能，需要基于RabbitMQ策略来实现，策略是用来控制和修改群集范围的某个vhost队列行为和Exchange行为

lion@node2:~$ rabbitmqctl set_policy -p test ha-allqueue "^" '{"ha-mode":"all"}'   
#这行命令，在vhost名称为test创建了一个策略，策略名称为ha-allqueue,策略模式为 all 即复制到所有节点，包含新增节点，策略正则表达式为 “^” 表示所有匹配所有队列名称。

例如下面的命令，^message 这个规则要根据自己修改，这个是指同步"message"开头的队列名称，我们配置时使用的应用于所有队列，所以表达式为"^"。

lion@node2:~$ rabbitmqctl set_policy -p test ha-allqueue "^message" '{"ha-mode":"all"}'

更多set_policy说明：http://www.rabbitmq.com/man/rabbitmqctl.1.man.html

通过软件负载均衡器haproxy实现分发（通过7562端口）
https://www.cnblogs.com/lion.net/p/5725474.html

）

#随意一台操作

#添加用户test 密码为test

rabbitmqctl  add_user  test  test

#设置test用户为administrator

rabbitmqctl set_user_tags test administrator

#添加vhost 名为test

rabbitmqctl add_vhost test

#设置test用户对 test vhost的所有权限  -p 后的第一个test为vhost名 第二个test为用户名

rabbitmqctl set_permissions -p test test '.*' '.*' '.*'

#添加镜像策略(同步消息到其它节点,消息持久化)

rabbitmqctl  set_policy -p test ha-allqueue "^" '{"ha-mode":"all"}'

#在vhost test中添加一个队列，名为test   durable=true【rabbitmq重启队列还在，即对队列做持久化】

rabbitmqadmin --vhost=test --username=test --password=test  declare queue name=test durable=true

#往队列里添加一条消息

rabbitmqadmin --vhost=test --username=test --password=test publish routing_key=test payload="this is a testing" 

#查看队列情况

rabbitmqadmin --vhost=test --username=test --password=test list queues

#从test queue消费一条信息

rabbitmqadmin --vhost=test --username=test --password=test get queue=test requeue=true   #requeue=true 这条消息消费后还在，反之如果为false消费后消息就不在了。

）

停掉rabbitmq1,在另外两台查看队列情况，可以看到test队列还是存在，获取队列的消息也是可以获取到的。

再重新开启rabbitmq1 可以看到test队列还是存在，获取队列的消息也是可以获取到的.