AliMQ(RockertMQ)源碼(五)Consumer的發佈訂閱和start()方法

1、發佈訂閱 發佈訂閱是調用了ComsumerImpl的subscribe方法。java this.subscribeTable.put(topic, listener); 是將topic和listener設置到subscribeTable中，可見，同一個consumer只能設置一個topic對應一個listener。 將tag放入到了ConsumerImpl的rebalanceImpl的subs

>>阅读原文<<