AI
推荐
模板社区
专题
登录
免费注册
首页
流程图
详情
RocketMQ-Consumer消费流程
2019-09-23 18:25:59
0
举报
分享方式
仅支持查看
RocketMQ-Consumer消费流程
RocketMQ-Consumer
模版推荐
作者其他创作
大纲/内容
org.apache.rocketmq.client.impl.consumer.DefaultMQPushConsumerImpl#pullMessagepullMessage(final PullRequest pullRequest)
org.apache.rocketmq.client.impl.consumer.PullMessageService线程死循环
拉取回调中执行ConsumeMessageConcurrentlyService#submitConsumeRequest
将消息封装成任务放入线程池，run方法中会执行绑定的监听方法，如果返回成功，则将Consumer端维护的偏移量加1，每隔5s向Broker同步一次，
消方息处理：当设置的监听方法返回成功：当前队列偏移量加1返回失败、NULL、抛异常 都是按失败处理，失败：就会把消息发给Broker ，topic为%RETRY%+consumergroup同时偏移量加1，如果在处理失败 就再发送给Broker，16次后 消息会被发送到死信队列 （需要人工干预）如果给Broker 发送消息失败：则 会定时在5秒后重新消费该消息偏移量也不会改变
consumeExecutor核心线程：20最大线程：64超时时间：1分钟队列：LinkedBlockingQueue无界队列
Consumer端消息的入口NettyClientHandler#channelRead0
PullRequest 包括了消息及消息的队列信息
收藏
立即使用
Eureka 注册发现
收藏
立即使用
事务传播性
收藏
立即使用
RocketMQ-Consumer消费流程
收藏
立即使用
CyclicBarrier原理
dishuipinganye
职业：暂无
去主页
Collect
Get Started
RocketMQ Consumer消费失败重试流程
Collect
Get Started
非消费类券使用流程
Collect
Get Started
rocketmq源码(八)——推模式Consumer消费消息
Collect
Get Started
Consumer and Industrial Marketing Channels
评论
0
条评论
下一页
Document
