延时消息定义
延时消息是指消息在发送后不会立即投递给消费者，而是在指定的延迟时间之后才可被消费。
开源 RabbitMQ 本身不直接支持原生延时消息语义，但可以通过现有机制组合或官方插件实现类似能力。
应用场景
延时消息适用于需要定时触发或延迟处理的业务场景，例如：
订单超时关闭
下单成功后发送延时消息，30 分钟后检查支付状态，未支付则关闭订单。提醒通知
预约活动开始前，通过延时消息发送提醒。任务调度
延迟执行数据清理、报表生成、状态检查等后台任务。
实现方案对比
| 方案 | 实现原理 | 特点 |
|---|---|---|
| 死信队列（DLX）+ TTL | 利用消息或队列 TTL 过期后转入死信交换机，再重新路由到消费队列 | 无需插件，兼容性好；配置复杂，延迟精度有限 |
| 延时消息插件 | 使用官方延时交换机，消息到期后才进入正常路由流程 | 使用简单、精度高；需安装插件，存在版本依赖 |
方案一：死信队列（DLX）+ TTL
实现原理
RabbitMQ 支持为：
消息 设置 TTL（
expiration）队列 设置 TTL（
x-message-ttl）
当消息到达 TTL 后不会立即删除，而是被投递到死信交换机（Dead Letter Exchange, DLX），再由 DLX 路由到目标队列，从而实现“延迟消费”。
流程说明
创建 死信交换机（DLX） 和 死信队列
创建业务队列，并配置：
x-dead-letter-exchangex-dead-letter-routing-key
消息进入业务队列并等待 TTL 到期
消息过期后转入 DLX
消费者从最终队列中消费消息
代码示例
// 声明死信交换机
channel.exchangeDeclare("dlx_exchange", "direct", true);
// 声明死信队列
channel.queueDeclare("dlx_queue", true, false, false, null);
channel.queueBind("dlx_queue", "dlx_exchange", "dlx_routing_key");
// 创建业务队列并设置死信规则Map<String, Object> args = new HashMap<>();
args.put("x-dead-letter-exchange", "dlx_exchange");
args.put("x-dead-letter-routing-key", "dlx_routing_key");
args.put("x-message-ttl", 10000); //队列级TTL：10秒
channel.queueDeclare("business_queue", true, false, false, args);
//发送消息（消息级 TTL）
AMQP.BasicProperties props = new AMQP.BasicProperties.Builder()
.expiration("5000") // 5 秒后过期
.build();
channel.basicPublish("","business_queue",props,"延迟消息".getBytes(StandardCharsets.UTF_8));特点说明
TTL 优先级
同时设置消息 TTL 和队列 TTL 时，取较小值
延迟精度
依赖队列头部过期检查机制，精度非严格实时
实现成本
无需额外组件，但配置相对复杂
方案二：延时消息插件方案
实现原理
通过声明特殊类型的交换机，使消息在 Exchange 层面延迟投递。
消息在延迟时间到期前不会进入正常路由流程。
前提条件
RabbitMQ 版本 ≥ 3.8
启用官方插件：
rabbitmq-plugins enable rabbitmq_delayed_message_exchange
天翼云RabbitMQ默认启用延迟交换器交换器插件，无需操作
使用步骤
声明
x-delayed-message类型交换机指定底层路由类型（
x-delayed-type）发送消息时在 Header 中设置
x-delay（毫秒）
代码示例
//声明延时交换机
Map<String, Object> args = new HashMap<>();
args.put("x-delayed-type","direct");
channel.exchangeDeclare("delayed_exchange","x-delayed-message",true,false,args);
// 声明并绑定队列
channel.queueDeclare("target_queue",true,false,false,null);
channel.queueBind("target_queue","delayed_exchange","routing_key");
//发送延时消息（延迟 5 秒）
Map<String, Object> headers = new HashMap<>();
headers.put("x-delay",5000);
AMQP.BasicProperties props = new AMQP.BasicProperties.Builder()
.headers(headers)
.build();
channel.basicPublish("delayed_exchange","routing_key",props,"延时消息".getBytes(StandardCharsets.UTF_8));特点说明
延迟精度高，使用方式直观
延迟逻辑在 Exchange 层完成
依赖插件及 RabbitMQ 版本兼容性
注意事项
精度与可靠性
DLX + TTL
可能存在毫秒级到秒级误差
插件方案
延迟精度更高，更适合严格定时场景
资源消耗
延时消息在到期前会占用 Broker 内存
大量长延时消息需重点监控：
队列堆积
内存水位
磁盘使用率
消息顺序
延时消息可能打乱原始发送顺序
对顺序敏感的业务需在消费端自行处理
总结
开源 RabbitMQ 不提供原生延时语义
可通过两种方式实现延时消息能力：
死信队列 + TTL：通用、稳定，但灵活性有限
延时消息插件：精度高、使用简单，但依赖部署环境
实际选型需综合考虑：
延迟精度要求
运维复杂度
消息规模与资源成本
