# ZSet 天然適合：
ZADD delay_queue 1718000000 "task_001"   # score=到期時間戳
ZADD delay_queue 1718000300 "task_002"   # 自動按時間排序

生產(chǎn)者                     Redis ZSet                      消費者(定時任務)
──────                    ──────────                      ──────────────
XADD delay_q              score  = 到期時間戳
score=到期時間            member = 任務數(shù)據(jù)
                          ┌─────────────────┐
                          │ 1718000000 task1 │  ← 最早到期
                          │ 1718000300 task2 │
                          │ 1718000600 task3 │
                          └─────────────────┘
                                  ↓
                          ZRANGEBYSCORE 0 當前時間
                          取到 task1（已到期）
                                  ↓
                          執(zhí)行 task1 → ZREM 刪除

// 生產(chǎn)者：投遞延時任務
$redis->zAdd('delay:orders', time() + 1800, json_encode([
    'order_id' => 12345,
    'action'   => 'auto_cancel',
]));
// 消費者：每秒輪詢到期任務（有 BUG 的版本）
$now = time();
$tasks = $redis->zRangeByScore('delay:orders', 0, $now, ['limit' => [0, 1]]);
if ($tasks) {
    $task = $tasks[0];
    // ?? 這里有 BUG！如果同時多個消費者拿到同一條
    $redis->zRem('delay:orders', $task);
    processTask($task);
}

-- 原子操作：查出到期任務 + 立刻刪除 + 返回
local tasks = redis.call('ZRANGEBYSCORE', KEYS[1], 0, ARGV[1], 'LIMIT', 0, 1)
if #tasks == 0 then
    return nil
end
local task = tasks[1]
local removed = redis.call('ZREM', KEYS[1], task)
if removed == 1 then
    return task       -- 刪除成功，返回任務
else
    return nil        -- 被別的消費者搶了
end

$lua = <<<'LUA'
local tasks = redis.call('ZRANGEBYSCORE', KEYS[1], 0, ARGV[1], 'LIMIT', 0, 1)
if #tasks == 0 then return nil end
local task = tasks[1]
if redis.call('ZREM', KEYS[1], task) == 1 then
    return task
else
    return nil
end
LUA;
// 定時任務循環(huán)執(zhí)行
while (true) {
    $task = $redis->eval($lua, ['delay:orders', time()], 1);
    //                                      ↑ KEYS 部分       ↑ key數(shù)量
    if ($task) {
        $data = json_decode($task, true);
        echo "處理任務: {$data['order_id']}\n";
        processTask($data);
    } else {
        sleep(1);  // 沒任務就等一下
    }
}

<?php
// ====== 生產(chǎn)者（下單時） ======
function createOrder($orderId) {
    $redis = new Redis();
    $redis->connect('127.0.0.1', 6380);
    // 1. 創(chuàng)建訂單...
    // 2. 投遞延時任務：30分鐘后自動取消
    $delayAt = time() + 1800;  // 30分鐘
    $task = json_encode([
        'order_id' => $orderId,
        'action'   => 'auto_cancel',
        'create_at'=> date('Y-m-d H:i:s'),
    ]);
    $redis->zAdd('delay:orders', $delayAt, $task);
    echo "訂單 {$orderId} 已創(chuàng)建，30分鐘后未支付將自動取消\n";
}
// ====== 消費者（定時腳本） ======
$lua = <<<'LUA'
local tasks = redis.call('ZRANGEBYSCORE', KEYS[1], 0, ARGV[1], 'LIMIT', 0, 1)
if #tasks == 0 then return nil end
if redis.call('ZREM', KEYS[1], tasks[1]) == 1 then
    return tasks[1]
end
return nil
LUA;
while (true) {
    $task = $redis->eval($lua, ['delay:orders', time()], 1);
    if ($task) {
        $data = json_decode($task, true);
        // 檢查訂單是否已支付
        $order = getOrder($data['order_id']);
        if ($order['status'] === 'unpaid') {
            cancelOrder($data['order_id']);
            echo "? 訂單 {$data['order_id']} 超時未支付，已自動取消\n";
        } else {
            echo "? 訂單 {$data['order_id']} 已支付，跳過\n";
        }
    } else {
        sleep(1);
    }
}

ZADD key score member
          ↑
     你自己指定的

ZADD delay_queue 1718000000 "task_001"
#                 ↑    時間戳就是 score，你自己算的
#                 score 決定了 ZSet 里的排序