1. 汗青

RabbitMQ是一个由erlang开拓的AMQP（Advanced Message Queue ）的开源实现。AMQP 的呈现其实也是应了宽大人民群众的需求，固然在同步动静通讯的世界里有许多果真尺度（如 COBAR的 IIOP ，可能是 SOAP 等），可是在异步动静处理惩罚中却不是这样，只有大企业有一些贸易实现（如微软的 MSMQ ，IBM 的 Websphere MQ 等），因此，在 2006 年的 6 月，Cisco 、Redhat、iMatix 等连系拟定了 AMQP 的果真尺度。

RabbitMQ是由RabbitMQ Technologies Ltd开拓而且提供贸易支持的。该公司在2010年4月被SpringSource（VMWare的一个部分）收购。在2013年5月被并入Pivotal。其实VMWare，Pivotal和EMC本质上是一家的。差异的是VMWare是独立上市子公司，而Pivotal是整合了EMC的某些资源，此刻并没有上市。

RabbitMQ的官网是http://www.rabbitmq.com

2. 应用场景

言归正传。RabbitMQ，可能说AMQP办理了什么问题，可能说它的应用场景是什么？

对付一个大型的软件系统来说，图纸加密，它会有许多的组件可能说模块可能说子系统可能（subsystem or Component or submodule）。那么这些模块的如何通信？这和传统的IPC有很大的区别。传统的IPC许多都是在单一系统上的，模块耦合性很大，不适合扩展（Scalability）；假如利用socket那么差异的模块简直可以陈设到差异的呆板上，可是照旧有许多问题需要办理。好比：

1）信息的发送者和吸收者如何维持这个毗连，假如一方的毗连间断，这期间的数据如何方法丢失？
2）如何低落发送者和吸收者的耦合度？
3）如何让Priority高的吸收者先接到数据？
4）如何做到load balance？有效平衡吸收者的负载？
5）如何有效的将数据发送到相关的吸收者？也就是说将吸收者subscribe 差异的数据，如何做有效的filter。
6）如何做到可扩展，甚至将这个通信模块发到cluster上？
7）如何担保吸收者吸收到了完整，正确的数据？

AMDQ协议办理了以上的问题，而RabbitMQ实现了AMQP。

3. 系统架构

RabbitMQ Server： 也叫broker server，它不是运送食物的卡车，而是一种传输处事。原话是RabbitMQisn’t a food truck, it’s a delivery service. 他的脚色就是维护一条从Producer到Consumer的蹊径，担保数据可以或许凭据指定的方法举办传输。可是这个担保也不是100%的担保，可是对付普通的应用来说这已经足够了。虽然对付贸易系统来说，可以再做一层数据一致性的guard，就可以彻底担保系统的一致性了。

Client P： 也叫Producer，数据的发送方。createmessages and publish (send) them to a broker server (RabbitMQ).一个Message有两个部门：payload（有效载荷）和label（标签）。payload顾名思义就是传输的数据。label是exchange的名字可能说是一个tag，它描写了payload，并且RabbitMQ也是通过这个label来抉择把这个Message发给哪个Consumer。AMQP仅仅描写了label，而RabbitMQ抉择了如何利用这个label的法则。

Client C: 也叫Consumer，数据的吸收方。Consumersattach to a broker server (RabbitMQ) and subscribe to a queue。把queue比作是一个有名字的邮箱。当有Message达到某个邮箱后，RabbitMQ把它发送给它的某个订阅者即Consumer。虽然大概会把同一个Message发送给许多的Consumer。在这个Message中，只有payload，label已经被删掉了。对付Consumer来说，它是不知道谁发送的这个信息的。就是协议自己不支持。可是虽然了假如Producer发送的payload包括了Producer的信息就另当别论了。

对付一个数据从Producer到Consumer的正确通报，尚有三个观念需要明晰：exchanges, queues and bindings。

尚有几个观念是上述图中没有标明的，那就是Connection（毗连），Channel（通道，频道）。

那么，为什么利用Channel，而不是直接利用TCP毗连？

对付OS来说，成立和封锁TCP毗连是有价钱的，频繁的成立封锁TCP毗连对付系统的机能有很大的影响，并且TCP的毗连数也有限制，这也限制了系统处理惩罚高并发的本领。可是，在TCP毗连中成立Channel是没有上述价钱的。对付Producer可能Consumer来说，可以并发的利用多个Channel举办Publish可能Receive。有尝试表白，1s的数据可以Publisp0K的数据包。虽然对付差异的硬件情况，差异的数据包巨细这个数据必定纷歧样，可是我只想说明，对付普通的Consumer可能Producer来说，这已经足够了。假如不足用，你思量的应该是如何细化split你的设计。

由Exchange，Queue，RoutingKey三个才气抉择一个从Exchange到Queue的独一的线路。

4.根基观念

ConnectionFactory、Connection、Channel