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