1RocketMQ使用相关问题1.1保证消息的可用性/可靠性/不丢失消息可能在哪些阶段丢失呢？可能会在这三个阶段发生丢失：生产阶段、存储阶段、消费阶段所以要从这三个阶段考虑：image.png1.1.1生产在生产阶段，主要通过请求确认机制，来保证消息的可靠传递。同步发送的时候，要注意处理响应结果和异常。如果返回响应OK，表示消息成功发送到了Broker，如果响应失败，或者发生其它异常，都应该重试。异步发送的时候，应该在回调方法里检查，如果发送失败或者异常，都应该进行重试。如果发生超时的情况，也可以通过查询日志的API，来检查是否在Broker存储成功。1.1.2存储存储阶段，可以通过配置可靠性

1RocketMQ使用相关问题1.1保证消息的可用性/可靠性/不丢失消息可能在哪些阶段丢失呢？可能会在这三个阶段发生丢失：生产阶段、存储阶段、消费阶段所以要从这三个阶段考虑：image.png1.1.1生产在生产阶段，主要通过请求确认机制，来保证消息的可靠传递。同步发送的时候，要注意处理响应结果和异常。如果返回响应OK，表示消息成功发送到了Broker，如果响应失败，或者发生其它异常，都应该重试。异步发送的时候，应该在回调方法里检查，如果发送失败或者异常，都应该进行重试。如果发生超时的情况，也可以通过查询日志的API，来检查是否在Broker存储成功。1.1.2存储存储阶段，可以通过配置可靠性

在基于了解或掌握其他同类MQ的基础知识上，怎么比较快速的掌握kafka的核心设计，确保在使用的过程中做到心中有数，做到知其然并知其所以然？本篇文章主要是笔者在已有的rmq的基础上学习kafka的思路以及过程的总结。ps、rmq指RocketMQps、文章写着写着发现有点长，应该挺乱了……ps、因为是学习笔记，所以就这样吧，随便看看……疑问带着问题去学习新的技能，也许会更贴近自己原有的知识储备，也能更好的把新知识纳入自己原有的知识体系并加以补充或者延展，形成更完整的知识脉络。基于原有的rmq的知识体系，在提前梳理了几个相关的，并且浅显的问题，主要是两个方面的内容，一类是MQ模型中生产者客户端的设

在基于了解或掌握其他同类MQ的基础知识上，怎么比较快速的掌握kafka的核心设计，确保在使用的过程中做到心中有数，做到知其然并知其所以然？本篇文章主要是笔者在已有的rmq的基础上学习kafka的思路以及过程的总结。ps、rmq指RocketMQps、文章写着写着发现有点长，应该挺乱了……ps、因为是学习笔记，所以就这样吧，随便看看……疑问带着问题去学习新的技能，也许会更贴近自己原有的知识储备，也能更好的把新知识纳入自己原有的知识体系并加以补充或者延展，形成更完整的知识脉络。基于原有的rmq的知识体系，在提前梳理了几个相关的，并且浅显的问题，主要是两个方面的内容，一类是MQ模型中生产者客户端的设

一、三大应用场景（优点）解耦、异步、削峰解耦：只需要将消息写入消息队列，需要消息的去消息队列中订阅就好异步：一些非必要的逻辑可以采用异步来完成，从而提升响应速度削峰：某个时间段并发量特别大的时候可以将消息发送到消息队列中，然后从消息队列中慢慢拉取进行消费解耦传统模式：image.png传统模式缺点：系统间耦合性太强，如上图所示，系统A在代码中直接调用系统B和系统C，如果将来系统D要接入，系统A还要修改代码，过于麻烦！image.png中间件模式优点：将消息写入消息队列，要消息的系统自己从消息队列中订阅，从而系统A不再需要做任何修改异步传统模式：image.png一些非必要的业务逻辑以同步的方式

一、三大应用场景（优点）解耦、异步、削峰解耦：只需要将消息写入消息队列，需要消息的去消息队列中订阅就好异步：一些非必要的逻辑可以采用异步来完成，从而提升响应速度削峰：某个时间段并发量特别大的时候可以将消息发送到消息队列中，然后从消息队列中慢慢拉取进行消费解耦传统模式：image.png传统模式缺点：系统间耦合性太强，如上图所示，系统A在代码中直接调用系统B和系统C，如果将来系统D要接入，系统A还要修改代码，过于麻烦！image.png中间件模式优点：将消息写入消息队列，要消息的系统自己从消息队列中订阅，从而系统A不再需要做任何修改异步传统模式：image.png一些非必要的业务逻辑以同步的方式

大家好，我是Leo。今天聊一下RocketMQ消息发送，重试机制，故障延迟机制，获取路由机制，消息队列的选择消息发送关系图首先放一下BrokerCluster，Broker，Topic，Queue的关系图。因为下文主要会沿着这四块进行梳理发送的三种方式消息发送的三种方式同步：发送者向MQ发送一条消息后，一直等待服务器返回成功才继续下一个。异步：发送者向MQ发送一条消息后，通过回调函数调用消息发布函数继续发送，主线程立即返回。单向：发送者向MQ发送一条消息后，直接返回，不等待消息服务器的结果，也不注册函数，简单来说，就是只管发。其他啥也不管。源码packageorg.apache.rocketm

大家好，我是Leo。今天聊一下RocketMQ消息发送，重试机制，故障延迟机制，获取路由机制，消息队列的选择消息发送关系图首先放一下BrokerCluster，Broker，Topic，Queue的关系图。因为下文主要会沿着这四块进行梳理发送的三种方式消息发送的三种方式同步：发送者向MQ发送一条消息后，一直等待服务器返回成功才继续下一个。异步：发送者向MQ发送一条消息后，通过回调函数调用消息发布函数继续发送，主线程立即返回。单向：发送者向MQ发送一条消息后，直接返回，不等待消息服务器的结果，也不注册函数，简单来说，就是只管发。其他啥也不管。源码packageorg.apache.rocketm