rocketmq 消息发送源码分析总结

2020-04-06  本文已影响0人  大强斌

DefaultMQProduce

主要作用

    1发送消息,异步,同步,和OneWay发送。

    消息发送消息流程图 

2 同步消息,异步消息,和oneway 实现上的区别

1 同步消息实现原理:利用netty发送完后,利用CountDownLatch 锁阻塞线程,等待服务响应的返回。超时后释放。

2异步,利用netty的异步发送并注册回调函数,主线程立马返回,当消息响应返回后。从缓存获取之前发送消息注册的方法,立刻执行。

3oneway 。直列利用netty异步发送。

上一篇下一篇

猜你喜欢

热点阅读