rmq消费者-推模式

启动流程

• 创建消费偏移量缓冲区offsetStore，集群消费模式实现类是RemoteBrokerOffsetStore，广播消费是LocalFileOffsetStore
• 创建单例MQClientInstance并启动：创建时(MQClientManager#getOrCreateMQClientInstance)，MQClientInstance对应一个clientId，ip+pid+时间戳（ClientConfig#changeInstanceNameToPID）。通过它的registerConsumer方法向其中注册消费者到consumerTable，其中key是消费组。MQClientInstance启动时，会启动RebalanceService和PullMessageService
• 根据主题获取读队列数：执行MQClientInstance.updateTopicSubscribeInfoWhenSubscriptionChanged，从nameserver获取主题对应的TopicRouteData，1、获取每个brokerName对应的BrokerDatas，放入MQClientInstance#brokerAddrTable。2、获取每个brokerName对应的队列配置queueDatas，根据队列配置中的读队列创建MessageQueue
  集合(MQClientInstance#topicRouteData2TopicSubscribeInfo)，最终放入RebalanceImpl#topicSubscribeInfoTable。

public