全部产品
Search
文档中心

云消息队列 RabbitMQ 版:其他问题

更新时间:Mar 07, 2026

AliyunAMQPReadOnlyAccess 为什么不支持查询队列消息?

AliyunAMQPReadOnlyAccess 策略只有"amqp:Get*"和"amqp:List*"的权限,可以添加 amqp:BasicGet 自定义权限,用于访问队列中的消息。请参见云消息队列 RabbitMQ 版自定义权限策略参考

{
    "Version": "1",
    "Statement": [
        {
            "Action": [
                "amqp:BasicGet"
            ],
            "Resource": [
                "acs:amqp:*:*:/instances/$instanceId/vhosts/$vhostName/queues/$queueName/messages/*"
            ],
            "Effect": "Allow"
        }
    ]
}

清空队列后控制台为什么仍显示有堆积消息?

清空队列操作默认不会清除延时消息。

QoS 生效机制?

如果存在超时阻塞的情况,建议将 QoS 或 Prefetch Count 设置为 1,避免客户端缓存过多消息同时过期。

什么时候消息会进死信?

如果一条消息没有设置 TTL,该消息进入死信队列仅有两种情况:1. 被 NACK,2. 消费重试次数达到上限。

如何设置消息ID?

请参见如何设置Message ID

死信队列里的消息量为什么会减少?

云消息队列 RabbitMQ 版消息最长保留 3 天。如果消息超过 3 天未被消费,死信队列中的消息量也会随之减少。请参见使用限制

消息保留时长?

云消息队列 RabbitMQ 版成功消费与未成功消费的所有消息的最大保留时长为 3 天。请参见使用限制

RabbitMQ 的网段?

云消息队列 RabbitMQ 版的网段不固定,无法提前获取固定网段信息。

自动删除队列为什么没有生效?

如果消费者未成功订阅队列,调用 channel.close 不会触发队列的自动删除。需要通过 channel.basicConsume 成功订阅消费后,自动删除队列的逻辑才会生效。

存储费用是什么?

云消息队列 RabbitMQ 版的消息保留时长为 3 天,存储费用基于消息体的存储量计算。该存储空间无法手动清理的,只能等待消息过期后自动释放。

清空队列的实际操作是重置消费位点。清空后仍可查看历史消息,因此清空队列后存储空间不会减少。

清空队列是什么?

清空队列的实际操作是重置消费位点(跳过未消费的消息),而不是删除消息。清空后仍可查看历史消息。

Queue 每秒流出消息数取决于什么?

Queue 每秒流出消息数取决于消息量、消费者数量及消费者设置的 QoS。

使用排他队列时需要注意什么?

Spring 框架使用CONNECTION模式时,需要提前在控制台创建 Exchange、Queue 及绑定关系。CONNECTION 模式下不会自动声明和创建这些资源。

如果消息进入队列, 然后重试16次, 那么收费是一次的费用还是16次的费用呢?

仅收取一次费用。后续重新入队再消费不再额外计费,仅对初始推送计费一次。

重入队是指消费失败后,消息重新进入服务端的队列等待消费。服务端有专门的重试队列,会按照一定的时间间隔重新向消费者推送消息。

TPS 上限对应哪个监控?

对应云监控中的实例 API 请求速率峰值。

Connection 连接数可以超过限制吗?

对于 Connection 连接数限制,虽然官方文档中标注为实例级别的限制,但实际是按后台节点维度进行限制,实例级别连接总数可能少量超过限制值。

对于预付费实例,各项配置均不可动态调整,建议在创建实例时合理规划资源,避免因资源超限导致业务异常。

生产和消费速率一致,为什么监控还是显示有堆积?

实际发送和消费速率基本匹配,但部分消息的 ACK 耗时较长,导致监控在某个采样时间点统计到一定的堆积量。在下一个采样周期,堆积通常会恢复正常。

某些 Pod 的消费量为什么突然下降了?

建议排查 Pod 的性能情况。可能因 CPU 使用率过高,导致客户端未能及时提交 ACK。服务端在未收到 ACK 的情况下无法继续推送消息,需要等待超时后重新推送,从而导致消费量下降。

例如 QoS 设置为1,那么只允许该消费者在同一时间有1 条消息未 ACK;服务端需要等待消费者处理完消息并提交 ACK 后,才能推送下一条消息。如果未收到 ACK,则只能等待超时后才能推送下一条。

RabbitMQ 可以使用默认密钥的主密钥吗?

可以。

报错 The channelMax limit is reached?

服务端只会对单个 Connection 上的 Channel 数量有限制,不会对总的 Channel 数量有限制;

从 SDK 代码来看,只要createChannel返回null,都会打印“The channelMax limit is reached”;

升配后需要重启客户端,否则客户端在创建连接时仍使用升配前的 Channel 数量限制,会继续报错。

比如:实例购买的时候Channel Max 为 100,客户端在创建连接时会与服务端进行参数协商,最终采用服务端提供的 100 的限制;由于这些连接在升配之前就已建立,其协商的 Channel Max 值仍为 100,而非升配后的 2000 或 2500,因此会继续触发报错。

Channel 参数协商过程示意

提升 TPS 会影响现有业务吗?

不会。通过控制台升配提升 TPS 时,不会导致连接闪断或已有连接断开。

创建 Connection 时,会有可能导致其他 Channel Shutdown 吗?

通常不会。但如果客户端资源(网络、内存、JVM)不足,可能导致其他连接或通道中断。建议重点排查客户端的资源使用情况,确认是否存在资源抢占或资源不足导致连接或通道中断的问题。

Queue 的消费者突然消失了?

建议优先检查该时间段内客户端的业务和资源情况,确认是否存在进程挂起或资源不足导致业务中断的问题。如果客户端运行正常,需要进一步确认服务端的消息推送是否正常。

队列清空消息未生效的原因?

1)Unacked 消息无法通过清空队列操作清除。Unacked 消息是指已推送到客户端但尚未提交 ACK 的消息,其数量会在消息过期后自动更新

2)如果设置了 TTL 的消息未被清除,请提交工单确认是否已开启相关配置开关

云上 RabbitMQ 实例目前不支持 reply-to?

云上 RabbitMQ 实例目前不支持 reply-to。

客户端日志如何计算 TPS?

对应 SQL 语句为:

 * and amqp-cn-xxx and Action : SendMessage | select InstanceId as instance_id, VHost as virtual_host, Queue as queue, microtime / 1000 / 1000 as time_second, count(*) as send_qps group by instance_id, virtual_host, queue, time_second order by time_second, send_qps limit 10000000

统计结果示例:

RabbitMQ 修改日志 Logstore 之后为什么查看日志为空?

在新的 Logstore 中点击【开启索引】,等待约一分钟后刷新页面即可查看日志。

操作步骤:

1)点击开启索引

2)直接【确定】即可

RabbitMQ 断连的可能原因?

如果客户端提交的有效 ACK 数量较少,服务端因未收到有效应答,会重复投递消息,导致消息堆积持续不下降。

而且这种情况下,表明消息在客户端堆积,可能导致连接无法发送心跳包,最终触发 Connection ALL_IDLE,连接断开。请优先排查客户端未能提交有效 ACK 的原因。

TTL 相关设置?

TTL 最大支持设置为 3 天,超过 3 天的设置将不生效。TTL 不生效时,消息到期后不会进入死信队列,并可能出现各种不符合预期的行为。

1)如果未设置 TTL,队列中均为普通消息,监控中的 readyMessage 指标即为普通消息的数量,也就是实际堆积量。

2)如果设置了 TTL,监控中的 readyMessage 指标表示存活消息的数量:

a) 如果 TTL 正常生效,队列中的存活消息数量根据 TTL 动态计算,监控中的 readyMessage 即为实际存活消息数量,属于正常现象。

b)如果 TTL 已设置但未生效,存活消息数量始终为 0,监控中的 readyMessage 也始终显示为 0,无法反映实际堆积情况。

报错 java.lang.IllegalArgumentException: Content headers exceeded max frame size: 40209 > 32768?

消息头部的帧大小超过限制。消息头部(Header)的默认大小限制为 32 KB,该限制在服务端无法调整。

建议将较长的数据从 Header 移至 Body 中,避免超出 Header 帧大小限制。

为什么清空队列还是可以查到消息?

清空队列后查询消息功能检索的是日志数据,日志的保存时间较长,因此仍可查询到历史消息。

解绑订阅关系报错?

原因:

排他队列仅对首次声明它的连接可见,只能由创建该排他队列的连接进行删除操作,无法通过控制台操作。

详情请参见排他队列

解决方案:

1)如果不再需要该排他队列,断开对应连接后,排他队列将被自动删除,其绑定关系也会一并移除。

2)如果无法找到创建该排他队列的 Connection ID,可以通过重启客户端来删除排他队列。

报错:VPC flow is not allowed to login in?

报错原因:

服务端检测到使用的用户名密码不是通过控制台生成的静态用户名密码,将请求流量误判为开源鉴权流量,因此拒绝连接。

解决方案:

确认 VPC 接入点连通性后,请确认使用的用户名和密码是在控制台上生成的静态用户名密码。如有疑问,建议重新生成用户名密码,确保配置正确。

如何实现跨地域内网访问?

跨地域内网访问的标准方案是使用 PrivateLink + CEN 方案;

请注意:使用该方案会产生 PrivateLink 的费用; 如需使用,请提交工单申请开通私网接入点,开通后可在控制台进行配置。操作时请注意 vSwitch 可用区和安全组配置。

详情请参见私网连接接入点