RocketMQ——Consumer篇:PULL模式下的消息消費(DefaultMQPullConsumer)

1 應用層的使用方式 在應用層初始化DefaultMQPullConsumer類,而後調用該類的start方法啓動Consumer;接下來的消費步驟以下:web 一、調用DefaultMQPullConsumer.fetchSubscribeMessageQueues(String topic)方法,根據topic獲取對應的MessageQueue(便可被訂閱的隊列),在該方法中最終經過調用MQA
相關文章
相關標籤/搜索