当前位置：首页 > PHP

php 实现队列

2026-02-27 12:30:51PHP

PHP 实现队列的方法

队列是一种先进先出（FIFO）的数据结构，PHP 可以通过多种方式实现队列功能。以下是几种常见的实现方法：

使用数组实现队列

PHP 的数组可以模拟队列的基本操作，通过 array_push 和 array_shift 函数实现入队和出队。

$queue = [];

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

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

使用 SplQueue 类

PHP 的 SPL（标准 PHP 库）提供了 SplQueue 类，专门用于队列操作。

$queue = new SplQueue();

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

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

使用 Redis 实现队列

对于需要持久化或分布式支持的场景，可以使用 Redis 作为队列存储。

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

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

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

使用消息队列系统

对于高并发或异步任务处理，可以使用专业的消息队列系统如 RabbitMQ 或 Kafka。

// RabbitMQ 示例（需安装 php-amqplib）
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('task_queue', false, true, false, false);

// 入队
$msg = new AMQPMessage('item1');
$channel->basic_publish($msg, '', 'task_queue');

// 出队（消费者端）
$callback = function ($msg) {
    echo $msg->body; // 输出 'item1'
};
$channel->basic_consume('task_queue', '', false, true, false, false, $callback);

使用数据库实现队列

对于简单的持久化队列，可以使用数据库表模拟队列。

php 实现队列

// 创建队列表（SQL）
CREATE TABLE queue (
    id INT AUTO_INCREMENT PRIMARY KEY,
    item TEXT NOT NULL,
    created_at TIMESTAMP DEFAULT CURRENT_TIMESTAMP
);

// 入队（PHP）
$pdo = new PDO('mysql:host=localhost;dbname=test', 'username', 'password');
$stmt = $pdo->prepare("INSERT INTO queue (item) 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) {
    $delete = $pdo->prepare("DELETE FROM queue WHERE id = ?");
    $delete->execute([$item['id']]);
    $pdo->commit();
    echo $item['item']; // 输出 'item1'
}