张申傲
RocketMQ详解(9)——Consumer简介
关注作者
前往小程序,Get
更优
阅读体验!
立即前往
腾讯云
开发者社区
文档
建议反馈
控制台
首页
学习
活动
专区
工具
TVP
最新优惠活动
文章/答案/技术大牛
搜索
搜索
关闭
发布
登录/注册
首页
学习
活动
专区
工具
TVP
最新优惠活动
返回腾讯云官网
张申傲
首页
学习
活动
专区
工具
TVP
最新优惠活动
返回腾讯云官网
社区首页
>
专栏
>
RocketMQ详解(9)——Consumer简介
RocketMQ详解(9)——Consumer简介
张申傲
关注
发布于 2020-09-03 10:56:37
542
0
发布于 2020-09-03 10:56:37
举报
文章被收录于专栏:
漫漫架构路
RocketMQ详解(9)——Consumer简介
一. RocketMQ的消费模式
在RocketMQ中,Consumer分为2类:MQPullConsumer和MQPushConsumer。其本质都是pull模式,即Consumer轮询从Broker拉取消息。
在push方式中,Consumer把轮询的过程封装了。当应用注册MessageListener后,Broker接收到消息时,会自动回调MessageListener的consumeMessage()方法,在Consumer端执行消费。对于应用来说,这个过程好像是消息自动推送过来的。该方式Consumer与Broker建立了长连接。
在pull方式中,需要应用自己实现拉取消息的过程,首先通过消费的Topic拿到MessageQueue集合,遍历MessageQueue集合,然后针对每个MessageQueue批量拉取消息。取完一次后,记录MessageQueue下一次要取的起始offset,取完后再换下一个MessageQueue。该方式Consumer与Broker建立的是短连接。
二. Consumer相关配置参数
consumeFromWhere Consumer启动后,默认从MessageQueue的什么位置开始消费,可以设置为ConsumeFromWhere.CONSUME_FROM_LAST_OFFSET从队尾开始消费或ConsumeFromWhere.CONSUME_FROM_FIRST_OFFSET从队头开始消费。
consumeThreadMin 消费者线程最小数量,默认20
consumeThreadMax 消费者线程最大数量,默认64
pullThresholdForQueue 拉取消息时,本地消息队列缓存的最大消息数量,默认1000
consumeMessageBatchMaxSize 批量消费时,一次最多消费多少条记录,默认1
pullBatchSize 批量拉取消息时,一次最多拉取的消息条数,默认32
pullInterval 消息拉取线程执行拉取消息的时间间隔,默认0
本文参与
腾讯云自媒体同步曝光计划
,分享自作者个人站点/博客。
原始发表:2018/09/13 ,如有侵权请联系
cloudcommunity@tencent.com
删除
前往查看
apache
批量计算
node.js
本文分享自
作者个人站点/博客
前往查看
如有侵权,请联系
cloudcommunity@tencent.com
删除。
本文参与
腾讯云自媒体同步曝光计划
,欢迎热爱写作的你一起参与!
apache
批量计算
node.js
评论
登录
后参与评论
0 条评论
热度
最新
推荐阅读
LV.
文章
0
获赞
0
目录
RocketMQ详解(9)——Consumer简介
一. RocketMQ的消费模式
二. Consumer相关配置参数
相关产品与服务
批量计算
批量计算(BatchCompute,Batch)是为有大数据计算业务的企业、科研单位等提供高性价比且易用的计算服务。批量计算 Batch 可以根据用户提供的批处理规模,智能地管理作业和调动其所需的最佳资源。有了 Batch 的帮助,您可以将精力集中在如何分析和处理数据结果上。
产品介绍
领券
问题归档
专栏文章
快讯文章归档
关键词归档
开发者手册归档
开发者手册 Section 归档
0
0
0
推荐