RocketMQ——Consumer篇:PUSH模式下的消息拉取(DefaultMQPushConsumer)

DefaultMQPushConsumerImpl中各個對象的主要功能以下:java RebalancePushImpl:主要負責決定,當前的consumer應該從哪些Queue中消費消息;web 1)PullAPIWrapper:長鏈接,負責從broker處拉取消息,而後利用ConsumeMessageService回調用戶的Listener執行消息消費邏輯;api 2)ConsumeMessa
相關文章
相關標籤/搜索