mq | Cwww3's Blog

消息队列

解耦
异步
流量削峰

AMQP

AMQP的全称为：Advanced Message Queuing Protocol（高级消息队列协议）。

相比JMS：

JMS定义的是API规范，而AMQP定义了线路层的协议。即JMS实现所发送的消息不能保证被另外不同的JMS实现使用；而AMQP的线路层协议规范了消息的格式，这样不仅能跨AMQP实现，还能跨语言和跨平台。
AMQP具有更加灵活和透明的消息模型。JMS中只有点对点和发布-订阅两种模式；而AMQP通过将消息生产者与消息队列解耦实现多种方式来发送消息。

JMS：(ActiveMQ)

消息生产者
消息消费者
消息通道

消息生产者将消息发送到通道中，消费者从通道中取出数据消费。

通道具有双重责任：

解耦消息的生产者与消费者；
传递数据以及确定消息发送地方。

AMQP：

在消息的生产者与通道之间引入了一种机制：Exchange（交换器），解耦了消息的生产者与队列。

消息生产者将消息（带有一个routing key参数）发送到Exchange上，Exchange会绑定一个或多个队列上，然后Exchange根据不同的路由模式，对比队列携带的routing key参数，负责将信息发送到不同队列上。

RabbitMQ

RabbitMQ是一个开源的AMQP实现，服务器端用Erlang语言编写。

Message

消息是不具名的，它由消息头和消息体组成。消息体是不透明的，而消息头则由一系列的可选属性组成，这些属性包括routing-key（路由键）、priority（相对于其他消息的优先权）、delivery-mode（指出该消息可能需要持久性存储）等。

Publisher

消息的生产者，也是一个向交换器发布消息的客户端应用程序。

Exchange

Exchange称作交换器，它接收消息和路由消息，然后将消息发送给消息队列。每个交换器都有独一无二的名字。相当于一个路由表。

Binding 和 Binding Key

每个Exchange都和一个特定的Queue绑定（可以是多对多的关系）。绑定的同时会指定一个binding key。

每个发送给Exchange的消息一般都有一个routing key参数；当队列与Exchange绑定的binding key与该消息的routing key参数相同的时候，该消息才会被Exchange发给特定的队列。

Queue

Queue是一个不重复，唯一，名字随机的的缓冲区，应用程序在其权限之内可以自由地创建、共享使用和消费消息队列。在RabbitMQ中，队列的名字是系统随机创建的，且当Consumer与Queue断开连接的时候，Queue会被自动删除，在下一次连接时又会自动创建。

Routing Key

生产者在将消息发送给Exchange的时候，一般会指定一个routing key，来指定这个消息的路由规则。
而这个routing key需要与Exchange Type及binding key联合使用才能最终生效。
在Exchange Type与binding key固定的情况下，生产者就可以在发送消息给Exchange时，通过指定routing key来决定消息流向哪里。
RabbitMQ为routing key设定的长度限制为255 bytes。

Channel

多路复用连接中的一条独立的双向数据流通道。信道是建立在真实的TCP连接内地虚拟连接，AMQP 命令都是通过信道发出去的，不管是发布消息、订阅队列还是接收消息，这些动作都是通过信道完成。因为对于操作系统来说建立和销毁 TCP 都是非常昂贵的开销，所以引入了信道的概念，以复用一条 TCP 连接。

Consumer

消息的消费者，表示一个从消息队列中取得消息的客户端应用程序。

Virtual Host

虚拟主机，表示一批交换器、消息队列和相关对象。虚拟主机是共享相同的身份认证和加密环境的独立服务器域。每个 vhost 本质上就是一个 mini 版的 RabbitMQ 服务器，拥有自己的队列、交换器、绑定和权限机制。vhost 是 AMQP 概念的基础，必须在连接时指定，RabbitMQ 默认的 vhost 是 / 。