RabbitMQ与AMQP协议详解

1. 消息队列的历史
了解一件事情的前因后果，将不会对它感到神秘。让咱们来看看消息队列（Message Queue）这项技术的发展历史。

Message Queue的需求由来已久，80年代最先在金融交易中，高盛等公司采用Teknekron公司的产品，当时的Message queuing软件叫作：the information bus（TIB）。 TIB被电信和通信公司采用，路透社收购了Teknekron公司。以后，IBM开发了MQSeries，微软开发了Microsoft Message Queue（MSMQ）。这些商业MQ供应商的问题是厂商锁定，价格高昂。2001年，Java Message queuing试图解决锁定和交互性的问题，但对应用来讲反而更加麻烦了。

因而2004年，摩根大通和iMatrix开始着手Advanced Message Queuing Protocol （AMQP）开放标准的开发。2006年，AMQP规范发布。2007年，Rabbit技术公司基于AMQP标准开发的RabbitMQ 1.0 发布。

目前RabbitMQ的最新版本为3.5.7，基于AMQP 0-9-1。

RabbitMQ采用Erlang语言开发。Erlang语言由Ericson设计，专门为开发concurrent和distribution系统的一种语言，在电信领域使用普遍。OTP（Open Telecom Platform）做为Erlang语言的一部分，包含了不少基于Erlang开发的中间件／库／工具，如mnesia／SASL，极大方便了Erlang应用的开发。OTP就相似于Python语言中众多的module，用户借助这些module能够很方便的开发应用。

2. AMQP messaging 中的基本概念

• Broker: 接收和分发消息的应用，RabbitMQ Server就是Message Broker。
• Virtual host: 出于多租户和安全因素设计的，把AMQP的基本组件划分到一个虚拟的分组中，相似于网络中的namespace概念。当多个不一样的用户使用同一个RabbitMQ server提供的服务时，能够划分出多个vhost，每一个用户在本身的vhost建立exchange／queue等。
• Connection: publisher／consumer和broker之间的TCP链接。断开链接的操做只会在client端进行，Broker不会断开链接，除非出现网络故障或broker服务出现问题。
• Channel: 若是每一次访问RabbitMQ都创建一个Connection，在消息量大的时候创建TCP Connection的开销将是巨大的，效率也较低。Channel是在connection内部创建的逻辑链接，若是应用程序支持多线程，一般每一个thread建立单独的channel进行通信，AMQP method包含了channel id帮助客户端和message broker识别channel，因此channel之间是彻底隔离的。Channel做为轻量级的Connection极大减小了操做系统创建TCP connection的开销。
• Exchange: message到达broker的第一站，根据分发规则，匹配查询表中的routing key，分发消息到queue中去。经常使用的类型有：direct (point-to-point), topic (publish-subscribe) and fanout (multicast)。
• Queue: 消息最终被送到这里等待consumer取走。一个message能够被同时拷贝到多个queue中。
• Binding: exchange和queue之间的虚拟链接，binding中能够包含routing key。Binding信息被保存到exchange中的查询表中，用于message的分发依据。

3. 典型的“生产／消费”消息模型

生产者发送消息到broker server（RabbitMQ）。在Broker内部，用户建立Exchange／Queue，经过Binding规则将二者联系在一块儿。Exchange分发消息，根据类型／binding的不一样分发策略有区别。消息最后来到Queue中，等待消费者取走。

4. Exchange类型
Exchange有多种类型，最经常使用的是Direct／Fanout／Topic三种类型。

Direct

Message中的“routing key”若是和Binding中的“binding key”一致， Direct exchange则将message发到对应的queue中。

Fanout

每一个发到Fanout类型Exchange的message都会分到全部绑定的queue上去。

Topic

根据routing key，及通配规则，Topic exchange将分发到目标queue中。

Routing key中能够包含两种通配符，相似于正则表达式：

“#”通配任何零个或多个word “*”通配任何单个word

这里也推荐给想要了解RabbitMQ的同窗一个网站，http://tryrabbitmq.com ，它提供在线RabbitMQ 模拟器，能够帮助理解Exchange／queue／binding概念。

至此，咱们对于消息队列的发展，RabbitMQ的产生，以及AMQP协议中的重要概念作了一个完整的介绍。