什么是死信Exchange_云消息队列 RabbitMQ 版-阿里云帮助中心

云消息队列 RabbitMQ 版的死信Exchange适用于处理被消费者否定应答或重试失败的消息。本文介绍死信Exchange的核心概念、路由流程、配置方式、注意事项和更多信息。

核心概念

死信Exchange
- 用于路由死信消息的Exchange。死信Exchange会根据Binding Key、死信Routing Key、Header属性将死信消息投递至死信Queue。死信Exchange可以是任何一种常见类型的Exchange，例如Direct Exchange。
死信Routing Key
- 死信消息的路由规则。如果不设置死信消息的Routing Key，则死信消息的Routing Key默认为消息本身的Routing Key。
死信消息
- 被重新发送到死信Exchange的消息。消息变成死信消息的可能原因如下：
  - requeue参数被设置为 false，消费者使用basic.reject或basic.nack否定应答（NACK）消息。
  - 消息重试次数超过16次，消息重试失败。具体信息，请参见消息超时和重试机制。
  - 消息过期，即消息在Queue中存在的时间超过了设置的消息存活时间。具体信息，请参见消息存活时间。
死信Queue
- 死信Exchange绑定的Queue，用于存储死信消息。

路由流程

死信Exchange路由死信消息的流程如下：

生产者将消息发送到Exchange。
Exchange将消息路由到Queue。
消费者从Queue拉取消息。
消费者消费失败后消息重试次数超过16次依然没有成功，或者消费者没有消费消息而直接否定应答，消息变成死信消息。
Queue根据x-dead-letter-exchange将死信消息发送到死信Exchange，并根据x-dead-letter-routing-key为死信消息设置死信Routing Key。
死信Exchange将死信消息路由到死信Queue。

注意事项

云消息队列 RabbitMQ 版不支持跨Vhost路由死信消息，即Queue被指定的死信Exchange必须和该Queue在同一个Vhost内。
云消息队列 RabbitMQ 版不支持修改Queue的死信Exchange。如果您需要修改某个Queue的死信Exchange，您需要删除该Queue后，在重新创建时设置死信Exchange。

配置方式

云消息队列 RabbitMQ 版支持以下方式配置死信Exchange：

控制台

您可以在云消息队列 RabbitMQ 版控制台创建Queue时，为其配置死信Exchange。

登录云消息队列 RabbitMQ 版控制台。
在概览页面的资源分布区域，选择地域。
在实例列表页面，单击目标实例名称。
在左侧导航栏，单击Queue 列表。
在Queue 列表页面，在当前 Vhost右侧的切换下拉列表中，选择Vhost，单击创建 Queue。

在创建 Queue面板，在Queue 名称文本框输入Queue的名称，选择是否为Auto Delete类型，单击高级选项，设置Queue的参数，然后单击确定。

参数	描述	说明
Queue 名称	Queue的名称	只能包含字母、数字、短划线（-）、下划线（_）、半角句号（.）、井号（#）、正斜线（/）、at符号（@）。长度限制在1~255字符。创建后无法修改，只能删除重建。以amq.开头的为保留字段，因此不能使用。例如：amq.test。
Auto Delete	最后一个Consumer取消订阅后，Queue是否自动删除。	true：在订阅该Queue消息的最后一个Consumer取消订阅该Queue的消息后，自动删除该Queue。 false：在订阅该Queue消息的最后一个Consumer取消订阅该Queue的消息后，不自动删除该Queue。
高级选项	Queue的参数设置，可用于设置死信Exchange、死信Routing Key和消息存活时间。	DeadLetterExchange：指定死信消息发送的目标Exchange。 DeadLetterRoutingKey：指定死信消息的Routing Key，即死信Exchange会将消息发送至匹配该死信Routing Key的Binding Key所对应的Queue。 MessageTTL：消息存活时间，单位毫秒（ms）。超过指定时间消息还未被成功消费则变为死信消息，该消息将会被发送到死信Exchange。更多信息，请参见消息存活时间。

API

您可以在通过API创建Queue时，为其配置死信Exchange。更多信息，请参见CreateQueue。

客户端

您可以在云消息队列 RabbitMQ 版客户端声明Queue时，为其配置死信Exchange。

通过x-dead-letter-exchange和x-dead-letter-routing-key设置死信消息要发送的Exchange以及死信消息的Routing Key。

例如，声明一个名称为some.exchange.name、类型为direct的Exchange，使用 x-dead-letter-exchange将该Exchange设置为死信Exchange，使用x-dead-letter-routing-key将死信消息的Routing Key设置为demo-routing-key。

Java示例代码如下：

channel.exchangeDeclare("some.exchange.name", "direct");
Map<String, Object> args = new HashMap<String, Object>();
arguments.put("x-dead-letter-exchange", "some.exchange.name");
arguments.put("x-dead-letter-routing-key", "demo-routing-key");
channel.queueDeclare("MyQueue", false, false, false, arguments);