RocketMQ中如何实现producer消息发送

这篇文章主要介绍了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举报,并提供相关证据,经查实将立刻删除涉嫌侵权内容。

(0)
打赏 微信扫一扫 微信扫一扫
上一篇 09/23 19:05
下一篇 09/23 19:05

相关推荐

发表评论

您的电子邮箱地址不会被公开。