如何通过PHP队列实现消息的延迟发送？

sudo apt-get install redis-server
sudo apt-get install php-redis

$redis = new Redis();
$redis->connect('127.0.0.1', 6379);

// 将消息添加到队列中，设置延迟发送时间为5分钟
function addDelayedMessage($message, $delay)
{
    global $redis;

    // 计算消息的发送时间
    $delayedTime = time() + $delay;

    // 将消息添加到队列中
    $redis->zAdd('delayed_queue', $delayedTime, $message);
}

// 检查是否有需要发送的消息
function checkDelayedMessages()
{
    global $redis;

    while (true) {
        // 获取下一条需要发送的消息
        $message = $redis->zRangeByScore('delayed_queue', 0, time(), ['limit' => [0, 1]]);

        if (count($message) > 0) {
            // 发送消息的逻辑，这里只是简单地打印消息
            echo "发送消息：" . $message[0] . PHP_EOL;

            // 从队列中移除已发送的消息
            $redis->zRem('delayed_queue', $message[0]);
        } else {
            // 没有需要发送的消息，退出循环
            break;
        }
    }
}

// 添加延迟发送的消息
addDelayedMessage('消息1', 300); // 5分钟后发送
addDelayedMessage('消息2', 600); // 10分钟后发送

// 检查是否有需要发送的消息
checkDelayedMessages();