当前位置：首页 > PHP

php 队列实现

2026-02-28 11:12:29PHP

队列实现（PHP）

在PHP中，队列可以通过多种方式实现，包括数组、SplQueue类以及第三方库如Laravel的队列系统。以下是几种常见的实现方法：

使用数组实现队列

PHP数组可以通过array_push和array_shift函数模拟队列的先进先出（FIFO）行为。

$queue = [];

// 入队
array_push($queue, 'item1');
array_push($queue, 'item2');

// 出队
$item = array_shift($queue);
echo $item; // 输出: item1

注意事项：

array_shift的时间复杂度为O(n)，因为需要重新索引数组。
适合小型队列或对性能要求不高的场景。

使用SplQueue类

PHP标准库（SPL）提供了SplQueue类，专门用于队列操作，性能优于数组。

$queue = new SplQueue();

// 入队
$queue->enqueue('item1');
$queue->enqueue('item2');

// 出队
$item = $queue->dequeue();
echo $item; // 输出: item1

// 检查队列是否为空
if (!$queue->isEmpty()) {
    echo "队列非空";
}

优势：

专为队列设计，操作高效。
提供isEmpty、count等实用方法。

使用Laravel队列系统

Laravel框架内置了强大的队列系统，支持数据库、Redis、Amazon SQS等驱动。

php 队列实现

安装与配置：

确保Laravel项目已安装队列依赖：

composer require laravel/horizon  # 可选，用于监控队列

配置队列驱动（如Redis）在.env文件中：
```
QUEUE_CONNECTION=redis
```

创建任务：
生成一个队列任务：

php artisan make:job ProcessTask

在生成的ProcessTask类中定义逻辑：

public function handle()
{
    // 任务逻辑
    logger()->info('任务已处理');
}

分发任务：

php 队列实现

ProcessTask::dispatch()->onQueue('high');

运行队列 worker：

php artisan queue:work

关键特性：

支持延迟队列、失败重试、优先级队列。
可通过Horizon监控队列状态。

使用Redis实现队列

Redis的LPUSH和RPOP命令天然适合队列场景，PHP可通过predis库操作。

$redis = new Predis\Client();

// 入队
$redis->lpush('my_queue', 'item1');
$redis->lpush('my_queue', 'item2');

// 出队
$item = $redis->rpop('my_queue');
echo $item; // 输出: item2

适用场景：