云消息队列 MQ消费者的相关内容

问答 2025-03-18 来自：开发者社区

RocketMQ 5.x，当使用Proxy时消费者无法从slave节点拉取消息

RocketMQ版本5.3，部署采用主从异步复制，Proxy独立部署。当主节点宕机后，使用Proxy无法从slave节点拉取消息，而使用Remoting协议+Nameserver可以从slave节点拉取消息。

阿里云文档 2025-02-08

创建Group ID用于消费者订阅消息

Group表示一类Producer或Consumer，这类Producer或Consumer通常生产或消费同一类消息，且消息发布或订阅的逻辑一致。使用云消息队列 RocketMQ 版进行消息收发，您需要创建Group ID用于标识同一类生产者实例或者同一类消费者实例。本文介绍如何在云消息队列 RocketMQ 版控制台上创建、删除和查询Group。

阿里云文档 2024-11-27

查询ROCKETMQ5.0系列的消费者分组

DATASOURCE::ROCKETMQ5::ConsumerGroups类型用于查询ROCKETMQ5.0系列的消费者分组。

问答 2024-10-12 来自：开发者社区

rocketmq5.3开通了Prometheus但没有上班生产者和消费者的Metrics 指标

使用k8s部署的rocketmq5.3，proxy和broker是分别独立部署的。通过配置broker.conf中将metricsExporterType 设置为 PROM。服务端 Metrics 指标像rocketmq_messages_in_total，rocketmq_messages_out_total等指标在prometheus中都能查到，但生产者 Metrics 指标（rocketm....

问答 2024-09-18 来自：开发者社区

从rocketmq-dashboard上看队列的数量和消费者终端的数量不一致，请问是什么问题

因为发现有一些消息能收到有一些不能，但是重启broker也都会被消费，观察dashboard发现如果发送到队列2.3就收不到，01就能正常消费，只有一个topic和一个tag，这个是什么原因？怎么处理呢？

阿里云文档 2024-08-28

消费者负载不均衡的原因和解决方法

在云消息队列 RabbitMQ 版中，消费者倾斜（Consumer Skew）指的是一个队列中的消息处理负载不均衡，导致部分消费者处理大量消息而其他消费者相对闲置的情况，包括消费者性能瓶颈、资源利用率不均等。本文将介绍这种不均衡产生的原因和解决方法。

问答 2024-08-28 来自：开发者社区

RocketMQ dashboard 消费者中的订阅组为什么无法删除？

问答 2024-08-28 来自：开发者社区

RocketMQ既然不提供重试策略又如何能保证消息至少被每一个组的消费者消费一次呢？失败了怎么办？

RocketMQ既然不提供重试策略又如何能保证消息至少被每一个组的消费者消费一次呢？失败了怎么办？超时了怎么办？错误了怎么办？消息如果网络原因丢失了怎么办？

文章 2024-08-16 来自：开发者社区

我服了，RocketMQ消费者负载均衡内核是这样设计的

前言上文分析了RocketMQ消费者消费消息核心原理，其中在消费者端，有一个重量级的组件：负载均衡组件, 他负责相对均匀的给消费者分配需要拉取的队列信息。我们此时可能会有以下问题: 1、一个Topic下可能会有很多逻辑队列，而消费者又有多个，这样不同的消费者到底消费哪个队列呢？ 2、如果消费者或者队列扩缩容，Topic下的队列又该分配给谁呢？这些时候负载均衡策略就有他的用武之地了...

文章 2024-08-16 来自：开发者社区

RocketMQ消费者消费消息核心原理（含长轮询机制）

前言在消息系统中，消费者消费消息有拉和推消息两种实现方式，拉消息是消费者主动向消息服务器发送拉消息请求，消息服务器将消息返回给消费者，而推消息是消息服务器主动向消费者推送消息的形式，这两种消息消费实现各有各的优势和劣势。在RocketMQ中，有两种消费者客户端,一种是Push模式消费者, 一种是Pull模式消费者，这两个其实都是表现，在RocketMQ底层实现中采用长轮询的机制来实现消息...