首选think-queue扩展并安装依赖,配置Redis驱动,编写任务类实现fire方法,通过Queue::push()推送任务,使用php think queue:listen命令启动监听,结合nohup或supervisor保持守护进程运行,确保任务持续消费。

搭建PHP队列服务,核心是选型、安装依赖、编写生产消费逻辑并保持监听。实际操作中,推荐使用成熟的扩展包或中间件,避免重复造轮子。下面以ThinkPHP框架集成Redis驱动为例,说明具体步骤。
选择方案与安装依赖
PHP实现消息队列有多种方式,常见的是基于Redis、RabbitMQ或专用扩展包如think-queue。对于ThinkPHP项目,直接使用think-queue最为便捷。
- 进入项目根目录,执行composer require topthink/think-queue安装扩展
- 确认/vendor/topthink/think-queue目录已生成,表示安装成功
- 若使用Redis作为驱动,确保服务器已安装Redis服务,并开启PHP的redis扩展
配置队列驱动与编写任务逻辑
think-queue支持多种驱动,但Redis在性能和稳定性上表现更好,适合大多数场景。
- 在application/extra/queue.php中配置Redis驱动,指定主机、端口、密码等信息
- 在控制器中引入use think\Queue;,通过Queue::push()方法将任务推入队列
- 定义任务类处理具体业务,比如发送邮件、处理订单等,该类需实现fire方法作为执行入口
启动监听与守护进程运行
队列任务需要持续监听,不能依赖手动触发。监听命令会不断检查队列中是否有新任务。
立即学习“PHP免费学习笔记(深入)”;
- 在项目根目录执行php think queue:listen --queue yourJobName启动监听
- 为防止命令行关闭导致监听中断,应使用守护进程方式运行
- 推荐命令:nohup php think queue:listen --queue yourJobName &,后台持续运行
- 可结合supervisor等工具管理进程,实现自动重启和日志监控
基本上就这些。只要完成依赖安装、正确配置驱动、编写好任务类并保持监听,队列服务就能稳定工作。关键是确保消费者进程不中断,同时注意任务失败重试和日志记录机制。不复杂但容易忽略。











