用php实现队列需根据需求选择方式。1.简单队列可用数组实现，通过array_shift()和[]模拟fifo操作，适合单进程小规模任务但数据易丢失；2.高并发场景应使用消息中间件如redis或rabbitmq，其中redis以lpush/rpop实现基本队列流程并支持多消费者并行处理；3.rabbitmq适用于复杂需求如延迟队列、死信队列等，通过php-amqplib库可实现生产者与消费者的交互。
用 PHP 实现队列其实并不难，但要根据具体需求来选择合适的方式。如果你只是想在代码中模拟一个简单的队列结构，可以用数组实现；而如果是为了构建一个消息队列系统，比如用于异步处理、任务分发、解耦服务等场景，那就要考虑使用专业的消息中间件了。
下面我们就从两个方向来聊聊怎么用 PHP 做队列。
一、PHP 中的简单队列实现
最基础的队列操作就是“先进先出”（FIFO），你可以用 PHP 的数组配合 array_shift() 和 [] 来模拟：
立即学习“PHP免费学习笔记（深入）”；
$queue = []; // 入队 $queue[] = 'task1'; $queue[] = 'task2'; // 出队 $task = array_shift($queue); echo $task; // 输出 task1
这种方式适合单进程、小规模任务处理，比如在脚本里处理一批数据，或者做定时任务时缓存一些操作指令。不过它有个明显缺点：数据存在内存里，重启就没了，而且不能跨进程共享。
小建议：如果你只是写个命令行工具跑一次性任务，这种实现足够。想保存状态的话，可以把队列内容存进数据库或文件，每次读取更新。
二、搭建消息队列系统：为什么需要它？
当你面对高并发、异步处理、模块解耦等场景时，就得引入真正的消息队列系统了。比如用户注册后发邮件、下单后通知库存服务、日志收集等等，这些都可以通过消息队列来优化流程。
常见的消息中间件有：
- RabbitMQ：功能强大，适合企业级应用
- Redis：轻量、快，适合中小型项目
- Kafka：高性能，适合大数据流处理
- Beanstalkd：简单易用，适合轻量任务队列
这里我们以 Redis 为例，看看怎么用 PHP 接入。
三、用 PHP + Redis 实现消息队列
安装扩展
首先确保你的 PHP 环境安装了 redis 扩展，可以通过 PECL 安装：
pecl install redis
然后在 php.ini 中加上：
extension=redis.so
发送消息（生产者）
$redis = new Redis();
$redis->connect('127.0.0.1', 6379);
// 向队列中添加一条消息
$redis->lPush('task_queue', json_encode(['type' => 'email', 'data' => 'hello@example.com']));处理消息（消费者）
while (true) {
$message = $redis->rPop('task_queue');
if ($message) {
$data = json_decode($message, true);
echo "Processing: " . $data['data'] . "\n";
// 这里执行具体的业务逻辑，比如发送邮件等
} else {
sleep(1); // 队列空了，休息一秒再查
}
}这样就是一个基本的消息队列流程了。你可以开多个消费者进程并行处理任务。
注意点：
- 生产环境中最好加个超时机制和失败重试逻辑
- 可以用 supervisor 或 systemd 来管理消费者进程
- Redis 的 list 类型只能保证基本的 FIFO，不支持复杂的路由规则
四、更高级的选择：RabbitMQ 示例简述
如果你需要更复杂的功能，比如延迟队列、死信队列、优先级队列、多消费者组等，推荐使用 RabbitMQ。
PHP 一般用 php-amqplib 这个库来连接 RabbitMQ。
生产者大致步骤如下：
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('Hello World!', ['delivery_mode' => AMQPMessage::DELIVERY_MODE_PERSISTENT]);
$channel->basic_publish($msg, '', 'task_queue');
$channel->close();
$connection->close();消费者部分略长，就不展开写了，重点是 RabbitMQ 支持更多特性，也更适合分布式系统。
基本上就这些。用 PHP 实现队列，从数组到消息中间件，每种方式都有适用场景。别一开始就想上 Kafka 或 RabbitMQ，先看需求，能用 Redis 就够用了。
