消息队列RocketMQ版是阿里云基于Apache RocketMQ构建的低延迟、高并发、高可用、高可靠的分布式消息中间件。

看过我之前几篇文章的应该都大概队消息队列有个概念了，都明白了，那这个消息从何而来呢?

所谓黄河之水天上来，大自然间每一个事物都不是平白无故来的吧?????怎么来的，????它母亲生产的;香奈儿????怎么来的，机器加原料生产的;就连平时吃的大米，也是有出处的;咱们是怎么来的，咱们当然是伟大的母亲生产下来的了

顺便感谢一下伟大的母亲，周日记得给她打个电话哦

下面进入主题，这是分割线

消息队列RocketMQ版既可为分布式应用系统提供异步解耦和削峰填谷的能力，同时也具备互联网应用所需的海量消息堆积、高吞吐、可靠重试等特性。下面列举了一些特点

• 消息查询：消息队列RocketMQ版提供了三种消息查询的方式，分别是按Message ID、Message Key以及Topic查询
• 查询消息轨迹：通过消息轨迹，能清晰定位消息从生产者发出，经由消息队列RocketMQ版服务端，投递给消息消费者的完整链路，方便定位排查问题
• 集群消费和广播消费：当使用集群消费模式时，消息队列RocketMQ版认为任意一条消息只需要被消费者集群内的任意一个消费者处理即可;当使用广播消费模式时，消息队列RocketMQ版会将每条消息推送给消费者集群内所有注册过的消费者，保证消息至少被每台机器消费一次
• 重置消费位点：根据时间或位点重置消费进度，允许用户进行消息回溯或者丢弃堆积消息
• 死信队列：将无法正常消费的消息储存到特殊的死信队列供后续处理
• 全球信息路由：用于全球不同地域之间的消息同步，保证地域之间的数据一致性

客户端，其实很容易理解了，我们可以把RocketMQ理解成一个消息服务，既然是一个服务，我们就需要调用这个服务，那么调用这个服务的时候，这个消息从哪里来，这个就是要根据业务场景来定了，所以啊，消息的生产者Producer属于一个客户端;消息产生了，总不能一直放着吧，总要有人处理掉这些消息吧，这也是业务决定的，所以消息的消费者consumer也是属于客户端。

下面啊，大鱼就带着大家一起来看看这客户端的用处

生产者Producer

生产者Producer，顾名思义，就是负责生产消息的，此时大家应该脑子有很多问号才对，比如Producer发消息发到哪里了，流程是怎么样的，发的消息都是什么类型的等等这些，这些问题搞懂了的话，Producer这个客户端基本就搞定了

鱼鱼教大家一个小技巧，学习一个东西，先搞懂大体流程，再拆分而细攻之，最后再统筹理解，这样效果会很好，独家秘方

接下来我从消息是如何发送的(负载均衡、容错机制)、消息发给谁和存储到哪里、消息的类型三方面来介绍Producer

1、消息是如何发送的?

首先，消息总不能产生了哪里也不去吧，那产生这个消息就没有任何意义了，所以这个消息总要发送到一个地方去，接力传递，看下面这个图