当前位置：首页 > PHP

使用php实现队列

2026-02-15 20:19:52PHP

使用 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）提供了 SplQueue 类，专门用于队列操作。

$queue = new SplQueue();

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

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

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

基于 Redis 实现队列

Redis 的列表（List）结构适合实现高性能队列。

$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'

基于数据库实现队列

使用数据库表模拟队列，适合持久化需求。

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

// 入队
$pdo = new PDO('mysql:host=localhost;dbname=test', 'user', 'password');
$stmt = $pdo->prepare("INSERT INTO queue (data) VALUES (?)");
$stmt->execute(['item1']);

// 出队
$stmt = $pdo->prepare("SELECT * FROM queue ORDER BY created_at ASC LIMIT 1");
$stmt->execute();
$item = $stmt->fetch();
echo $item['data']; // 输出 'item1'

// 删除已处理项
$pdo->prepare("DELETE FROM queue WHERE id = ?")->execute([$item['id']]);

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

对于分布式系统，可以使用专业的消息队列工具。

使用php实现队列

// 安装 AMQP 扩展后使用
$connection = new AMQPConnection([
    'host' => 'localhost',
    'port' => 5672,
    'login' => 'guest',
    'password' => 'guest'
]);
$connection->connect();

$channel = new AMQPChannel($connection);
$queue = new AMQPQueue($channel);
$queue->setName('my_queue');
$queue->declareQueue();

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

// 出队
$message = $queue->get();
if ($message) {
    echo $message->getBody(); // 输出 'item1'
    $queue->ack($message->getDeliveryTag());
}