产品优势
功能齐全 支持多种消息类型：普通消息、定时消息、分区顺序消息、事务消息 支持多种消费模式：Pub/Sub 模式、Tag 过滤 支持 TCP Java SDK 运维体系...千万级高并发处理能力 服务可靠 99.9%服务高可用 99.99999%数据高可靠 支持消息重投机制
消息过滤
如果想测试消息重投的功能,可以将Action.CommitMessage 替换成Action.ReconsumeLater return Action.CommitMessage;} });订阅单个 Tag 消费者如需订阅某 Topic 下某一种类型的消息，请明确标明 Tag：SOFABOOT 示例 import ...
功能与特性概述
性能 普通消息 是 是 是 是 最高 事务消息 定时和延时消息 分区顺序消息 是 否 否 否 高 全局顺序消息 一般 消息特性 消息重试：在消费者返回消息重试的响应后，云消息队列 RocketMQ 版 会按照相应的 重试规则 进行消息重投。至少投递一次...
开源对比
重试策略 消费超时会重投消息，重试策略，请参见 消息超时和重试机制。无超时重投策略。是否持久化 支持持久化和非持久化。支持持久化和非持久化。Max length 无需配置，支持海量消息堆积。需配置，防止消息堆积过多而引起的内存问题导致宕...
集群消费和广播消费
注意事项 广播模式下，云消息队列 RocketMQ 版 保证消息至少被客户端消费一次，但是并不会重投消费失败的消息，因此业务方需要关注消费失败的情况。广播模式下，客户端每一次重启都会从最新消息消费。客户端在被停止期间发送至服务端的消息...
集群消费和广播消费
广播模式下，消息队列保证每条消息至少被每台客户端消费一次，但是并不会重投消费失败的消息，因此业务方需要关注消费失败的情况。广播模式下，客户端每一次重启都会从最新消息消费。客户端在被停止期间发送至服务端的消息将会被自动跳过，...
JMS SDK
MessageListener抛出异常就不会ACK，在 VisibilityTimeout 后消息会重投。MANUAL_ACKNOWLEDGE：您需要在代码中调用 acknowledge()对消息进行ACK。示例代码 创建队列 String accessKeyId=ServiceSettings.getMNSAccessKeyId();String ...
消息收发定价详情
计费示例 消息收发次数计算示例 服务端每天收到生产者发送的700万条普通消息，由于一个Topic会被多个Group订阅，且考虑到消息消费失败重投的情况，消息投递次数按照800万次预估；每条消息大小为40 KB。服务端每天收到生产者发送的300万条...
仪表盘
变成死信状态指的是消息达到最大重投次数后不再投递。这些不再投递的消息会根据Group的死信策略配置保存至指定Topic或被丢弃。uid instance_id topic consumer_group Gauge rocketmq_storage_size byte 实例所使用的存储空间大小，包含所有...
消费失败是否支持重试？
重试机制 云消息队列 RabbitMQ 版 服务端有默认的消息重试机制，不支持您在Consumer客户端重新配置消息重试机制和关闭消息重试机制。云消息队列 RabbitMQ 版 服务端默认的消息重试机制如下：如果您没有开启Consumer客户端消费消息，则不会...
消息超时和重试机制
重试机制 云消息队列 RabbitMQ 版 服务端有默认的消息重试机制，不支持您在Consumer客户端重新配置消息重试机制和关闭消息重试机制。云消息队列 RabbitMQ 版 服务端默认的消息重试机制如下：如果您没有开启Consumer客户端消费消息，则不会...
消息重试
云消息队列 RocketMQ 版 支持消息重试功能，即Consumer消费某条消息失败或消费超时，云消息队列 RocketMQ 版 会根据消息重试机制重新投递消息。本文介绍 云消息队列 RocketMQ 版 分别在HTTP协议和TCP协议下的消息重试策略。注意事项 一条...
消息重试
本文介绍 SOFAStack 消息队列的消息重试机制和配置方式。顺序消息的重试 对于顺序消息，当消费者消费消息失败后，消息队列会自动不断地进行消息重试（每次间隔时间为 1 秒），这时，应用会出现消息消费被阻塞的情况。因此，建议您使用顺序...
怎样让Consumer不立即消费消息并使消息重入队列？
您可以通过basicReject或basicNack方法否定应答消息，使消息重入队列，从而是其他Consumer可以消费消息。使用basicReject方法否定应答单条消息并使消息重入队列 您可以使用basicReject方法实现Consumer否定应答单条消息并使其重入队列。...
怎样让Consumer不立即消费消息并使消息重入队列？
您可以通过basicReject或basicNack方法否定应答消息，使消息重入队列，从而是其他Consumer可以消费消息。使用basicReject方法否定应答单条消息并使消息重入队列 您可以使用basicReject方法实现Consumer否定应答单条消息并使其重入队列。...
消费重试
消息重试策略差异 根据消费者类型不同，消息重试策略的具体内部机制和设置方法有所不同，具体差异如下：消费者类型 重试过程状态机 重试间隔 最大重试次数 PushConsumer 已就绪 处理中 待重试 提交 死信 丢弃 消费者分组创建时元数据控制。...
SDK FAQ
您可以使用basicReject方法否定应答单条消息，或者使用basicNack方法否定应答一条或多条消息，并使消息重入队列。使用basicReject方法否定应答消息并使消息重入队列 参数 说明 deliveryTag Channel的消息投递的唯一标识符。requeue 被否定...
名词解释
消息重试次数超过16次，消息重试失败。具体信息，请参见 消息重试。消息过期，即消息在Queue中存在的时间超过了设置的消息存活时间。具体信息，请参见 消息存活时间。死信Queue 死信Exchange绑定的Queue，用于存储死信消息。V Vhost 虚拟...
死信消息
应用场景 典型死信消息处理场景 消息重试失败后，您可以选择将死信消息存储到指定的死信Topic中，通过另外创建一个ConsumerGroup消费这些死信消息来处理异常链路或分析死信消息。典型错误使用死信消息场景 处理死信消息时，如果将死信消息...
死信队列
背景信息 当一条消息初次消费失败，云消息队列 RocketMQ 版 会自动进行消息重试，达到最大重试次数后，若消费依然失败，则表明消费者在正常情况下无法正确地消费该消息。此时，云消息队列 RocketMQ 版 不会立刻将消息丢弃，而是将其发送到...
版本说明
修复顺序消息重试时，重试次数不准确的问题。修复某些条件下客户端生成Message ID重复的问题。aliyun-mq-windows-net-sdk.zip 1.1.3 发布时间 发布内容 Windows版下载 2019-02-01 功能优化 支持实例化用户使用以下两种方式接入（非实例化...
死信Exchange
消息重试次数超过16次，消息重试失败。具体信息，请参见 消息超时和重试机制。消息过期，即消息在Queue中存在的时间超过了设置的消息存活时间。具体信息，请参见 消息存活时间。死信Queue 死信Exchange绑定的Queue，用于存储死信消息。路由...
版本说明
修复顺序消息重试时，重试次数不准确的问题。修复某些条件下客户端生成Message ID重复的问题。aliyun-mq-windows-net-sdk.zip 1.1.3 发布时间 发布内容 Windows版下载 2019-02-01 功能优化 支持实例化用户使用以下两种方式接入（非实例化...
产品优势
消息重试 重试一次一分钟，最多16次重试。超过最大重试次数后的消息进入死信队列，死信消息可查询、可导出。死信Exchange 增强型死信Exchange，不仅支持被否定应答的消息，还支持重试失败的消息自动进入死信Exchange，确保消息不丢失。超强...
消费者分类
由 云消息队列 RocketMQ 版 的SDK在后台完成消息获取、触发监听器调用以及进行消息重试处理。示例代码如下：/消费示例：使用PushConsumer消费普通消息。ClientServiceProvider provider=ClientServiceProvider.loadService();String topic=...
UpdateConsumerGroup-更新消费者分组
消费者出现异常消费某条消息失败，且消息重试后依然未成功，消息将被投递至死信 Topic 中，以便后续进行业务恢复或回溯。更多信息，请参见 消费重试与死信。DLQ_mqtest 返回参数 名称 类型 描述 示例值 object Result requestId string ...
CreateConsumerGroup-创建消费者分组
消费者出现异常消费某条消息失败，且消息重试后依然未成功，消息将被投递至死信 Topic 中，以便后续进行业务恢复或回溯。更多信息，请参见 消费重试与死信。DLQ_mqtest 返回参数 名称 类型 描述 示例值 object Result requestId string ...
权益分发
在电商和新零售领域，权益分发适用于对特定的用户进行指定运营活动的场景。技术层面上，此种场景的DB和缓存的数据强一致性较难保证。...更多信息 云消息队列 RocketMQ 版 的功能与特性详情，请参见以下文档：功能与特性概述 消息重试
如何设置Message ID
如需实现消息幂等，即如果消息重试多次，消费者端对该重复消息消费多次与消费一次的结果是相同的，并且多次消费没有对系统产生副作用，在为每条消息设置唯一Message ID的基础上，您还需要在 云消息队列 RabbitMQ 版 的Consumer客户端对消息...
如何设置Message ID
如需实现消息幂等，即如果消息重试多次，消费者端对该重复消息消费多次与消费一次的结果是相同的，并且多次消费没有对系统产生副作用，在为每条消息设置唯一Message ID的基础上，您还需要在 云消息队列 RabbitMQ 版 的Consumer客户端对消息...
升降配管理
建议您在客户端配置重试机制，将变更期间发送失败的消息重试发送。变更过程中，整体服务不受影响。升降配设置 升级实例配置 参数 说明 规格类型 支持从标准版变更为专业版。不支持从专业版变更为标准版。网络类型 支持将VPC实例变更为公网/...
订阅消息API
说明 HTTP协议下 云消息队列 RocketMQ 版 的消息重试机制为：无序消息每隔5分钟重试一次，顺序消息每隔1分钟重试一次，最多重试288次。ConsumedTimes String 消息被消费的次数。MessageTag String 消息Tag。Properties String 消息属性。...
OnsMessageDetail-查询消息详细信息
2 ReconsumeTimes integer 消息重试消费的次数。0 StoreTimestamp long 消息被服务端存储的时间戳。单位：毫秒。1570761026708 Body string 消息体内容经过 Base 64 算法加密后的字符串。aGVsbG8=InstanceId string 云消息队列 RocketMQ 版...
死信队列
当一条消息初次消费失败，消息队列会自动进行消息重试。达到最大重试次数后，若消费依然失败，则表明消费者在正常情况下无法正确地消费该消息。此时，消息队列不会立刻将消息丢弃，而是将其发送到该消费者对应的特殊队列中。在消息队列中，...
API概览
本产品（云消息队列 RocketMQ 4.0 版/2019-02-14）的OpenAPI采用 RPC 签名风格，签名细节参见 签名机制说明。...OnsDLQMessageResendById 重发指定的死信消息 重发指定Message ID的死信消息，使该消息能够被Consumer再次消费。
弹性策略
建议您在客户端配置重试机制，将变更期间发送失败的消息重试发送。变更过程中，整体服务不受影响。生效时间 为保障在预留规格生效时间内升降配至预设容量，服务端会在生效时间开始之前执行升降配任务，建议提前配置定时任务保障足够的升降...
OnsDLQMessageGetById-根据Message ID查询死信消息
407 ReconsumeTimes integer 消息重试消费的次数。1 StoreTimestamp long 消息被服务端存储的时间戳。单位：毫秒。1570761026708 InstanceId string 实例 ID。MQ_INST_111111111111_DOxxxxxx MsgId string 消息 ID。0BC16699165C03B925DB8A...
OnsMessageGetByMsgId-通过MsgId查询消息
407 ReconsumeTimes integer 消息重试消费的次数。1 StoreTimestamp long 被服务端存储的时间戳。1570761026708 InstanceId string 实例 ID。MQ_INST_111111111111_DOxxxxxx MsgId string 消息 ID，即 Message ID。1E0578FE110F18B4AAC235C...
SDK参考概述
普通消息 顺序消息 定时和延时消息 事务消息 PushConsumer PullConsumer 批量消费 广播消费 集群消费 消息重试 查询消息轨迹 死信队列 重置消费位点 SDK使用说明 HTTP协议和TCP协议的接入点不可混用。例如，您使用TCP协议的SDK收发消息，您...
OnsMessageGetByKey-根据Message Key查询消息
406 ReconsumeTimes integer 消息重试消费的次数。1 StoreTimestamp long 被 Broker 存储的时间戳。1570760999811 InstanceId string 实例 ID。MQ_INST_111111111111_DOxxxxxx MsgId string 消息 ID，即 Message ID。1E0578FE110F18B4AAC...
- 产品推荐
- 这些文档可能帮助您