java中用rabbitmq实现“超时未支付自动关闭”的核心是利用ttl和死信队列机制：订单消息发至带ttl的队列，超时后自动进入死信队列，由监听该队列的消费者执行关单逻辑。

Java 中用 RabbitMQ 实现“超时未支付自动关闭”，核心是结合消息的 TTL（Time-To-Live）和死信队列（DLX + DLK）机制：把订单支付等待消息发到一个带 TTL 的队列，到期未被消费就自动进入死信队列，由监听死信队列的消费者触发关单逻辑。

1. 声明带 TTL 的业务队列并绑定死信交换机

创建一个普通队列时，通过 x-message-ttl 设置消息过期时间（单位毫秒），同时用 x-dead-letter-exchange 和 x-dead-letter-routing-key 指定死信转发目标。注意：TTL 设在队列上是整队列统一过期；设在消息上更灵活（优先级更高），但需生产者显式设置。

• 推荐方式：队列级 TTL + 死信配置（简单、易维护）
• 示例声明（Spring AMQP）：

@Bean
public Queue payWaitQueue() {
    return QueueBuilder.durable("queue.pay.wait")
            .withArgument("x-message-ttl", 15 * 60 * 1000) // 15分钟
            .withArgument("x-dead-letter-exchange", "exchange.dlx")
            .withArgument("x-dead-letter-routing-key", "routing.key.close.order")
            .build();
}

2. 声明死信交换机与死信队列并绑定

死信交换机一般用 direct 类型，死信队列正常声明即可，再通过路由键绑定到该交换机。这个队列就是专门处理超时消息的地方。

Docker Image Puller

使用 Python 脚本下载 Docker 镜像并打包为 tar 文件。用户说“下载镜像”“拉取镜像”“pull xxx”“帮我下载 nginx 镜像”等时触发。支持 SOCKS5 代理直连（推荐）和国内镜像站加速两种模式。

下载

• 死信交换机无需特殊配置，普通 direct exchange 即可
• 死信队列建议设置 durable=true，避免重启丢失待处理关单任务
• 绑定关系必须与队列中指定的 x-dead-letter-routing-key 一致

3. 发送支付等待消息（不设消息级 TTL，复用队列 TTL）

下单成功后，向 payWaitQueue 发送一条包含订单 ID 的消息。由于队列已设 TTL，该消息会在 15 分钟后自动过期，并被 RabbitMQ 投递到死信交换机，再路由到死信队列。

• 发送时无需额外设置 expiration 属性（除非需要为不同订单设不同超时）
• 消息体建议含 orderId、timestamp、bizType 等字段，方便关单逻辑使用
• 确保发送时 routing key 匹配业务队列绑定的 key（如 "" 或 "#"，取决于绑定方式）

4. 消费死信队列，执行关单操作

为死信队列单独配置一个消费者，收到消息后根据订单 ID 查询当前状态：若仍为“待支付”，则调用关单服务更新订单状态、释放库存等；若已是“已支付”或“已关闭”，直接忽略。

• 关单前务必校验订单最新状态，防止重复处理或误关已支付订单
• 建议加分布式锁或数据库乐观锁，避免多实例并发处理同一订单
• 处理失败需记录日志，必要时投递到重试队列（如延迟重试队列）

Java免费学习笔记：立即使用
解锁 Java 大师之旅：从入门到精通的终极指南