这篇文章将为大家详细讲解有关RocketMQ中Client端架构是怎么样的，小编觉得挺实用的，因此分享给大家做个参考，希望大家阅读完这篇文章后可以有所收获。
RocketMQ的producer/consumer相关功能都由client包提供，client包的底层功能提供了对网络通信、topic路由信息获取等能力的封装。client核心类如下图：
NettyRemotingClient类封装了基础的网络通讯能力，向外提供了三种不同的通讯方式：
同步调用invokeSync，调用方会阻塞一直等到响应返回或超时
异步调用invokeAsync，调用方立即返回，当获得响应结果后在一个线程池中调用callback
单向调用invokeOneway，发送请求后不关心response
MQClientAPIImpl类在RemotingClient的基础上，封装了rocketmq client端所有用到的request command组装以及reponse解析逻辑。
MQClientInstance是整个rocketmq client端的中枢，对于同一个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端架构是怎么样的”这篇文章就分享到这里了，希望以上内容可以对大家有一定的帮助，使各位可以学到更多知识，如果觉得文章不错，请把它分享出去让更多的人看到。
免责声明：本站发布的内容（图片、视频和文字）以原创、转载和分享为主，文章观点不代表本网站立场，如果涉及侵权请联系站长邮箱：is@yisu.com进行举报，并提供相关证据，一经查实，将立刻删除涉嫌侵权内容。
