RocketMQ中Client端架构是怎么样的

这篇文章将为大家详细讲解有关RocketMQ中Client端架构是怎么样的,小编觉得挺实用的,因此分享给大家做个参考,希望大家阅读完这篇文章后可以有所收获。RocketMQ的producer/consumer相关功能都由client包提供,client包的底层功能提供了对网络通信、topic路由信息获取等能力的封装。client核心类如下图:NettyRemotingClient类封装了基础的网络通讯能力,向外提供了三种不同的通讯方式:同步调用invokeSync,调用方会阻塞一直等到响应返回或超时异步调用invokeAsync,调用方立即返回,当获得响应结果后在一个线程池中调用callback单向调用invokeOneway,发送请求后不关心responseMQClientAPIImpl类在RemotingClient的基础上,封装了rocketmq client端所有用到的request command组装以及reponse解析逻辑。MQClientInstance是整个rocketmq cli 香港云主机ent端的中枢,对于同一个client(clientid相同)只维护一个MQClientInstance实例。它了维护该client上启动的所有producer、consumer的信息,以及涉及到的topic的路由信息。MQClientInstance会启动后台任务,周期性地执行从nameserver更新topic的路由信息,向broker发送心跳,剔除失联的broker,持久化消费者offset等工作。MQClientInstance还会启动PullMessageService,用于调用consumer从broker上拉取message消费;启动RebalanceService,周期性重新分配topic下的message queue和consumer之间的订阅关系。关于“RocketMQ中Client端架构是怎么样的”这篇文章就分享到这里了,希望以上内容可以对大家有一定的帮助,使各位可以学到更多知识,如果觉得文章不错,请把它分享出去让更多的人看到。

相关推荐: 怎么使用GlidedSky爬虫js加密

这篇文章主要介绍“怎么使用GlidedSky爬虫js加密”,在日常操作中,相信很多人在怎么使用GlidedSky爬虫js加密问题上存在疑惑,小编查阅了各式资料,整理出简单好用的操作方法,希望对大家解答”怎么使用GlidedSky爬虫js加密”的疑惑有所帮助!接…

免责声明:本站发布的图片视频文字,以转载和分享为主,文章观点不代表本站立场,本站不承担相关法律责任;如果涉及侵权请联系邮箱:360163164@qq.com举报,并提供相关证据,经查实将立刻删除涉嫌侵权内容。

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

相关推荐

发表评论

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