分布式系统之消息中间件rabbitmq

既然要做分布式系统，就不得不说分布式消息通信系统。分布式系统的基础是各个分布式单元能够以各种方式互相通信，分布式消息中间件比较有名的开源实现有rabbitMQ，zeroMQ（库），ActiveMQ等，本篇先考察一下著名的消息中间件rabbitmq

 

rabbitmq在2010年4月被SpringSource收购，后者是vmware的一个部门，就是说，rabbitmq目前已经是vmware的了。

 

rabbitmq使用erlang语言编写，实现了AMQP协议。AMQP协议在04年中~06年中由摩根大通集团和iMatix公司开发，后来由AMQP工作组维护。最初用于金融领域，后来慢慢成为一个通用的协议。与JMS不同，AMQP定义了详细的消息格式，因此任何语言开发的软件都可以与其他语言开发的软件进行互通，只要他们的消息格式一致即可。

 

AMQP协议定义了Message Broker作为消息服务器，定义了User作为消息服务器的使用者（producer或consumer），User和Message Broker之间可以建立物理连接Connection，在Connection上，可以创建虚拟连接channel。基于Channel，可以声明（declare）交换机exchange，队列queue，可以在exchange和queue间建立绑定binding，Message由生产者发送到exchange，然后按照规则发送给binding到该exchange的queue。Message分为头部和消息体，其中头部包含了routing-key，而binding也有routing-key的属性，不过这个binding的这个属性可以是一个或多个明确的routing-key，也可以是一个或多个pattern。

 

exchange和queue之间可以有多个binding，一个exchange可以bind多个queue，一个queue也可以bind到多个exchange。这里exchange相当于硬件的交换机，但queue不是连线，而是一个缓存，binding是queue和exchange之间的关系。虽然exchange和queue之间可以有多个binding，但不会导致一个消息会从exchange重复发送给同一个queue，一个消息从一个exchange最多发送一次给一个queue。

 

binding实际上是exchange上的一条配置规则。

 

2011年8月31日，AMQP发布了1.0版本。1.0版本中去掉了exchange和binding，使用queue和link来代替。

 

先到这里，下次继续。