rocketmq 消息发送源码分析总结

DefaultMQProduce

主要作用

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

    消息发送消息流程图 


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

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

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

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

©著作权归作者所有,转载或内容合作请联系作者
平台声明：文章内容（如有图片或视频亦包括在内）由作者上传并发布，文章内容仅代表作者本人观点，简书系信息发布平台，仅提供信息存储服务。

推荐阅读更多精彩内容