消息队列——RocketMQ

本文主要是介绍消息队列——RocketMQ，希望对大家解决编程问题提供一定的参考价值，需要的开发者们随着小编来一起学习吧！

什么是消息队列：

MQ 全称（Message Queue）又名消息队列，是一种提供消息队列服务的中间件，也称为消息中间件，是一套提供了消息生产、存储、消费全过程 API的软件系统(消息即数据)。通俗点说，就是一个先进先出的数据结构。

应用场景：

异步解耦(减少请求响应时间和解耦)
但是对于用户来说，注册功能实际只需要注册系统存储用户的账户信息后，该用户便可以登录，而后续 的注册短信和邮件不是即时需要关注的步骤。 所以实际当数据写入注册系统后，注册系统就可以把其他的操作放入对应的消息队列 MQ 中然后马上返 回用户结果，由消息队列 MQ 异步地进行这些操作(较耗时而且不需要即时（同步）返回结果的操作作为消息放入消息队列)

常见的 MQ 产品

ZeroMQ:
号称最快的消息队列系统，尤其针对大吞吐量的需求场景。扩展性好，开发比较灵活，采用 C 语言 实现，实际上只是一个 socket 库的重新封装，如果做为消息队列使用，需要开发大量的代码。 ZeroMQ 仅提供非持久性的队列，也就是说如果 down 机，数据将会丢失。
RabbitMQ:
使用 erlang 语言开发，性能较好，适合于企业级的开发。但是不利于做二次开发和维护。
ActiveMQ:
历史悠久的 Apache 开源项目。已经在很多产品中得到应用，实现了 JMS1.1 规范，可以和 springjms 轻松融合，实现了多种协议，支持持久化到数据库，对队列数较多的情况支持不好。
RocketMQ:
阿里巴巴的 MQ 中间件，由 java 语言开发，性能非常好，能够撑住双十一的大流量，而且使用起来 很简单。
Kafka:
Kafka 是 Apache 下的一个子项目，是一个高性能跨语言分布式Publish/Subscribe 消息队列系统， 相对于 ActiveMQ 是一个非常轻量级的消息系统，除了性能非常好之外，还是一个工作良好的分布式系统。

RocketMQ 的架构及概念

Broker(邮递员):
Broker 是 RocketMQ 的核心，负责消息的接收，存储，投递等功能.
NameServer(邮局):
消息队列的协调者，Broker 向它注册路由信息，同时Producer 和 Consumer 向其获取路由信息
Producer(寄件人):
消息的生产者，需要从 NameServer 获取 Broker 信息，然后与 Broker 建立连接，向 Broker 发送消 息
Consumer(收件人):
消息的消费者，需要从 NameServer 获取 Broker 信息，然后与 Broker 建立连接，从 Broker 获取消息
Topic(地区):
用来区分不同类型的消息，发送和接收消息前都需要先创建Topic，针对 Topic 来发送和接收消息
Message Queue(邮件):
为了提高性能和吞吐量，引入了 Message Queue，一个 Topic 可以设置一个或多个 Message Queue，这样消息就可以并行往各个Message Queue 发送消息，消费者也可以并行的从多个 Message Queue 读取消息 Message Message 是消息的载体。
Producer Group 生产者组:
简单来说就是多个发送同一类消息的生产者称之为一个生产者组。
Consumer Group 消费者组:
消费同一类消息的多个 consumer 实例组成一个消费者组。

发送不同类型的消息

可靠同步发送:
同步发送是指消息发送方发出数据后，会在收到接收方发回响应之后才发下一个数据包的通讯方 式。 此种方式应用场景非常广泛，例如重要通知邮件、报名短信通知、营销短信系统等。
可靠异步发送:
异步发送是指发送方发出数据后，不等接收方发回响应，接着发送下个数据包的通讯方式。发送 方通过回调接口接收服务器响应，并对响应结果进行处理。 异步发送一般用于链路耗时较长，对 RT 响应时间较为敏感的业务场景，例如用户视频上传后通知 启动转码服务，转码完成后通知推送转码结果等。
单向发送:
单向发送是指发送方只负责发送消息，不等待服务器回应且没有回调函数触发，即只发送请求不 等待应答。 适用于某些耗时非常短，但对可靠性要求并不高的场景，例如日志收集。

这篇关于消息队列——RocketMQ的文章就介绍到这儿，希望我们推荐的文章对编程师们有所帮助！

---