阿里云文档 2025-10-27

RocketMQ消费者的原理架构

本文介绍云消息队列 RocketMQ 版中消费者(Consumer)的定义、模型关系、内部属性、行为约束、版本兼容性及使用建议。

阿里云文档 2025-06-05

Consumer如何否定应答消息并使其重入队列

您可以通过basicReject或basicNack方法否定应答消息,使消息重入队列,从而是其他Consumer可以消费消息。

阿里云文档 2025-06-05

怎样让Consumer不立即消费消息并使消息重入队列

您可以通过basicReject或basicNack方法否定应答消息,使消息重入队列,从而是其他Consumer可以消费消息。

问答 2023-04-06 来自:开发者社区

RocketMQ实例支持多少个 Consumer Gruop?

RocketMQ单实例支持1000个 Consumer Gruop, 如果我要支持5000个Consumer Gruop是不是要买5个实例? 这5个实例可以看作是一个整体5000么? 还是5个单独的1000?

文章 2022-02-18 来自:开发者社区

从入门到入土(八)RocketMQ的Consumer是如何做的负载均衡的

一、问题描述面试官:RocketMQ的Consumer是如何做的负载均衡?比如:5个Consumer进程同时消费一个Topic,这个Topic只有4个queue会出现啥情况?反之Consumer数量小于queue的数据是啥情况?应聘者:一脸懵逼。二、源码剖析1、RebalancePushImplpublic class RebalancePushImpl extends RebalanceImp....

文章 2022-01-05 来自:开发者社区

RocketMQ源码解析:手把手教老婆看懂consumer接收到的MessageExt

RocketMQ使用教程相关系列 目录目录源代码说明MessageExt的源码解析继承于Message,Message源码解析喝点毒鸡汤源代码说明MessageExt位于此包下:package org.apache.rocketmq.common.message;MessageExt的源码解析参数说明在代码里public class MessageExt extends Message { ...

RocketMQ源码解析:手把手教老婆看懂consumer接收到的MessageExt
问答 2021-11-11 来自:开发者社区

RocketMQ-Spring 中如何实现RocketMQ Lite Pull Consumer?

RocketMQ-Spring 中如何实现RocketMQ Lite Pull Consumer?

问答 2020-12-13 来自:开发者社区

Rocketmq 可否出现多个Consumer实例并且每个实例的GroupId不同?

一个应用中,有多个消费实例,消费不同的类型的业务数据。

问答 2020-07-21 来自:开发者社区

RocketMQ consumer not OnLine,消费者无法消费MQ消息

MQ控制台页面Exception: CODE:206 DESC:Not found the consumer group consume stats, because return offset table is empty, maybe the consumer not consume any message ,在之前是可以正常消费。在一段时间后就不可以消费了。

问答 2019-11-27 来自:开发者社区

rocketmq consumer使用的问题

使用com.aliyun.openservices.ons.api.ONSFactory创建consumer时,指定 properties.put(PropertyKeyConst.ConsumeThreadNums, 4); 但实际的线程数是68。这是为什么? 线程数都与什么有关?

本页面内关键词为智能算法引擎基于机器学习所生成,如有任何问题,可在页面下方点击"联系我们"与我们沟通。