查看“RabbitMQ集群方案原理”的源代码

一、RabbitMQ集群方案的原理
RabbitMQ这款消息队列中间件产品本身是基于Erlang编写，Erlang语言天生具备分布式特性（通过同步Erlang集群各节点的magic cookie来实现）。

因此，RabbitMQ天然支持Clustering。这使得RabbitMQ本身不需要像ActiveMQ、Kafka那样通过ZooKeeper分别来实现HA方案和保存集群的元数据。集群是保证可靠性的一种方式，同时可以通过水平扩展以达到增加消息吞吐量能力的目的。下面先来看下RabbitMQ集群的整体方案：

[[File:rabbitmq-11.png|500px|center|border]]

上面图中采用三个节点组成了一个RabbitMQ的集群，Exchange A（交换器，对于RabbitMQ基础概念不太明白的童鞋可以看下基础概念）的元数据信息在所有节点上是一致的，而Queue（存放消息的队列）的完整数据则只会存在于它所创建的那个节点上。，其他节点只知道这个queue的metadata信息和一个指向queue的owner node的指针。

（1）RabbitMQ集群元数据的同步

RabbitMQ集群会始终同步四种类型的内部元数据（类似索引）： a.队列元数据：队列名称和它的属性； b.交换器元数据：交换器名称、类型和属性； c.绑定元数据：一张简单的表格展示了如何将消息路由到队列； d.vhost元数据：为vhost内的队列、交换器和绑定提供命名空间和安全属性； 因此，当用户访问其中任何一个RabbitMQ节点时，通过rabbitmqctl查询到的queue／user／exchange/vhost等信息都是相同的。

（2）为何RabbitMQ集群仅采用元数据同步的方式

第一，存储空间，如果每个集群节点都拥有所有Queue的完全数据拷贝，那么每个节点的存储空间会非常大，集群的消息积压能力会非常弱（无法通过集群节点的扩容提高消息积压能力）；

第二，性能，消息的发布者需要将消息复制到每一个集群节点，对于持久化消息，网络和磁盘同步复制的开销都会明显增加。

（3）RabbitMQ集群发送/订阅消息的基本原理
RabbitMQ集群的工作原理图如下：

[[File:rabbitmq-12.png|500px|center|border]]

场景1：客户端直接连接队列所在节点

如果有一个消息生产者或者消息消费者通过amqp-client的客户端连接至节点1进行消息的发布或者订阅，那么此时的集群中的消息收发只与节点1相关，这个没有任何问题；如果客户端相连的是节点2或者节点3（队列1数据不在该节点上），那么情况又会是怎么样呢？

场景2：客户端连接的是非队列数据所在节点

如果消息生产者所连接的是节点2或者节点3，此时队列1的完整数据不在该两个节点上，那么在发送消息过程中这两个节点主要起了一个路由转发作用，根据这两个节点上的元数据（也就是上文提到的：指向queue的owner node的指针）转发至节点1上，最终发送的消息还是会存储至节点1的队列1上。

同样，如果消息消费者所连接的节点2或者节点3，那这两个节点也会作为路由节点起到转发作用，将会从节点1的队列1中拉取消息进行消费。

一、RabbitMQ集群完善

[[File:rabbitmq-13.png|{700px|center|border]]

可以根据这个架构图，做一些RabbitMQ集群完善，主要是将内存节点作为负载，磁盘节点作为存储。

更改集群节点类型：

 rabbitmqctl stop_app
 rabbitmqctl change_cluster_node_type ram
 rabbitmqctl change_cluster_node_type disc
 rabbitmqctl start_app
 rabbitmqctl cluster_status
如果出现错误：

 Error: unable to connect to node rabbit@manager1: nodedown
解决方式：

 /sbin/service rabbitmq-server stop
 /sbin/service rabbitmq-server start
 rabbitmqctl status
如果要将节点移除集群，则在本节点上执行：

 rabbitmqctl stop_app && 
 rabbitmqctl reset && 
 rabbitmqctl start_app
然后在主节点执行：

 rabbitmqctl forget_cluster_node rabbit@manager3
节点加入集群命令：

 rabbitmqctl join_cluster rabbit@manager3 --ram
 rabbitmqctl join_cluster rabbit@manager3 --disc

[[分类:rabbitmq]]