美文网首页
rocketmq 消息发送源码分析总结

rocketmq 消息发送源码分析总结

作者: 大强斌 | 来源:发表于2020-04-06 17:46 被阅读0次

    DefaultMQProduce

    主要作用

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

        消息发送消息流程图 

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

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

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

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

    相关文章

      网友评论

          本文标题:rocketmq 消息发送源码分析总结

          本文链接:https://www.haomeiwen.com/subject/lkibphtx.html