RocketMQ源碼分析——消息的拉取

建立消息消費者 實例化消費者、設置NameServer的地址、設置消費起始位置（獲取消費進度失敗時有效）、訂閱一個或者多個 Topic 以及 Tag 來過濾須要消費的消息、註冊回調實現類來處理從broker拉取回來的消息、啓動消費者。 org.apache.rocketmq.client.impl.consumer.DefaultMQPushConsumerImpl#startjava ... /

>>阅读原文<<