死信队列与延迟队列专题测试

对

错

对

错

对

错

channel.queueDeclare("my.queue", true, false, false, Collections.singletonMap("x-dead-letter-exchange", "dlx.exchange"));

channel.exchangeDeclare("my.queue", "direct", true); channel.queueBind("my.queue", "dlx.exchange", "");

channel.queueDeclare("my.queue", true, false, false, Collections.singletonMap("dead-letter-exchange", "dlx.exchange"));

channel.basicConsume("my.queue", true, consumer);

channel.basicPublish(exchange, routingKey, null, messageBody.getBytes());

AMQP.BasicProperties props = new AMQP.BasicProperties.Builder().expiration("30000").build(); channel.basicPublish(exchange, routingKey, props, messageBody.getBytes());

Map<String, Object> headers = new HashMap<>(); headers.put("x-delay", 30000); AMQP.BasicProperties props = new AMQP.BasicProperties.Builder().headers(headers).build(); channel.basicPublish(exchange, routingKey, props, messageBody.getBytes());

Map<String, Object> headers = new HashMap<>(); headers.put("x-delay", 30); AMQP.BasicProperties props = new AMQP.BasicProperties.Builder().headers(headers).build(); channel.basicPublish(exchange, routingKey, props, messageBody.getBytes());

队列级 TTL（x-message-ttl）和消息级 TTL（expiration）同时设置时，以消息级 TTL 为准

队列级 TTL（x-message-ttl）和消息级 TTL（expiration）同时设置时，以两者中较小的值为准

消息级 TTL 可以设置得比队列级 TTL 更长，消息会在消息级 TTL 到期后才过期

TTL 过期的消息会被直接丢弃，不会进入死信队列

直接清空死信队列，避免占用过多磁盘空间

先分析死信原因，修复问题后重新发布消息或进行补偿处理

将所有死信消息原样重新发布到原业务队列

增大死信队列的 TTL，让消息自动过期删除

DLX 是一种特殊类型的交换机，只能绑定一个队列

消息进入 DLX 后，会根据 DLX 的路由规则转发到绑定的队列

只有被消费者拒绝的消息才会通过 DLX 转发

DLX 必须由管理员手动创建，RabbitMQ 不会自动处理

在补偿逻辑中检查消息的 x-death 次数，超过阈值则丢弃

使用消息 ID 作为业务幂等键，在补偿前检查是否已处理过

将死信消息直接删除，不进行补偿

每次补偿时修改消息内容并重新发送到死信队列

delayed

direct、fanout 或 topic（即底层路由类型）

x-delay

x-delayed-message

x-death 是一个列表类型，记录消息每次进入死信队列的信息

x-death 中的 reason 字段取值为 rejected、expired 或 maxlen

x-death 中的 queue 字段记录消息从哪个队列被转发为死信

消息多次进入死信队列时，x-death 列表只保留最后一次记录

消费者调用 basicNack(deliveryTag, false, false) 拒绝消息

消息在队列中等待的时间超过了队列的 x-message-ttl 设置

队列的消息数量达到了 x-max-length 限制，最早的消息被溢出

消费者调用 basicAck(deliveryTag, false) 确认消息

业务队列（配置 x-dead-letter-exchange 参数）

死信交换机（DLX）

死信队列（绑定到 DLX）

业务交换机

插件方案的延迟消息存储在交换机内存中，不会进入队列，TTL+DLX 方案的延迟消息先入普通队列等待过期

插件方案支持在运行时动态修改消息的延迟时间，TTL+DLX 方案不支持

插件方案的消息排序行为由插件内部实现控制，TTL+DLX 方案的消息按过期时间先后顺序进入死信队列

插件方案无需额外声明死信交换机和死信队列，TTL+DLX 方案需要

RabbitMQ 只在消息到达队列头部时才检查和过期该消息

消息级 TTL 过期的消息即使不在队列头部，也会被立即移除

设置消息级 TTL 时，所有消息的过期时间必须单调递增

队列级 TTL 通过后台定时扫描实现，不依赖消息位置

需要声明一个"延迟队列"（设置 TTL 和 DLX）和一个"业务队列"（接收到期消息）

延迟队列中不需要消费者，消息到期后自动转发到业务队列

同一延迟队列中消息的 TTL 必须单调递增，否则延迟时间会错乱

可以为不同的延迟时间（5分钟、10分钟、30分钟）创建多个延迟队列来实现分级延迟