RocketMQ中Client端架构是怎么样的

这篇文章将为大家详细讲解有关RocketMQ中Client端架构是怎么样的，小编觉得挺实用的，因此分享给大家做个参考，希望大家阅读完这篇文章后可以有所收获。

RocketMQ的producer/consumer相关功能都由client包提供，client包的底层功能提供了对网络通信、topic路由信息获取等能力的封装。client核心类如下图：

1. 网络通讯NettyRemotingClient

NettyRemotingClient类封装了基础的网络通讯能力，向外提供了三种不同的通讯方式：

• 同步调用invokeSync，调用方会阻塞一直等到响应返回或超时

• 异步调用invokeAsync，调用方立即返回，当获得响应结果后在一个线程池中调用callback

• 单向调用invokeOneway，发送请求后不关心response

2. 请求/响应Command封装及解析

MQClientAPIImpl类在RemotingClient的基础上，封装了rocketmq client端所有用到的request command组装以及reponse解析逻辑。

3. client端中枢MQClientInstance

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端架构是怎么样的”这篇文章就分享到这里了，希望以上内容可以对大家有一定的帮助，使各位可以学到更多知识，如果觉得文章不错，请把它分享出去让更多的人看到。