CreateConsumerGroup-创建消费者分组
参数取值如下：Concurrently：并发投递 Orderly：顺序投递 Concurrently consumeRetryPolicy object 是 待创建消费者分组的消费重试策略。更多信息，请参见 消费重试。maxRetryTimes integer 否 最大重试次数。16 retryPolicy string 是 重...
Group导入/导出
取值如下：FixedRetryPolicy：固定间隔重试 DefaultRetryPolicy：阶梯退避重试 更多信息，请参见 消费重试。MaxRetryTimes 最大重试次数 不超过1000次。DeadLetterTargetTopic 死信Topic 死信Topic不能和原消息发送Topic相同。若不需要使用...
GetConsumerGroup-获取指定消费者分组详情
Concurrently consumeRetryPolicy object 消费者分组的消费重试策略。更多信息，请参见 消费重试。retryPolicy string 重试策略类型。枚举值：FixedRetryPolicy：固定间隔重试。DefaultRetryPolicy：阶梯退避重试。DefaultRetryPolicy ...
SOFAMQ 常见问题
3 1 分钟 4 2 分钟 5 3 分钟 6 4 分钟 7 5 分钟 8 6 分钟 9 7 分钟 10 8 分钟 11 9 分钟 12 10 分钟 13 20 分钟 14 30 分钟 15 1 小时 16 2 小时 广播消费方式 广播消费方式可以保证一条消息至少被消费一次，但消费失败后不做重试操作。...
GetMqSofamqMessageById
B214-6CB5E44B7F04 请求ID Data Object 查询结果 StoreSize Long 407 消息大小，单位：KB ReconsumeTimes Long 1 消息重试消费的次数 StoreTimestamp Long 1570761026708 被服务端存储的时间戳 Topic String test-mq_topic 消息的 Topic ...
消费托管MQ接口
确认消息 消费托管MQ消息成功后，进行确认，方法名称：ackMQMessage。函数原型 AckMQMessageResponse ackMQMessage(final AckMQMessageRequest request)请求参数 参数 必选 说明 streamId 是 队列ID，即数据导出服务中的任务ID。...
推送到HTTP
重试策略：选择重试策略。消息推送格式：选择消息推送格式。步骤三：发布消息 登录 消息服务MNS控制台。在左侧导航栏，单击 主题列表。在顶部菜单栏，选择地域。在 主题列表 页面，找到目标主题，在其右侧操作列选择 更多>发布消息。在 ...
OnsMessageGetByMsgId-通过MsgId查询消息
如遇消息消费有问题，则可通过该接口查询具体发送的消息内容来排查问题。根据 Message ID 查询消息的方式属于精确查询，查询条件需要的 Message ID 从每次消息发送成功的 SendResult 中获取，因此业务方必须存储每次发送消息的结果。查询到...
消费者（Consumer）
因此，为了保证分组内消息的正常负载和消费，云消息队列 RocketMQ 版 要求同一分组下的所有消费者以下消费行为保持一致：投递顺序 消费重试策略 版本兼容性 如行为约束中所述，同一分组内所有消费者的投递顺序和消费重试策略需要保持一致。...
OnsMessageGetByKey-根据Message Key查询消息
406 ReconsumeTimes integer 消息重试消费的次数。1 StoreTimestamp long 被 Broker 存储的时间戳。1570760999811 InstanceId string 实例 ID。MQ_INST_111111111111_DOxxxxxx MsgId string 消息 ID，即 Message ID。1E0578FE110F18B4AAC...
推送到移动设备
重试策略：选择重试策略。消息推送格式：选择消息推送格式。步骤三：发布消息 登录 消息服务MNS控制台。在左侧导航栏，单击 主题列表。在顶部菜单栏，选择地域。在 主题列表 页面，找到目标主题，在其右侧操作列单击 发布消息。在 快速体验...
配置消息监控告警实现风险预警
配置死信消息告警最佳实践 背景：消息队列RocketMQ版支持死信消息，将消费失败并超过重试次数的消息投递至死信队列，以便您后续进行人工处理。监控进入死信队列的消息量可以帮助您及时预警当前业务出现的非预期且无法判断的异常问题。未...
推送到邮箱
重试策略：选择重试策略。消息推送格式：选择 SIMPLIFIED。步骤三：发布消息 登录 消息服务MNS控制台。在左侧导航栏，单击 主题列表。在顶部菜单栏，选择地域。在 主题列表 页面，找到目标主题，在其右侧操作列选择 更多>发布消息。在 快速...
推送到阿里短信
重试策略：选择重试策略。消息推送格式：选择 SIMPLIFIED。步骤三：发布消息 登录 消息服务MNS控制台。在左侧导航栏，单击 主题列表。在顶部菜单栏，选择地域。在 主题列表 页面，找到目标主题，在其右侧操作列单击 发布消息。在 快速体验...
触发器高级功能
如果启用死信队列，未被处理或超过重试次数的消息会被投递到目标服务中。函数计算支持的目标服务包括 消息服务MNS、云消息队列 RocketMQ 版、云消息队列 Kafka 版 和 事件总线EventBridge，您可以根据需求选择不同的队列类型。如果未启用...
查询Group ID内所有死信消息
406 ReconsumeTimes integer 消息重试消费的次数。1 StoreTimestamp long 消息被服务端存储的时间戳。1570760999811 InstanceId string 实例 ID。MQ_INST_111111111111_DOxxxxxx MsgId string 消息 ID，即 Message ID。1E0578FE110F18B4AAC...
触发器高级功能
如果启用死信队列，未被处理或超过重试次数的消息会被投递到目标服务中。函数计算支持的目标服务包括 消息服务MNS、云消息队列 RocketMQ 版、云消息队列 Kafka 版 和 事件总线EventBridge，您可以根据需求选择不同的队列类型。如果未启用...
消息收发常见问题
实际重试消息都是间隔产生的，只是暂时堆在了写缓存区内，写成功后才会打印日志。为什么消息会一直重试？连接正常的情况下，消息会间隔5秒到10秒重试一次，超过一定次数后还失败则会被丢弃。如果消息重试时客户端连接已经断开，则消息不会...
异地应用双活切流
说明 若推送规则失败，则单击 重试 进行重试，MSHA将在2小时内定时自动重试，如果超时仍未成功，则切流工单进入 异常 状态并回滚重推基线规则。3.各层切流。单击 接入层切流 详情。MSHA将执行各单元流量比例推送和各单元化路由规则推送。...
事务消息
因此需要下游业务分支自行保证消息正确处理，建议消费端做好 消费重试，如果有短暂失败可以利用重试机制保证最终处理成功。中间状态可见性 云消息队列 RocketMQ 版 事务消息为最终一致性，即在消息提交到下游消费端处理完成之前，下游分支...
OnsDLQMessageGetById-根据Message ID查询死信消息
407 ReconsumeTimes integer 消息重试消费的次数。1 StoreTimestamp long 消息被服务端存储的时间戳。单位：毫秒。1570761026708 InstanceId string 实例 ID。MQ_INST_111111111111_DOxxxxxx MsgId string 消息 ID。0BC16699165C03B925DB8A...
死信队列
当一条消息初次消费失败，消息队列会自动进行消息重试。达到最大重试次数后，若消费依然失败，则表明消费者在正常情况下无法正确地消费该消息。此时，消息队列不会立刻将消息丢弃，而是将其发送到该消费者对应的特殊队列中。在消息队列中，...
版本说明
修复顺序消息重试时，重试次数不准确的问题。修复某些条件下客户端生成Message ID重复的问题。aliyun-mq-windows-net-sdk.zip 1.1.3 发布时间 发布内容 Windows版下载 2019-02-01 功能优化 支持实例化用户使用以下两种方式接入（非实例化...
实例类型
1 MB 延时消息最大延时时间 7天 24小时 7天 7天 消息最大保留时间 3天 3天 3天 3天 消息最大重入Queue次数 16 16 16 64 消息超时重试间隔 5分钟 60秒 5分钟 30分钟 接口调用限制 限制项 限制项接口 Serverless版 专业版 企业版 铂金版 单...
OnsMessagePageQueryByTopic-查询Topic内所有消息
406 ReconsumeTimes integer 消息重试消费的次数。1 StoreTimestamp long 消息被服务端存储的时间戳，单位：毫秒。1570760999811 InstanceId string 实例 ID。MQ_INST_111111111111_DOxxxxxx MsgId string 消息 ID，即 Message ID。1E0578...
使用限制
1 MB 延时消息最大延时时间 7天 24小时 7天 7天 消息最大保留时间 3天 3天 3天 3天 消息最大重入Queue次数 16 16 16 64 消息超时重试间隔 5分钟 60秒 5分钟 30分钟 接口调用限制 重要 Serverless版、专业版和企业版：单个接口的调用量受...
版本说明
修复顺序消息重试时，重试次数不准确的问题。修复某些条件下客户端生成Message ID重复的问题。aliyun-mq-windows-net-sdk.zip 1.1.3 发布时间 发布内容 Windows版下载 2019-02-01 功能优化 支持实例化用户使用以下两种方式接入（非实例化...
短信发送状态回执错误码
IS_CLOSE 短信下发时通道被关停 阿里云会自动剔除被关停通道，建议稍候重试。PARAMS_ILLEGAL 参数错误 请检查短信签名、短信文案或手机号码等参数是否传入正确。MOBILE_NOT_ON_SERVICE 停机、空号、暂停服务、关机、不在服务区 原因：运营...
普通消息
具体信息，请参见 消费重试。消费提交 消费者完成消费处理，并向服务端提交消费结果，服务端标记当前消息已经被处理（包括消费成功和失败）。云消息队列 RocketMQ 版 默认支持保留所有消息，此时消息数据并不会立即被删除，只是逻辑标记已...
实例规格
客户端可以通过重试避免消息丢失，已经写入成功的消息不受影响。完全独享。磁盘 如果您购买300 GB磁盘，则实际存储业务的磁盘大小为100 GB，其余200 GB为备份容量。如果您购买300 GB磁盘，则实际存储业务的磁盘大小为300 GB，额外赠送600 ...
MQ订阅消息
系统会在有效期内不断进行重试，消费方可能收到多次重试消息 {"EventCatgory":"BIZ","Event":"BIZ_DISPLAY_RETRYING","EventId":"abfhjkfsbeuyftfkhjlj","EventTime":1648096954000,"Payload":{"Type":"ESL","DeviceBarCode":"abcdefg",...
定时/延时消息
具体信息，请参见 消费重试。消费提交 消费者完成消费处理，并向服务端提交消费结果，服务端标记当前消息已经被处理（包括消费成功和失败）。云消息队列 RocketMQ 版 默认支持保留所有消息，此时消息数据并不会立即被删除，只是逻辑标记已...
消息收发定价详情
计费示例 消息收发次数计算示例 服务端每天收到生产者发送的700万条普通消息，由于一个Topic会被多个Group订阅，且考虑到消息消费失败重投的情况，消息投递次数按照800万次预估；每条消息大小为40 KB。服务端每天收到生产者发送的300万条...
消息队列RocketMQ版
test 在 数据处理 区域，设置消息的过滤、转换、重试和死信。消息过滤 无需过滤：默认投递全部事件。自定义配置：使用事件模式匹配特定事件。详细规则，请参见 消息过滤。消息转换 默认配置：默认将消息内容或相关属性映射到目标端。映射...
版本说明
优化特殊场景下客户端发送重试消息分裂出多条重复消息的问题。ons-client-1.8.8.1.Final 1.8.8.Final 发布时间 发布内容 下载 2021-04-02 功能优化 优化了心跳发送逻辑。修复了SDK占用内存过多的问题。修复了消息消费失败发回...
订阅消息API
ReceiptHandle String 消息的句柄，用于确认消息消费成功，句柄仅使用一次，对于同一条消息如果存在重试每次拿到的句柄是不同的，消息句柄应该在到 NextConsumeTime 指定的时间之前使用。PublishTime String 消息的发送时间戳，单位：毫秒...
QueryMqSofamqMessageByKey
Message ID PropertyList Array 消息属性列表 Name String TAGS Key 名 Value String TagA 值 ReconsumeTimes Long 1 消息重试消费的次数 StoreHost String 11.220.*.*:10911 存储该消息的服务器实例 StoreSize Long 407 消息大小 ...
配额与限制
消息消费重试次数 默认值：16次。最大限制：不超过1000次。消费重试次数应根据实际业务需求设置合理的参数值，避免使用重试进行无限触发。重试次数过大容易造成系统压力过量增加。事务异常检查间隔 默认值：60秒。取值范围：不支持自定义...
GetMqSofamqDLQMessageById
Name String TAGS Key 名 Value String TagA 值 ReconsumeTimes Long 1 消息重试消费的次数 StoreHost String 11.220.*.*:10911 存储该消息的服务器实例 StoreSize Long 407 消息大小 StoreTimestamp Long 1570761026708 被服务端存储的...
QueryMqSofamqMessageByTopic
Message ID PropertyList Array 消息属性列表 Name String TAGS Key 名 Value String TagA 值 ReconsumeTimes Long 1 消息重试消费的次数 StoreHost String 11.220.*.*:10911 存储该消息的服务器实例 StoreSize Long 407 消息大小 ...
- 产品推荐
- 这些文档可能帮助您