当前位置：首页 > PHP

php使用redis实现队列

2026-01-28 22:39:51PHP

PHP 使用 Redis 实现队列

Redis 是一个高性能的键值存储系统，支持多种数据结构，如字符串、哈希、列表、集合等。利用 Redis 的列表（List）数据结构可以轻松实现队列功能。以下是实现队列的几种常见方法：

基本队列操作（先进先出）

使用 Redis 的 LPUSH 和 RPOP 命令可以实现基本的队列功能。LPUSH 将元素插入列表头部，RPOP 从列表尾部移除元素。

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

// 入队（将任务添加到队列）
$redis->lPush('task_queue', 'task1');
$redis->lPush('task_queue', 'task2');

// 出队（从队列中获取任务）
$task = $redis->rPop('task_queue');
echo $task; // 输出: task1
?>

阻塞式队列

如果需要队列在为空时阻塞等待新任务，可以使用 BRPOP 命令。BRPOP 会阻塞连接直到队列中有新元素或超时。

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

// 阻塞式出队（等待最多 5 秒）
$task = $redis->brPop('task_queue', 5);
if ($task) {
    echo $task[1]; // 输出队列中的任务
}
?>

优先级队列

通过多个列表实现优先级队列。高优先级任务放入高优先级队列，低优先级任务放入低优先级队列。使用 BRPOP 按优先级顺序检查队列。

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

// 高优先级任务入队
$redis->lPush('high_priority_queue', 'urgent_task');

// 低优先级任务入队
$redis->lPush('low_priority_queue', 'normal_task');

// 按优先级出队（先检查高优先级队列）
$task = $redis->brPop(['high_priority_queue', 'low_priority_queue'], 0);
echo $task[1]; // 输出: urgent_task
?>

延迟队列

使用 Redis 的有序集合（Sorted Set）可以实现延迟队列。将任务的执行时间作为分数，定时检查并处理到期的任务。

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

// 添加延迟任务（5 秒后执行）
$redis->zAdd('delayed_queue', time() + 5, 'delayed_task');

// 检查并处理到期任务
while (true) {
    $tasks = $redis->zRangeByScore('delayed_queue', 0, time(), ['limit' => [0, 1]]);
    if (!empty($tasks)) {
        $task = $tasks[0];
        $redis->zRem('delayed_queue', $task);
        echo "Processing: $task\n";
    }
    sleep(1); // 避免频繁检查
}
?>

任务确认机制

对于需要确认的任务，可以使用两个队列：一个用于待处理任务，另一个用于已处理任务。完成任务后，将任务从待处理队列移动到已处理队列。

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

// 添加任务到待处理队列
$redis->lPush('pending_queue', 'task1');

// 处理任务
$task = $redis->rPop('pending_queue');
if ($task) {
    // 模拟任务处理
    echo "Processing: $task\n";
    // 将任务移动到已处理队列
    $redis->lPush('processed_queue', $task);
}
?>

使用 PHP 扩展包

如果需要更高级的功能，可以使用 PHP 的 Redis 队列扩展包，如 Predis 或 Laravel 的队列系统（基于 Redis）。

安装 Predis：

composer require predis/predis

使用 Predis 实现队列：

<?php
require 'vendor/autoload.php';
$redis = new Predis\Client('tcp://127.0.0.1:6379');

// 入队
$redis->lpush('task_queue', 'task1');

// 出队
$task = $redis->rpop('task_queue');
echo $task;
?>