这篇文章主要介绍了RocketMQ中如何实现producer消息发送，具有一定借鉴价值，感兴趣的朋友可以参考下，希望大家阅读完这篇文章之后大有收获，下面让小编带着大家一起了解一下。RocketMQ中一个topic可以分布在多个broker上，每个broker上又可以包含多个message queue。每个message具体发送到哪个broker的哪个message queue中，这个决策过程是在client端完成的。client会从nameserver订阅topic的路由信息，按照一定的负载均衡算法为每个message选择出一个queue，并完成投递。producer的消息投递过程大体如下图：producer的投递出错重试分为两种情况，同步出错重试（sync）以及异步出错重试（async）。同步发送出错重试是在DefaultMQProducerImpl.sendDefaultImpl中完成：异步发送的出错重试则是在更底层的MQClientAPIImpl.sendMessageAsync里实现：在异常处理的onExceptionImpl方法中会再次触发sendMessageAsync方法：消息的负载均衡是通过MQFaultStrategy.selectOneMessageQueue方法来实现的：感谢你 香港云主机能够认真阅读完这篇文章，希望小编分享的“RocketMQ中如何实现producer消息发送”这篇文章对大家有帮助，同时也希望大家多多支持开发云，关注开发云行业资讯频道，更多相关知识等着你来学习!
相关推荐: 服务器的透明代理、匿名代理、混淆代理、高匿代理哪些区别
这篇文章主要讲解了“服务器的透明代理、匿名代理、混淆代理、高匿代理哪些区别”，文中的讲解内容简单清晰，易于学习与理解，下面请大家跟着小编的思路慢慢深入，一起来研究和学习“服务器的透明代理、匿名代理、混淆代理、高匿代理哪些区别”吧！这4种代理，主要是在代理服务器…
免责声明：本站发布的图片视频文字，以转载和分享为主，文章观点不代表本站立场，本站不承担相关法律责任；如果涉及侵权请联系邮箱：360163164@qq.com举报，并提供相关证据，经查实将立刻删除涉嫌侵权内容。
微信扫一扫 
