不能直接用ThinkPHP定时任务处理超时订单，因其轮询延迟大、易漏检重复执行且无法精准控制30分钟时效；应采用RabbitMQ死信队列方案，通过队列级TTL+DLX实现可靠延迟消息。
为什么不能直接用 ThinkPHP 的定时任务处理超时订单
因为 think:timer 或 Cron 轮询检查订单状态，存在明显延迟（最小精度通常为 1 分钟），且在高并发下容易漏检或重复执行；更重要的是，它无法做到「订单创建即刻绑定 30 分钟后触发」的精准时效控制。RabbitMQ 的 delayed message 插件或死信队列（DLX）才是更可靠的选择。
如何配置 RabbitMQ 支持延迟消息（以 DLX 方式为例）
官方不原生支持延迟投递，需通过「设置 TTL + 死信交换机」组合实现。关键点不是安装插件，而是声明队列时正确绑定死信属性：
- 创建一个普通队列
order_timeout_queue，设置x-message-ttl=1800000（30 分钟毫秒值） - 同时设置
x-dead-letter-exchange=dlx.order和x-dead-letter-routing-key=order.cancel - 再声明死信交换机
dlx.order（类型direct），并绑定到真正消费取消逻辑的队列order_cancel_queue
注意：TTL 必须设在队列（queue）级别，而非单条消息——否则 RabbitMQ 会忽略；ThinkPHP 使用 php-amqplib/php-amqplib 时，通过 $channel->queue_declare() 的 $arguments 参数传入上述键值对。
在 ThinkPHP 中发送延迟消息的具体写法
不要在控制器里直接 new AMQP 连接，应封装为服务类（如 OrderTimeoutService），并在订单创建成功后调用：
立即学习“PHP免费学习笔记（深入）”；
// 示例：投递一条 30 分钟后触发的取消消息
$connection = new \PhpAmqpLib\Connection\AMQPStreamConnection(
config('rabbitmq.host'),
config('rabbitmq.port'),
config('rabbitmq.user'),
config('rabbitmq.password')
);
$channel = $connection->channel();
// 注意：这里只是发布消息，队列和死信已在初始化时声明好
$msg = new \PhpAmqpLib\Message\AMQPMessage(
json_encode(['order_id' => $orderId]),
['content_type' => 'application/json']
);
$channel->basic_publish($msg, '', 'order_timeout_queue'); // 路由到普通队列，靠 TTL 触发流转
常见错误：basic_publish 误将消息发到死信交换机；或未确保 order_timeout_queue 已被声明（首次运行需手动声明或加幂等初始化逻辑）。
消费者如何稳定监听并执行取消逻辑
用命令行启动常驻消费者（如 php think rabbitmq:consume），避免 Web 请求生命周期干扰：
- 消费者必须独占绑定
order_cancel_queue，且开启auto_ack=false - 业务逻辑执行失败时，调用
$channel->basic_nack($delivery_info['delivery_tag'])拒绝消息，防止丢失 - 取消前先查数据库确认订单仍为「待支付」状态——防止重复消费导致误取消
- 建议加 Redis 锁（
SET order_cancel_lock_{$orderId} 1 EX 60 NX），应对多实例部署下的竞争
最关键的细节：消费者进程必须能被平滑重启（如收到 SIGTERM 时完成当前消息再退出），否则正在处理的取消动作可能中断，而 RabbitMQ 不会重发已 ack 的消息。
