文章目录1. 前言2. 什么是 MQ2.1 同步通信2.2 异步通信3. MQ 的作用3.1 异步解耦3.2 流量削峰3.3 消息分发3.4 延迟通知4. 为什么选择 RabbitMQ4.1 Kafka4.2 RocketMQ4.3 RabbitMQ5. RabbitMQ介绍1. 前言Rabbit兔子的意思。互联网行业很多公司都喜欢用动物命名产品或者作为公司的 logo、吉祥物。比如腾讯的企鹅京东的狗美团的袋鼠携程的海豚阿里就更多了蚂蚁飞猪天猫菜鸟闲鱼盒马……更是以一己之力组建了一个动物园……Rabbit 也是一个公司名。MQmessage queue消息队列的意思RabbitMQ 是 Rabbit 企业下的一个消息队列产品。RabbitMQ 是一个实现了 AMQP 的消息队列服务是当前主流的消息中间件之一。AMQP即Advanced Message Queuing Protocol高级消息队列协议是一个通用的应用层协议提供统一消息服务的协议为面向消息的中间件设计。基于此协议的客户端与消息中间件可传递消息并不受客户端或中间件开发语言等条件的限制。在互联网架构中会经常使用 MQ 来作为消息通信服务。接下来我们看下什么是 MQ。2. 什么是 MQMQMessage queue从字面意思上看本质是个队列FIFO 先入先出只不过队列中存放的内容是消息message而已。消息可以非常简单比如只包含文本字符串、JSON 等也可以很复杂比如内嵌对象。MQ 多用于分布式系统之间进行通信。系统之间的调用通常有两种方式同步通信 与 异步通信。2.1 同步通信定义直接调用对方的服务数据从一端发出后立即就可以达到另一端。如下图所示2.2 异步通信定义数据从一端发出后先进入一个容器进行临时存储当达到某种条件后再由这个容器发送给另一端。容器的一个具体实现就是 MQmessage queue如下图所示而 RabbitMQ 就是 MQ 的一种实现。3. MQ 的作用MQ 主要工作是接收并转发消息在不同的应用场景下可以展现不同的作用。比如可以把 MQ 想象成一个仓库。采购部门进货之后把零件放进仓库里生产部门从仓库中取出零件并加工成产品。MQ 和仓库的区别是仓库里放的是物品MQ 里放的是消息仓库负责存储物品并转发物品MQ 负责存储和转发消息。如下图所示它的作用如下。3.1 异步解耦在业务流程中一些操作可能非常耗时但并不需要即时返回结果。可以借助 MQ 把这些操作来进行异步化。比如用户注册后发送注册短信或邮件通知可以作为异步任务处理而不必等待这些操作完成后才告知用户注册成功。3.2 流量削峰在访问量剧增的情况下应用仍然需要继续发挥作用但是这样的突发流量并不常见。如果以能处理这类峰值为标准而投入资源无疑是巨大的浪费。使用 MQ 能够使关键组件支撑突发访问压力不会因为突发流量而崩溃。比如秒杀或者促销活动可以使用 MQ 来控制流量将请求排队然后系统根据自己的处理能力逐步处理这些请求。3.3 消息分发当多个系统需要对同一数据做出响应时可以使用 MQ 进行消息分发。比如支付成功后支付系统可以向 MQ 发送消息其他系统订阅该消息而无需轮询数据库。3.4 延迟通知在需要在特定时间后发送通知的场景中可以使用 MQ 的延迟消息功能。比如在电子商务平台中如果用户下单后一定时间内未支付可以使用延迟队列在超时后自动取消订单。4. 为什么选择 RabbitMQ目前业界有很多的 MQ 产品例如 RabbitMQ、RocketMQ、ActiveMQ、Kafka、ZeroMQ 等也有直接使用 Redis 充当消息队列的案例这些消息队列各有侧重也没有好坏只有适合不适合在实际选型时需要结合自身需求以及 MQ 产品特征综合考虑。以下我们介绍一下当前最主流的 3 种 MQ 产品。4.1 KafkaKafka 一开始的目的就是用于日志收集和传输追求高吞吐量性能卓越单机吞吐达到十万级在日志领域比较成熟功能较为简单主要支持简单的 MQ 功能如果有日志采集需求肯定是首选 kafka 了。4.2 RocketMQRocketMQ 采用 Java 语言开发由阿里巴巴开源后捐赠给了 Apache。它在设计时借鉴了 Kafka并做出了一些自己的改进青出于蓝而胜于蓝经过多年双十一的洗礼在可用性、可靠性以及稳定性等方面都有出色的表现。适合对于可靠性比较高且并发比较大的场景比如互联网金融。但支持的客户端语言不多且社区活跃度一般。4.3 RabbitMQ采用 Erlang 语言开发MQ 功能比较完备且几乎支持所有主流语言开源提供的界面也非常友好性能较好吞吐量能达到万级社区活跃度也比较高比较适合中小型公司数据量没那么大且并发没那么高的场景。综合由于 RabbitMQ 的综合能力较强且 RabbitMQ 社区比较成熟管理界面友好所以咱们接下来主要学习 RabbitMQ 的使用。5. RabbitMQ介绍可以去访问 RabbitMQ 官网 查看详情。RabbitMQ 是采用 Erlang 语言实现 AMQPAdvanced Message Queuing Protocol高级消息队列协议的消息中间件它最初起源于金融系统领域为了在分布式系统中存储和转发消息而设计的。在此之前有一些消息中间件的商业实现比如微软的 MSMQMicroSoft Message QueueIBM 的 WebSphere 等。但是他们价格太贵了一般只应用于大型组织机构。RabbitMQ 开发始于 2006 年是由 Rabbit Technologies 开发并且提供商业支持的。之所以取名为 Rabbit是因为兔子行动非常迅速且繁殖起来非常疯狂RabbitMQ 的开创者认为这个名字再合适不过了。2010年4月Rabbit Technologies 被 VMware 旗下的 SpringSource 收购在2013年5月被并入 Pivotal。其实 VMwarePivotal 本质上是一家的。不同的是VMware 是独立上市子公司而 Pivotal 是整合了 EMC 的某些资源其中我们现在使用的 Spring 系列框架就是 Pivotal 公司热门的产品之一。直到后来 Pivotal 将其开源RabbitMQ 才逐渐走向大众RabbitMQ 发展到今天已经被越来越多的人认可尤其是互联网公司已经有着大规模的场景应用这和它在易用性扩展性可靠性和高可用性等方面的卓越表现是分不开的。接下来我们就一起来深入了解一下 RabbitMQ。