RocketMQ——Consumer篇:PULL消费模式下的调度消费服务

与PUSH模式相比,PULL模式须要应用层不间断地进行拉取消息而后再执行消费处理,提升了应用层的编码复杂度,为了Pull方式的编程复杂度,RocketMQ提供了调度消费服务(MQPullConsumerScheduleService),在topic的订阅发送变化(初次订阅或距上次拉取消息超时)就触发PULL方式拉取消息。web 1 应用层使用方式 该类是PULL模式下面的调度服务,当Rebalan
相关文章
相关标签/搜索