当前位置：首页 > PHP

实现延迟队列php

2026-03-13 09:33:02PHP

延迟队列的实现方法

在PHP中实现延迟队列可以通过多种方式完成，以下是几种常见的方法：

基于Redis的延迟队列

使用Redis的有序集合（Sorted Set）可以实现延迟队列。将任务添加到有序集合中，分数设置为任务的执行时间戳。通过定时轮询有序集合中分数小于当前时间戳的任务来执行。

实现延迟队列php

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

// 添加延迟任务
$redis->zAdd('delayed_queue', time() + 60, 'task_data');

// 消费延迟任务
while (true) {
    $tasks = $redis->zRangeByScore('delayed_queue', 0, time());
    foreach ($tasks as $task) {
        // 处理任务
        processTask($task);
        $redis->zRem('delayed_queue', $task);
    }
    sleep(1);
}

基于数据库的延迟队列

使用数据库表存储延迟任务，通过定时查询来获取到期的任务。

实现延迟队列php

// 添加延迟任务
$pdo = new PDO('mysql:host=localhost;dbname=test', 'username', 'password');
$stmt = $pdo->prepare("INSERT INTO delayed_queue (task_data, execute_time) VALUES (?, ?)");
$stmt->execute(['task_data', time() + 60]);

// 消费延迟任务
$stmt = $pdo->prepare("SELECT * FROM delayed_queue WHERE execute_time <= ?");
$stmt->execute([time()]);
$tasks = $stmt->fetchAll(PDO::FETCH_ASSOC);
foreach ($tasks as $task) {
    processTask($task['task_data']);
    $pdo->prepare("DELETE FROM delayed_queue WHERE id = ?")->execute([$task['id']]);
}

基于消息队列的延迟队列

使用RabbitMQ等消息队列的延迟插件可以实现延迟队列功能。

// 使用RabbitMQ的延迟插件
$connection = new AMQPConnection([
    'host' => 'localhost',
    'port' => 5672,
    'login' => 'guest',
    'password' => 'guest'
]);
$connection->connect();
$channel = new AMQPChannel($connection);

$exchange = new AMQPExchange($channel);
$exchange->setName('delayed_exchange');
$exchange->setType('x-delayed-message');
$exchange->setArguments(['x-delayed-type' => 'direct']);
$exchange->declareExchange();

$queue = new AMQPQueue($channel);
$queue->setName('delayed_queue');
$queue->declareQueue();
$queue->bind('delayed_exchange', 'delayed_routing_key');

// 发送延迟消息
$exchange->publish('task_data', 'delayed_routing_key', AMQP_NOPARAM, [
    'headers' => ['x-delay' => 60000] // 延迟60秒
]);

// 消费延迟消息
$queue->consume(function($envelope, $queue) {
    processTask($envelope->getBody());
    $queue->ack($envelope->getDeliveryTag());
});