这篇文章将为大家详细讲解有关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加密”的疑惑有所帮助！接…
免责声明：本站发布的图片视频文字，以转载和分享为主，文章观点不代表本站立场，本站不承担相关法律责任；如果涉及侵权请联系邮箱：360163164@qq.com举报，并提供相关证据，经查实将立刻删除涉嫌侵权内容。
微信扫一扫 
