RabbitMQ的基础

MQ概念

MQ全称Message Queue 消息队列，是在消息的传输过程中保存消息的容器。多用于分布式系统之间进行通信。

• MQ，消息队列，存储消息的中间件
• 分布式系统通信两种方式：直接远程调用和借助第三方完成间接通信
• 发送方称之为生产者，接收方称之为消费者

MQ 的优势和劣势

优势

• 应用解耦：提高系统容错性和可维护性
• 异步提速：提升用户体验和系统吞吐量
• 削峰填谷：提高系统稳定性

劣势

• 系统可用性降低：系统引入的外部依赖越多，系统稳定性越差。一旦宕机，就会对业务造成影响。如何保证MQ的高可用？
• 系统复杂度提高：MQ的加入大大增加了系统的复杂度，以前系统间是同步的远程调用，现在是通过MQ进行异步调用。如何保证消息没有被重复消费？怎么处理消息丢失情况？那怎么保证消息传递的时序性？
• 一致性问题：A系统处理完业务，通过MQ给B、C、D三个系统发送消息数据，如果B、系统、C系统处理成功、D系统处理失败。如何保证消息处理的一致性？

常见的MQ产品

RabbitMQ、Rocket MQ、Active MQ、Kafka、Zero MQ、MetaMQ等

Rabbit MQ的简介

AMQP，即Advanced Message Queuing Protocol 高级消息队列，是一个网络协议，是应用协议的一个开放标准，为面向消息的中间件设计。基于协议的客户端与消息中间价可传递消息，并不受客户端/中间间不同产品，不同的开发语言等条件限制。

相关概念：

• Broker：接收和分发消息的应用，RabbitMQ Server就是Message Broker
• Virtual host：出于多租户和安全因素设计的，把AMQP的基本组件划分到一个虚拟的分组中，类似于网络中namespace概念。当多个不同的用户使用一个Rabbit MQ Server提供服务时，可以划分出多个vhost，每个用户在自己的vhost创建exchange/queue等。
• Connection：publisher/consumer 和broker之间TCP连接。
• 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 ，topic ，and fanout。
• Queue：消息最终被送到这里等待consumer取走。
• Binding：exchange和queue之间的虚拟连接，binding中可以包含routing key。binding信息被保存到exchange中的查询表中，用于message的分发依据

RabbitMQ的六种工作模式：

简单模式、work queues、Publish/Subscribe发布与订阅模式、Routing路由模式、Topics主题模式、RPC远程调用模式。

JMS

• JMS即Java消息服务（JavaMessageService）应用程序接口，是一个Java平台中关于面向中间件的API。
• JMS是Java EE规范中的一种，类比JDBC。
• 很多消息中间件都实现JMS规范，例如Active MQ，Rabbit MQ官方没有提供JMA实现包，开源社区中有。

小结

1. Rabbit MQ是基于AMQP协议使用Erlang语言开发的一款消息队列。
2. Rabbit MQ提供了6种工作模式
3. AMQP是协议，类比与HTTP。
4. JMS是PAI规范接口，类比于JDBC。