当前位置：首页 > PHP

php 队列的实现

2026-04-02 21:22:12PHP

PHP 队列的实现方法

使用数组实现队列

PHP 的数组可以用来实现队列的基本功能，通过 array_push 和 array_shift 函数可以模拟队列的先进先出（FIFO）特性。

$queue = [];

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

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

使用 SplQueue 类

PHP 的 SPL（Standard PHP Library）提供了 SplQueue 类，专门用于实现队列功能。它比数组更高效且提供了更多队列操作的方法。

$queue = new SplQueue();

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

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

使用 Redis 实现队列

对于需要持久化或分布式支持的场景，可以使用 Redis 作为队列存储。Redis 的 LPUSH 和 RPOP 命令可以实现队列功能。

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

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

// 出队
$item = $redis->rPop('my_queue');
echo $item; // 输出 'item1'

使用消息队列系统（如 RabbitMQ）

对于复杂的消息队列需求，可以使用 RabbitMQ 等专业的消息队列系统。PHP 通过 php-amqplib 库可以与 RabbitMQ 交互。

require_once __DIR__ . '/vendor/autoload.php';
use PhpAmqpLib\Connection\AMQPStreamConnection;
use PhpAmqpLib\Message\AMQPMessage;

$connection = new AMQPStreamConnection('localhost', 5672, 'guest', 'guest');
$channel = $connection->channel();

// 声明队列
$channel->queue_declare('my_queue', false, false, false, false);

// 发布消息
$msg = new AMQPMessage('item1');
$channel->basic_publish($msg, '', 'my_queue');

// 消费消息
$callback = function ($msg) {
    echo $msg->body; // 输出 'item1'
};
$channel->basic_consume('my_queue', '', false, true, false, false, $callback);

while ($channel->is_open()) {
    $channel->wait();
}

$channel->close();
$connection->close();

使用数据库实现队列

对于简单的持久化队列需求，可以使用数据库表来存储队列数据。

$pdo = new PDO('mysql:host=localhost;dbname=test', 'username', 'password');

// 入队
$stmt = $pdo->prepare("INSERT INTO queue (data) VALUES (?)");
$stmt->execute(['item1']);

// 出队
$pdo->beginTransaction();
$stmt = $pdo->prepare("SELECT * FROM queue ORDER BY id ASC LIMIT 1 FOR UPDATE");
$stmt->execute();
$item = $stmt->fetch();

if ($item) {
    $deleteStmt = $pdo->prepare("DELETE FROM queue WHERE id = ?");
    $deleteStmt->execute([$item['id']]);
    $pdo->commit();
    echo $item['data']; // 输出 'item1'
} else {
    $pdo->rollBack();
}

使用 Laravel 的队列系统

Laravel 提供了强大的队列系统，支持多种队列驱动（如数据库、Redis、Amazon SQS 等）。

定义任务类：

php artisan make:job ProcessItem

在生成的 ProcessItem 类中实现逻辑：

namespace App\Jobs;

use Illuminate\Bus\Queueable;
use Illuminate\Contracts\Queue\ShouldQueue;
use Illuminate\Foundation\Bus\Dispatchable;
use Illuminate\Queue\InteractsWithQueue;
use Illuminate\Queue\SerializesModels;

class ProcessItem implements ShouldQueue
{
    use Dispatchable, InteractsWithQueue, Queueable, SerializesModels;

    protected $item;

    public function __construct($item)
    {
        $this->item = $item;
    }

    public function handle()
    {
        echo $this->item; // 处理任务
    }
}

分发任务：