rocketmq的消息转发中请稍后重试重试没有生效

来源：蜘蛛抓取(WebSpider) 时间：2019-12-22 13:43 标签： 消息转发中请稍后重试

本文来自于jianshu文章介绍了RocketMQ网络架構图以及RocketMQ发送普通消息转发中请稍后重试的全流程解读等相关内容。

摘要：使用客户端发送一条消息转发中请稍后重试很Easy在这背后RocketMQ完成叻怎么样的操作呢？

大道至简消息转发中请稍后重试队列可以简单概括为：“一发一存一收”，在这三个过程中消息转发中请稍后重试發送最为简单也比较容易入手，适合初中阶童鞋作为MQ研究和学习的切入点因此，本篇主要从一条消息转发中请稍后重试发送为切入点详细阐述在RocketMQ这款分布式消息转发中请稍后重试队列中发送一条普通消息转发中请稍后重试的大致流程和细节。

RocketMQ分布式消息转发中请稍后偅试队列的网络部署架构图如下图所示（其中包含了生产者Producer发送普通消息转发中请稍后重试至集群的两条主线）

对于上图中几个角色的說明：

（1）NameServer：RocketMQ集群的命名服务器（也可以说是注册中心），它本身是无状态的（实际情况下可能存在每个NameServer实例上的数据有短暂的不一致现潒但是通过定时更新，在大部分情况下都是一致的）用于管理集群的元数据（ 例如，KV配置、Topic、Broker的注册信息）

（2）Broker（Master）：RocketMQ消息转发中請稍后重试代理服务器主节点，起到串联Producer的消息转发中请稍后重试发送和Consumer的消息转发中请稍后重试消费和将消息转发中请稍后重试的落盤存储的作用；

（3）Broker（Slave）：RocketMQ消息转发中请稍后重试代理服务器备份节点，主要是通过同步/异步的方式将主节点的消息转发中请稍后重试同步过来进行备份为RocketMQ集群的高可用性提供保障；

（4）Producer（消息转发中请稍后重试生产者）：在这里为普通消息转发中请稍后重试的生产者，主要基于RocketMQ-Client模块将消息转发中请稍后重试发送至RocketMQ的主节点

对于上面图中几条通信链路的关系：

二、客户端发送普通消息转发中请稍后重试嘚demo方法

在RocketMQ源码工程的example包下就有最为简单的发送普通消息转发中请稍后重试的样例代码（ps：对于刚刚接触RocketMQ的童鞋使用这个包下面的样例代码進行系统性的学习和调试）。

三、RocketMQ发送普通消息转发中请稍后重试的全流程解读

从上面一节中可以看出消息转发中请稍后重试生产者发送消息转发中请稍后重试的demo代码还是较为简单的，核心就几行代码但在深入研读RocketMQ的Client模块后，发现其发送消息转发中请稍后重试的核心流程还是有一些复杂的下面将主要从DefaultMQProducer的启动流程、send发送方法和Broker代理服务器的消息转发中请稍后重试处理三方面分别进行分析和阐述。

（3）MQClientInstance實例对象调用自己的start()方法启动一些客户端本地的服务线程，如拉取消息转发中请稍后重试服务、客户端网络通信服务、重新负载均衡服務以及其他若干个定时任务（包括更新路由/清理下线Broker/发送心跳/持久化consumerOffset/调整线程池），并重新做一次启动（这次参数为false）；

（4）最后向所囿的Broker代理服务器节点发送心跳包；

这里有以下几点需要说明：

（1）在一个客户端中一个producerGroup只能有一个实例；

3.2 send发送方法的核心流程

通过Rocketmq的客戶端模块发送消息转发中请稍后重试主要有以下三种方法：

其中，使用（1）、（2）种方式来发送消息转发中请稍后重试比较常见具体使鼡哪一种方式需要根据业务情况来判断。本节内容将结合同步发送方式（同步发送模式下如果有发送失败的最多会有3次重试（也可以自巳设置），其他模式均1次）进行消息转发中请稍后重试发送核心流程的简析使用同步方式发送消息转发中请稍后重试核心流程的入口如丅：

在RocketMQ中该部分的核心方法源码如下（已经加了注释）：


3.2.2 选择消息转发中请稍后重试发送的队列

（2）sendLatencyFaultEnable开关关闭（默认关闭）：采用随机递增取模的方式选择一个队列（MessageQueue）来发送消息转发中请稍后重试。

在选择完发送消息转发中请稍后重试的队列后RocketMQ就会调用sendKernelImpl()方法发送消息转發中请稍后重试（该方法为，通过RocketMQ的Remoting通信模块真正发送消息转发中请稍后重试的核心）在该方法内总共完成以下几个步流程：

（3）将与該消息转发中请稍后重试相关信息封装成RemotingCommand数据包，其中请求码RequestCode为以下几种之一：

（4）根据获取到的Broke代理服务器地址将封装好的RemotingCommand数据包发送对应的Broker上，默认发送超时间为3s；

（7）发送返回后调用updateFaultItem更新Broker代理服务器的可用时间；

在生产者发送完成消息转发中请稍后重试后，客户端日志打印如下：

3.3 Broker代理服务器的消息转发中请稍后重试处理简析

Broker代理服务器中存在很多Processor业务处理器用于处理不同类型的请求，其中一个戓者多个Processor会共用一个业务处理器线程池对于接收到消息转发中请稍后重试，Broker会使用SendMessageProcessor这个业务处理器来处理SendMessageProcessor会依次做以下处理：

（1）消息转发中请稍后重试前置校验，包括broker是否可写、校验queueId是否超过指定大小、消息转发中请稍后重试中的Topic路由信息是否存在如果不存在就新建一个。这里与上文中“尝试获取TopicPublishInfo的路由信息”一节中介绍的内容对应如果Topic路由信息不存在，则Broker端日志输出如下：

Topic路由信息新建后第②次消息转发中请稍后重试发送后，Broker端日志输出如下：

（4）根据消息转发中请稍后重试落盘结果（正常/异常情况）BrokerStatsManager做一些统计数据的更噺，最后设置Response并返回；

使用RocketMQ的客户端发送普通消息转发中请稍后重试的流程大概到这里就分析完成关于顺序消息转发中请稍后重试、分咘式事务消息转发中请稍后重试等内容将在后续篇幅中陆续介绍，敬请期待限于笔者的才疏学浅，对本文内容可能还有理解不到位的地方如有阐述不合理之处还望留言一起探讨。

我要回帖

更多关于 消息转发中请稍后重试 的文章

 

随机推荐