死信队列
在左侧导航栏，选择 中间件>消息队列>死信队列。单击 按 Group ID 查询。在 Group ID 的输入框中，输入关键词搜索想要查找的 Group ID，然后选中，或直接在下拉列表中选择想要查找的 Group ID。单击时间选择框，选择想要查询的时间范围的...
死信队列
对于消费失败且重试后依然失败的消息，云消息队列 RocketMQ 版 不会立丢弃，而是将消息转发至指定的队列中，即死信队列，这些消息即为死信消息。当消费失败的原因排查并解决后，您可以重发这些死信消息，让消费者重新消费；若您暂时无法...
重试和死信
容错策略 容错策略即在错误发生时的处理方式，目前支持两类容错方式：允许容错（推荐）：允许异常容错，当异常发生时不会阻塞执行，超过最大重试次数后会根据配置将消息投递至死信队列或直接丢弃。禁止容错：不允许容错，当异常发生并超过...
重试和死信
死信队列 死信消息队列将以任务维度为依据进行限制，当发生无法处理或者超过重试次数的情况时，会将失败的原始数据原封不动发送至消息队列，该选项默认为不启用状态。说明 当前仅支持将死信发送至 云消息队列 RocketMQ 版 和 消息服务MNS。
重试和死信
容错策略 容错策略即在错误发生时的处理方式，目前支持两类容错方式：允许容错（推荐）：允许异常容错，当异常发生时不会阻塞执行，超过最大重试次数后会根据配置将消息投递至死信队列或直接丢弃。禁止容错：不允许容错，当异常发生并超过...
OnsDLQMessageResendById-重发指定的死信消息
死信消息已达最大重试次数，若重发后再次消费失败，则死信队列中将增加一条 Message ID 相同的消息，可通过控制台死信队列的查询页面或者管控 API 查看该结果。您可通过同一 Message ID 的消息出现次数判断重发后依然消费失败的次数。由于...
重试和死信
容错策略 容错策略即在错误发生时的处理方式，目前支持两类容错方式：允许容错（推荐）：允许异常容错，当异常发生时不会阻塞执行，超过最大重试次数后会根据配置将消息投递至死信队列或直接丢弃。禁止容错：不允许容错，当异常发生并超过...
OnsDLQMessageGetById-根据Message ID查询死信消息
通过传入Message ID查询指定的死信消息。包括存储时间、消息体、Key和Tag。接口说明 注意 阿里云提供的 OpenAPI 属于管控类 API，用于管理和查询阿里云服务的相关资源。仅推荐在管控链路集成，消息收发的核心...具体操作，请参见 死信队列。
查询Group ID内所有死信消息
通过传入Group ID和时间段，分页查询指定时间段内该Group ID内存在的所有死信消息。接口说明 注意 阿里云提供的 OpenAPI 属于管控类 API，用于管理和查询阿里云服务的相关资源。仅推荐在管控链路集成，消息收发...具体操作，请参见 死信队列。
DeadLetterQueue
名称 类型 描述 示例值 object 死信队列资源标识，支持如下云产品作为死信队列：消息服务 MNS 云消息队列 RocketMQ 版 消息队列 Kafka 版 事件总线 EventBridge Arn string 死信队列 ARN。acs:mq:cn-shanghai:14319991365*:/instances/MQ_...
DeadLetterQueue
名称 类型 描述 示例值 object EventBridge 触发器的死信队列配置 Arn string 死信队列的 ARN acs:mq:cn-shanghai:14319991365*:/instances/MQ_INST_14319991365*_BYWs*/topic/testTopic
重试和死信
死信队列 死信队列将以任务维度为依据进行限制，当发生无法处理或者超过重试次数的情况时，会将失败的原始数据原封不动发送至消息队列，该选项默认为不启用状态。说明 当前支持将死信发送至 云消息队列 RocketMQ 版、消息服务MNS、云消息...
RunOptions
配置该参数即为启用死信队列，默认不启用死信队列，超过重试策略后的消息将被丢弃。支持配置消息服务 MNS、云消息队列 RocketMQ 版、消息队列 Kafka 版以及事件总线 EventBridge。errorsTolerance string 异常容忍策略，包含如下两种策略：...
版本说明
0.7(2020-04-25)新增 死信队列功能。通过该功能，即可在管控台直接查询和重新发送进入死信队列的死信消息。详见 死信队列。报警管理功能。通过该功能，即可监控某 Group ID 订阅的某 Topic 的消息消费状态并接收报警短信，以便及时处理消费...
RunOptions
deadLetterQueue DeadLetterQueue 是否启用死信队列。默认不启用死信队列，超过重试策略后的消息将被丢弃。maximumTasks long 并发配额（消费者数量）。1 errorsTolerance string 异常容忍策略：NONE：不容忍异常。ALL：容忍所有异常。ALL ...
PutTargets-在指定的规则下创建或更新事件目标
Arn string 否 死信队列的 Arn，未处理或超过重试次数的事件会被写入死信队列。acs:mns:cn-hangzhou:123456789098*:/queues/deadletterqueue 或 acs:mq:cn-hangzhou:123456789098*:/instances/MQ_INST_123456789098*_BX8QbBPL/topic/...
通过原始日志快速分析和定位问题
本文介绍基于 云消息队列 ...822e-72dfad2a*or ResourceName:deliveryTag=1)其中 PushMessage 日志表示服务端推送消息到客户端，客户端在收到消息后调用 BasicReject(requeue=false)，对应 SendDlqMessage 日志表示消息被路由到死信队列中。
API 概览
ListMqSofamqTrace 查询消息轨迹查询任务列表 死信队列 API 描述 GetMqSofamqDLQMessageById 通过消息 ID 查询死信消息 QueryMqSofamqDLQMessageByGroupId 通过 Group 查询死信消息 ResendMqSofamqDLQMessageById 重发死信消息 ...
CreateRule-创建一个事件规则
Arn string 否 死信队列的 Arn，未处理或超过重试次数的事件会被写入死信队列。支持消息服务 MNS 和消息队列 RocketMQ 版。acs:mns:cn-hangzhou:123456789098*:/queues/deadletterqueue 或 acs:mq:cn-hangzhou:123456789098*:/instances/MQ...
基本概念
死信队列 死信队列用于处理无法被正常消费的消息。当一条消息初次消费失败，云消息队列 RocketMQ 版 会自动进行 消息重试；达到最大重试次数后，若消费依然失败，则表明Consumer在正常情况下无法正确地消费该消息。此时，云消息队列 ...
集成概述
死信队列 支持 消息服务MNS 和 云消息队列 RocketMQ 版 等服务做死信队列。支持 云消息队列 Kafka 版 做死信队列。重试策略 统一支持。部分支持。依赖Kafka资源 不额外依赖。系统自动或手动创建任务位点Topic、任务配置Topic、任务状态...
产品优势
超过最大重试次数后的消息进入死信队列，死信消息可查询、可导出。死信Exchange 增强型死信Exchange，不仅支持被否定应答的消息，还支持重试失败的消息自动进入死信Exchange，确保消息不丢失。超强性能 平台性能上限 支持百万级队列，横向...
功能与特性概述
死信队列：将无法正常消费的消息储存到特殊的死信队列供后续处理。仪表盘：提供丰富、全面、多维度的统计指标，您可以分别从实例、Topic和Group维度查看消息生产指标、消息消费指标以及消息堆积等相关指标。监控报警：您可使用 云消息队列 ...
消息重试
您可以通过消费死信队列中的死信消息来恢复业务异常。消息重试主要功能行为包括：重试间隔：上一次消费失败或超时后，距下次消息可被重新消费的间隔时间。最大重试次数：消息消费失败后，可被 云消息队列 RocketMQ 版 重复投递的最大次数。...
配置消息监控告警实现风险预警
配置死信消息告警最佳实践 背景：消息队列RocketMQ版支持死信消息，将消费失败并超过重试次数的消息投递至死信队列，以便您后续进行人工处理。监控进入死信队列的消息量可以帮助您及时预警当前业务出现的非预期且无法判断的异常问题。未...
消费者分组（ConsumerGroup）
消费重试策略：消费者消费消息失败时的重试策略，包括重试次数、死信队列设置等。具体信息，请参见 消费重试。模型关系 在 云消息队列 RocketMQ 版 的领域模型中，消费者分组的位置和流程如下：消息由生产者初始化并发送到 云消息队列 ...
路由到云消息队列 Kafka 版
部分事件$.data.key 任务属性 设置事件流的重试策略及死信队列。更多信息，请参见 重试和死信。返回 事件流 页面，找到创建好的事件流，在其右侧 操作 栏，单击 启用。启用事件流后，会有30秒~60秒的延迟时间，您可以在 事件流 页面的 状态...
通过EventBridge快速订阅ECS事件
当下游事件接收端出现异常（如宕机、服务不可用、网络抖动等），导致接收端无法正常接收事件时，EventBridge 支持多种方式处理这些异常，包括：重试策略、容错策略、死信队列。您可以在 步骤二：创建ECS事件订阅规则 中，配置重试和死信...
通过EventBridge快速订阅ECS事件
当下游事件接收端出现异常（如宕机、服务不可用、网络抖动等），导致接收端无法正常接收事件时，EventBridge 支持多种方式处理这些异常，包括：重试策略、容错策略、死信队列。您可以在 步骤二：创建ECS事件订阅规则 中，配置重试和死信...
路由到云消息队列 RabbitMQ 版
部分事件$.data.props 任务属性 设置事件流的重试策略及死信队列。更多信息，请参见 重试和死信。返回 事件流 页面，找到创建好的事件流，在其右侧 操作 栏，单击 启用。启用事件流后，会有30秒~60秒的延迟时间，您可以在 事件流 页面的 ...
路由到云消息队列 RocketMQ 版
部分事件$.data.systemProperties.TAGS 任务属性 设置事件流的重试策略及死信队列。更多信息，请参见 重试和死信。返回 事件流 页面，找到创建好的事件流，在其右侧 操作 栏，单击 启用。启用事件流后，会有30秒~60秒的延迟时间，您可以在 ...
创建Kafka Sink Connector
部分事件$.data.key 任务属性 设置此任务的重试策略及死信队列。更多信息，请参见 重试和死信。返回 任务列表 页面，找到创建好的任务，在其右侧 操作 列，单击 启用。在 提示 对话框，阅读提示信息，然后单击 确认。启用任务后，会有30秒~...
创建MNS Sink Connector
完整事件 任务属性 设置此任务的重试策略及死信队列。更多信息，请参见 重试和死信。返回 任务列表 页面，找到创建好的任务，在其右侧 操作 列，单击 启用。在 提示 对话框，阅读提示信息，然后单击 确认。启用任务后，会有30秒~60秒的延迟...
SDK参考概述
普通消息 顺序消息 定时和延时消息 事务消息 PushConsumer PullConsumer 批量消费 广播消费 集群消费 消息重试 查询消息轨迹 死信队列 重置消费位点 SDK使用说明 HTTP协议和TCP协议的接入点不可混用。例如，您使用TCP协议的SDK收发消息，您...
消息轨迹
进死信时间 消息消费失败被投递至死信队列的时间。使用限制 RocketMQ 4.x/3.x 版本的SDK客户端默认不开启消息轨迹功能，您需要在消息收发代码中开启消息轨迹功能，才能在控制台查询到消息的轨迹信息。具体配置如下：生产者 producer....
创建FC Sink Connector
完整事件 任务属性 设置此任务的重试策略及死信队列。更多信息，请参见 重试和死信。返回 任务列表 页面，找到创建好的任务，在其右侧 操作 列，单击 启用。在 提示 对话框，阅读提示信息，然后单击 确认。启用任务后，会有30秒~60秒的延迟...
基于事件流实现MNS消息路由
完整事件 任务属性 设置事件流的重试策略及死信队列。更多信息，请参见 重试和死信。返回 事件流 页面，找到创建好的事件流，在其右侧 操作 栏，单击 启用。启用事件流后，会有30秒~60秒的延迟时间，您可以在 事件流 页面的 状态 栏查看...
EventBridge事件调度
MQTT调度 云消息队列 MQTT 版 作为事件源通过 事件总线 与 云工作流 调度集成后，通过云消息队列 MQTT 版调度能够触发关联工作流执行，通过 云工作流 可以对发布到 云消息队列 MQTT 版 的消息进行自定义处理。本文介绍如何在控制台创建MQTT...
云消息队列 Kafka 版
任务属性 设置事件流的重试策略及死信队列。更多信息，请参见 重试和死信。返回 事件流 页面，找到创建好的事件流，在其右侧 操作 栏，单击 启用。启用事件流后，会有30秒~60秒的延迟时间，您可以在 事件流 页面的 状态 栏查看启动进度。...
- 产品推荐
- 这些文档可能帮助您