rocketmq 消息发送源码分析总结
2020-04-06 本文已影响0人
大强斌
DefaultMQProduce
主要作用
1发送消息,异步,同步,和OneWay发送。
消息发送消息流程图
2 同步消息,异步消息,和oneway 实现上的区别
1 同步消息实现原理:利用netty发送完后,利用CountDownLatch 锁阻塞线程,等待服务响应的返回。超时后释放。
2异步,利用netty的异步发送并注册回调函数,主线程立马返回,当消息响应返回后。从缓存获取之前发送消息注册的方法,立刻执行。
3oneway 。直列利用netty异步发送。