RocketMq系列之topic路由信息更新(二)

前言 本文的主要是为了介绍,在生产者或者消费者启动的时候,须要实例化MqClientInstance,做为负责和borker通讯的实例, 在这个里面初始化了不少定时任务,心跳,nameServer地址更新, topic路由信息更新java 源码入口 org.apache.rocketmq.client.impl.factory.MQClientInstanceweb public void sta
相关文章
相关标签/搜索