消费失败是否支持重试？
如果您开启了Consumer客户端消费消息，消费失败，即Consumer客户端一分钟内没有应答消息，则触发消息重试：重试期间，任何一次消费成功，即Consumer客户端应答消息，则立即停止消息重试。重试间隔时间：专业版实例：60秒 企业版实例：5分钟...
接口和参数说明
SUSPEND_TIME_MILLIS（顺序消息）只适用于顺序消息，设置消息消费失败的重试间隔时间。MAX_CACHED_MESSAGE_AMOUNT 客户端本地的最大缓存消息数据，单位：条。默认值为 1000。MAX_CACHED_MESSAGE_SIZE_IN_MI_B 客户端本地的最大缓存消息大小...
消费重试
消费失败的原因不会导致连续性，即当前消息消费失败是一个小概率事件，不是常态化的失败，后面的消息大概率会消费成功。此时可以对当前消息进行重试，避免进程阻塞。以下场景不建议使用消息重试 消费处理逻辑中使用消费失败来做条件判断的...
消息重试
消息投递失败后需要重试 集群消费模式下，消息消费失败后期望消息重试，需要在消息监听器接口的实现中明确进行配置（三种方式任选一种）：方式1：返回Action.ReconsumeLater（推荐）方式2：返回Null 方式3：抛出异常 示例代码 public class...
消息重试
配置方式 消费失败后，重试配置方式 集群消费方式下，消息消费失败后期望消息重试，需要在消息监听器接口的实现中明确进行配置（三种方式任选一种）：返回 Action.ReconsumeLater（推荐）返回 Null 抛出异常 示例代码：public class ...
消费者分类
此时如果消息消费失败，云消息队列 RocketMQ 版 服务端同样无法感知，因此也不会进行消费重试。顺序性保障 基于 云消息队列 RocketMQ 版 顺序消息 的定义，如果消费者分组设置了顺序消费模式，则PushConsumer在触发消费监听器时，严格遵循...
TCP协议客户端大版本发布
消息消费失败率 top20 GroupIDs：统计消费消息时失败率最高的前20个Group。消息轨迹 缺少非普通消息的轨迹数据和消费堆积场景的相关数据。增加了消息消费环节的轨迹数据，可根据异常、失败及耗时等条件查询消息轨迹。增加了定时、事务等...
顺序消息
顺序消息消费失败进行消费重试时，为保障消息的顺序性，后续消息不可被消费，必须等待前面的消息消费完成后才能被处理。使用限制 顺序消息仅支持使用 MessageType 为 FIFO 的主题，即顺序消息只能发送至类型为顺序消息的主题中，发送的消息...
仪表盘
消息消费失败率 top20 GroupIDs 统计消费消息时失败率最高的前20个Group。计费指标信息 说明 以下各计费指标项的值均包含了大消息倍数和高级特性消息倍数的计算结果。大消息倍数：以消息大小4 KB为计量单位。例如，发送一条16 KB的消息，...
常见问题
消息消费失败是否会重新消费？消息队列RocketMQ版5.x系列实例支持广播消费吗？消息队列RocketMQ版定时消息最大可定时多长时间？客户端连接常见问题 客户端连接时出现“signature validate by dauth failed”错误 客户端连接时出现...
常见问题
消息消费失败是否会重新消费？云消息队列 RocketMQ 版5.0系列实例支持广播消费吗？云消息队列 RocketMQ 版定时消息最大可定时多长时间？实例的Topic数量和Group数量有限制吗？云消息队列 RocketMQ 版存储需要挂载磁盘吗？客户端连接常见...
接口和参数说明
suspendTimeMillis（顺序消息）只适用于顺序消息，设置消息消费失败的重试间隔时间。maxCachedMessageAmount 消费者客户端本地的最大缓存消息数量，取值范围为[100,50000]，默认值：5000，单位：条。该参数在客户端级别生效，限定额会平均...
AMQP客户端接收不到实时消息，为什么？
如果客户端对重试推送的消息消费失败，可能导致堆积队列阻塞。按大约一分钟间隔，物联网平台会向客户端再次重试推送。解决方法 在 物联网平台控制台 对应实例下，进入 消息转发>服务端订阅 页面，确认已创建的产品订阅中已添加 推送消息...
服务端订阅使用限制
如果客户端对重试推送的消息消费失败，可能导致堆积队列阻塞。按大约一分钟间隔，物联网平台向客户端再次重试推送。消息保存条数 一个消费组最多可堆积1亿条消息。消息保存时长 1天。实时消息推送限流 一个连接限流1,000 TPS。您可通过增加...
收发顺序消息
顺序消息消费失败进行重试前的等待时间，单位（毫秒），取值范围:10毫秒~30,000毫秒。properties.put(PropertyKeyConst.SuspendTimeMillis,"100");消息消费失败时的最大重试次数。properties.put(PropertyKeyConst.MaxReconsumeTimes,"20")...
死信消息
例如，某条消息生产者发送到服务端的时间为13∶00∶00，2个小时后（15∶00∶00）该消息消费失败且重试失败被存储至死信Topic，则该消息的保存时长从15∶00∶00开始计算。使用限制 保存死信消息的Topic只支持普通消息和顺序消息类型的Topic...
版本说明
修复批量消费未设置最大等待时间从而导致部分消息消费失败的问题。ons-client-1.8.8.7.Final 1.8.8.5.Final 发布时间 发布内容 下载 2022-05-16 问题修复 修复RAM角色实现跨云账号STS授权场景下，updateCredential方法调用频率较高时，三元...
消息轨迹
进死信时间 消息消费失败被投递至死信队列的时间。使用限制 RocketMQ 4.x/3.x 版本的SDK客户端默认不开启消息轨迹功能，您需要在消息收发代码中开启消息轨迹功能，才能在控制台查询到消息的轨迹信息。具体配置如下：生产者 producer....
消费者分组（ConsumerGroup）
消费者业务类型一致：一般消费者分组和主题对应，不同业务域对消息消费的要求不同，例如消息过滤属性、消费重试策略不同。因此，不同业务域主题的消费建议使用不同的消费者分组，避免一个消费者分组消费超过10个主题。消费者分组管理尽量...
消息（Message）
消费重试次数 定义：消息消费失败后，云消息队列 RocketMQ 版 服务端重新投递的次数。每次重试后，重试次数加1。更多信息，请参见 消费重试。取值：由服务端系统标记。首次消费，重试次数为0；消费失败首次重试时，重试次数为1。业务自定义...
配置消息监控告警实现风险预警
基于消息消费失败的原因，确定具体的问题修复措施。配置限流次数告警最佳实践 背景：消息队列RocketMQ版支持将指定实例触发限流的事件作为监控项，通过对限流次数的监控，可以帮助您了解当前业务的受损情况。未配置风险：限流次数越多，...
查询消息轨迹
消息状态说明 状态类型 状态参数 发送状态 发送成功 发送失败 消息定时中 事务未提交 事务回滚 消费状态 全部成功 部分成功 全部失败 尚未消费 消费结果未返回 消费成功 消费失败 消息轨迹常见问题 为什么查询不到消息轨迹？检查客户端的...
版本说明
修复批量消费未设置最大等待时间从而导致部分消息消费失败的问题。ons-client-1.8.8.7.Final 1.8.8.5.Final 发布时间 发布内容 下载 2022-05-16 问题修复 修复RAM角色实现跨云账号STS授权场景下，updateCredential方法调用频率较高时，三元...
接入方式
因此在由于网络、业务信息延迟等问题导致消息消费失败的情况下，该条消息将被跳过。2.顺序消费 Linkedmall消息在发送时保证按分区有序，如您需要按序消费消息，请务必参考示例代码中的消费部分，对每个分区内的消息串行处理/拉取消息 ...
功能发布列表
本文介绍了 云消息队列 RocketMQ 版 每次发布涉及的新增功能、功能优化、重要问题...修复批量消费未设置最大等待时间从而导致部分消息消费失败的问题。优化 TCP Java SDK版本说明 历史发布记录 更多历史功能迭代记录，请参见 历史发布记录。
使用须知
云消息队列 RocketMQ 版 提供了通过HTTP协议的多语言SDK接入的能力，并支持公网...采用TCP协议发送消息，HTTP协议消费消息时，消费消息失败。您可以自行采用Base64编码对发送的消息进行编（解）码，以适用于此类不符合XML规范的消息收发场景。
示例代码
}@Override public void onException(OnExceptionContext context){/消息发送失败，需要进行重试处理，可重新发送这条消息或持久化这条数据进行补偿处理。System.out.println("send message failed.topic="+context.getTopic()+",msgId="+...
消息收发定价详情
计费示例 消息收发次数计算示例 服务端每天收到生产者发送的700万条普通消息，由于一个Topic会被多个Group订阅，且考虑到消息消费失败重投的情况，消息投递次数按照800万次预估；每条消息大小为40 KB。服务端每天收到生产者发送的300万条...
AMQP客户端接入说明
如果客户端对重试推送的消息消费失败，可能导致堆积队列阻塞。按大约一分钟间隔，物联网平台向客户端再次重试推送。说明 消费端存在短暂的流量不均衡，属于正常现象。一般能在10分钟内恢复。如果您的消息QPS较高或消息处理较耗费资源，建议...
订阅关系一致
除了保证同一Group ID下的Consumer实例订阅关系一致，还必须保证订阅消息的Group ID的协议版本和SDK的协议版本一致，例如，使用TCP协议的SDK收发消息，订阅消息时也必须使用创建的TCP协议的Group ID，否则会导致消息消费失败。如何查看订阅...
使用限制
如果客户端对重试推送的消息消费失败，可能导致堆积队列阻塞。按大约一分钟间隔，物联网平台向客户端再次重试推送。消息保存条数 一个消费组最多可堆积1亿条消息。消息保存时长 1天。实时消息推送限流 一个连接限流1,000 TPS。您可通过增加...
OnsConsumerStatus-查询Group ID消费状态
test-mq_topic FailedCountPerHour long 每小时内消费失败的消息数统计。0 OkTps float 消费消息成功的 TPS 统计。0 FailedTps float 消费消息失败的 TPS 统计。0 SubscriptionSet object[]订阅关系集合。SubString string 订阅该 Topic 的...
Group导入/导出
ConsumeRetryPolicy 消费者消费消息失败时，系统的重试策略。取值如下：FixedRetryPolicy：固定间隔重试 DefaultRetryPolicy：阶梯退避重试 更多信息，请参见 消费重试。MaxRetryTimes 最大重试次数 不超过1000次。DeadLetterTargetTopic ...
查询消息轨迹
发送失败：消息发送失败，服务端没有存储消息，需要重试。消息定时中：该消息是定时或者延时消息，且尚未到达投递时间。事务未提交：该消息是事务消息，且尚未提交状态。事务回滚：该消息是事务消息，并且已经回滚。Topic：Key：消息的业务...
死信队列
对于消费失败且重试后依然失败的消息，云消息队列 RocketMQ 版 不会立丢弃，而是将消息转发至指定的队列中，即死信队列，这些消息即为死信消息。当消费失败的原因排查并解决后，您可以重发这些死信消息，让消费者重新消费；若您暂时无法...
SOFAMQ 常见问题
消息队列消费失败如何重新消费消息？消息发送了，但是没有收到怎么办？消息队列是否能保证消息不重复？控制台显示的消息堆积量是否包含了 Topic 下所有 Tag 的消息？消息队列是否可以在公网访问？暂不支持，消息的生产者和消费者需要和消息...
集群消费和广播消费
广播模式下，消息队列保证每条消息至少被每台客户端消费一次，但是并不会重投消费失败的消息，因此业务方需要关注消费失败的情况。广播模式下，客户端每一次重启都会从最新消息消费。客户端在被停止期间发送至服务端的消息将会被自动跳过，...
OnsDLQMessageResendById-重发指定的死信消息
由于死信消息是经过重试逻辑依然消费失败的消息，通常意味着消费逻辑可能存在问题，故请先查明多次消费失败的原因，再调用本接口重新发送。当前消息队列 RocketMQ 版不管理死信重发的状态，重发后消费成功的消息不会从死信队列中移除。需...
集群消费和广播消费
注意事项 广播模式下，云消息队列 RocketMQ 版 保证消息至少被客户端消费一次，但是并不会重投消费失败的消息，因此业务方需要关注消费失败的情况。广播模式下，客户端每一次重启都会从最新消息消费。客户端在被停止期间发送至服务端的消息...
订阅者最佳实践
云消息队列 Kafka 版 没有处理失败消息的设计，实践中通常会打印失败的消息或者存储到某个服务（例如创建一个Topic专门用来放失败的消息），然后定时检查失败消息的情况，分析失败原因，根据情况处理。消费延迟 云消息队列 Kafka 版 的消费...
- 产品推荐
- 这些文档可能帮助您