Coin163

首页 > RocketMQ原理解析-consumer 7.shutdown

RocketMQ原理解析-consumer 7.shutdown

相关标签: rocketmq consumer

2020腾讯云双十一活动,全年最低!!!(领取3500元代金券),
地址https://cloud.tencent.com/act/cps/redirect?redirect=1073

2020阿里云最低价产品入口,含代金券(新老用户有优惠),
入口地址https://www.aliyun.com/minisite/goods

DefaultMQPushConsumerImpl  关闭消费端

         关闭消费线程

         将分配到的Set<MessageQueue>的消费进度保存到broker

利用DefaultMQPushConsumerImpl获取ProcessQueueTable<MessageQueue,ProcessQueue>的keyset的messagequeue去获取

RemoteBrokerOffsetStore.offsetTable<MessageQueue,AutomicLong>Map中的消费进度,

offsetTable中的messagequeue的值,在update的时候如果没有对应的Messagequeue会构建, 但是也会rebalance的时候将没有分配到的messagequeue删除

rebalance会将offsettable中没有分配到messagequeue删除, 但是在从offsettable删除之前会将offset保存到broker

         Unregiser客户端

         pullMessageService关闭

         scheduledExecutorService关闭,关闭一些客户端的起的定时任务

         mqClientApi关闭

         rebalanceService关闭

原文

DefaultMQPushConsumerImpl  关闭消费端          关闭消费线程          将分配到的Set<MessageQueue>的消费进度保存到broker 利用DefaultMQPushConsumerImpl获取ProcessQueueTable<MessageQue

------分隔线----------------------------
相关推荐