现在主流的消息队列产品都提供了非常完善的消息可靠性保证机制，可以做到在消息传递的过程中，即使发生网络中断或者硬件故障，也能确保消息的可靠传递、不丢消息。绝大部分丢消息的原因都是由于开发者不熟悉消息队列，没有正确使用和配置消息队列导致的。检测消息丢失的方法用消息队列最尴尬的情况不是丢消息，而是丢了消息还不知道。因此，我们需要设计一套机制来监控消息是否有丢失。根据项目的成熟程度，一般有两种方式来检测：如果项目基础设施比较完善，那么可以使用分布式链路追踪系统来追踪每一条消息。如果项目初期，系统刚上线，那么可以利用消息队列的有序性来检测是否有消息丢失。我们可以在Producer端发出的每一条消息附加一

现在主流的消息队列产品都提供了非常完善的消息可靠性保证机制，可以做到在消息传递的过程中，即使发生网络中断或者硬件故障，也能确保消息的可靠传递、不丢消息。绝大部分丢消息的原因都是由于开发者不熟悉消息队列，没有正确使用和配置消息队列导致的。检测消息丢失的方法用消息队列最尴尬的情况不是丢消息，而是丢了消息还不知道。因此，我们需要设计一套机制来监控消息是否有丢失。根据项目的成熟程度，一般有两种方式来检测：如果项目基础设施比较完善，那么可以使用分布式链路追踪系统来追踪每一条消息。如果项目初期，系统刚上线，那么可以利用消息队列的有序性来检测是否有消息丢失。我们可以在Producer端发出的每一条消息附加一

由于篇幅原因，本次的源码分析只限于Producer侧的发送消息的核心逻辑，我会通过流程图、代码注释、文字讲解的方式来对源码进行解释，后续应该会专门开几篇文章来做源码分析。这篇博客聊聊关于RocketMQ相关的东西，主要聊的点有RocketMQ的功能使用、RocketMQ的底层运行原理和部分核心逻辑的源码分析。至于我们为什么要用MQ、使用MQ能够为我们带来哪些好处、MQ在社区有哪些实现、社区的各个MQ的优劣对比等等，我在之前的文章《消息队列杂谈》已经聊过了，如果需要了解的话可以回过头去看看。基础概念Broker首先我们要知道，使用RocketMQ时我们经历了什么。那就是生产者发送一条消息给Roc

由于篇幅原因，本次的源码分析只限于Producer侧的发送消息的核心逻辑，我会通过流程图、代码注释、文字讲解的方式来对源码进行解释，后续应该会专门开几篇文章来做源码分析。这篇博客聊聊关于RocketMQ相关的东西，主要聊的点有RocketMQ的功能使用、RocketMQ的底层运行原理和部分核心逻辑的源码分析。至于我们为什么要用MQ、使用MQ能够为我们带来哪些好处、MQ在社区有哪些实现、社区的各个MQ的优劣对比等等，我在之前的文章《消息队列杂谈》已经聊过了，如果需要了解的话可以回过头去看看。基础概念Broker首先我们要知道，使用RocketMQ时我们经历了什么。那就是生产者发送一条消息给Roc