RocketMQ——消费过程

PullMessageService负责拉取消息,从远端服务器拉取消息后存储到ProcessQueue中,而后调用ConsumeMessageService#submitConsumeRequest 方法进行消费,适应小城池来消费消息,确保消息拉取与消息消费的解耦。apache   1.jpg 消息消费 ConsumeMessageConcurrentlyService#submitConsume
相关文章
相关标签/搜索