讲师中心 微信公众号
AI工具推荐 视频效率加速

PHP怎么实现简单的消息队列功能

浅强君_9302

浅强君_9302

发布时间:2026-09-29 15:03:47

|

308人浏览过

|

来源于php中文网

原创

Redis的LPUSH/BRPOP可实现轻量队列,适合允许少量丢失、无需事务回滚、单机或小集群场景;数组和SplQueue因内存级、无跨进程持久性、无锁及高并发风险等缺陷不适用。

php怎么实现简单的消息队列功能

直接用 Redis 的 LPUSH/BRPOP 就能跑起来,不需要装 RabbitMQ 或改数据库结构——前提是你的任务允许少量丢失、不依赖事务回滚,且单机或小集群够用。

为什么不用数组或 SplQueue 做队列

数组([])和 SplQueue 是内存级数据结构,PHP 请求结束就销毁。你无法让一个请求「入队」、另一个 CLI 进程「出队」;它们只适合单次脚本内流转,比如临时缓存一批待处理 ID。真实队列必须跨进程、跨请求持久存在。

  • array_push() + array_shift() 在高并发下会竞争写入,无锁机制,数据错乱风险高
  • SplQueue 没有网络协议支持,不能被多个 PHP 实例共享
  • 两者都无法支撑守护进程长期运行时的可靠性(如消费者崩溃后任务不丢失)

用 Redis 实现队列的最小可行代码

核心就是两行命令:LPUSH 入队,BRPOP 阻塞出队。别碰 PUB/SUB——它不保证消息可达,也不存历史,不是队列。

生产者(比如用户下单后触发):

btpanel phpsite 宝塔面板PHP网站
btpanel phpsite 宝塔面板PHP网站

宝塔面板 PHP 网站管理:站点创建、删除、启停、PHP 版本切换、域名管理、SSL证书管理、伪静态管理、数据库管理

下载

立即学习“PHP免费学习笔记(深入)”;

$redis = new Predis\Client();
$task = ['action' => 'send_welcome_email', 'user_id' => 123];
$redis->lPush('queue:email', json_encode($task));

消费者(常驻 CLI 脚本):

while (true) {
    // 阻塞最多 30 秒,避免空轮询打满 CPU
    $res = $redis->bRPop(['queue:email'], 30);
    if ($res) {
        $data = json_decode($res[1], true);
        try {
            processEmail($data); // 你的业务逻辑
        } catch (\Exception $e) {
            // 记日志,但别 throw —— 否则任务永远卡住
            error_log("Failed to process email task: " . $e->getMessage());
        }
    }
}
  • 用 bRPop 不用 RPop:前者阻塞等待,后者轮询查,浪费连接和 CPU
  • 键名加前缀(如 queue:email):避免和其他业务 key 冲突
  • 不要在 catch 里 throw 或 exit:消费者进程必须持续运行,否则队列停摆

容易被忽略的三个落地细节

很多人写完上面代码就以为成了,结果上线后出问题——卡在以下三点:

  • BRPOP 超时时间设太短(如 1 秒):频繁唤醒进程,IO 上升,延迟反而变高;建议 10–30 秒
  • 没做消费者进程守护:用 nohup php worker.php & 启动后,终端关闭或 SSH 断连会导致进程退出;必须用 supervisor 或 systemd 管理生命周期
  • 没处理「消费者崩溃但任务已取出」的情况:BRPOP 取出即删除,如果后续逻辑崩了,任务就丢了。真要保不丢,得换 RPOPLPUSH + 死信队列方案,或者直接上 RabbitMQ 的 ACK 机制

如果你的场景是发验证码、站内信这类低敏感任务,Redis 队列足够轻快;一旦涉及支付回调、订单状态同步,就得考虑 MySQL 持久化队列或 RabbitMQ 的确认机制——简单不等于万能,关键看任务丢不起还是丢得起。

相关文章

PHP速学教程(入门到精通)
PHP速学教程(入门到精通)

PHP怎么学习?PHP怎么入门?PHP在哪学?PHP怎么学才快?不用担心,这里为大家提供了PHP速学教程(入门到精通),有需要的小伙伴保存下载就能学习啦!

下载

相关标签:

本站声明:本文内容由网友自发贡献,版权归原作者所有,本站不承担相应法律责任。如您发现有涉嫌抄袭侵权的内容,请联系admin@php.cn

热门AI工具

更多
UP简历
UP简历 Hot

一款AI办公效率工具,主要用于基于AI技术的免费在线简历制作工具,适合需要提升相关任务效率的用户。

豆包大模型

豆包大模型是一款由字节跳动推出的企业级大语言模型服务平台。

DeepSeek

DeepSeek是一款面向对话、写作、编程和推理场景的AI大模型工具。

WorkBuddy

一款AI办公效率工具,主要用于腾讯云推出的AI原生桌面智能体工作台,适合需要提升相关任务效率的用户。

切问学术

切问学术是一款AI论文写作工具,复旦大学NLP团队推出的AI学术智能体。

咔片AIPPT

一款在线AI演示文稿制作工具,可根据主题和内容需求辅助生成PPT结构与页面,提高演示材料制作效率。

火山引擎

火山引擎是一款面向企业的云计算与AI服务平台。

PixPix
PixPix Hot

PixPix是一款面向电商视觉生产的AI商品图生成工具。

蛙蛙写作

一款AI论文写作工具,主要用于超级AI智能写作助手,适合需要提升相关任务效率的用户。

相关专题

更多
php文件怎么打开
php文件怎么打开

打开php文件步骤:1、选择文本编辑器;2、在选择的文本编辑器中,创建一个新的文件,并将其保存为.php文件;3、在创建的PHP文件中,编写PHP代码;4、要在本地计算机上运行PHP文件,需要设置一个服务器环境;5、安装服务器环境后,需要将PHP文件放入服务器目录中;6、一旦将PHP文件放入服务器目录中,就可以通过浏览器来运行它。

9484

2023.09.01

php怎么取出数组的前几个元素
php怎么取出数组的前几个元素

取出php数组的前几个元素的方法有使用array_slice()函数、使用array_splice()函数、使用循环遍历、使用array_slice()函数和array_values()函数等。本专题为大家提供php数组相关的文章、下载、课程内容,供大家免费下载体验。

5721

2023.10.11

php反序列化失败怎么办
php反序列化失败怎么办

php反序列化失败的解决办法检查序列化数据。检查类定义、检查错误日志、更新PHP版本和应用安全措施等。本专题为大家提供php反序列化相关的文章、下载、课程内容,供大家免费下载体验。

2055

2023.10.11

php怎么连接mssql数据库
php怎么连接mssql数据库

连接方法:1、通过mssql_系列函数;2、通过sqlsrv_系列函数;3、通过odbc方式连接;4、通过PDO方式;5、通过COM方式连接。想了解php怎么连接mssql数据库的详细内容,可以访问下面的文章。

3568

2023.10.23

php连接mssql数据库的方法
php连接mssql数据库的方法

php连接mssql数据库的方法有使用PHP的MSSQL扩展、使用PDO等。想了解更多php连接mssql数据库相关内容,可以阅读本专题下面的文章。

4254

2023.10.23

html怎么上传
html怎么上传

html通过使用HTML表单、JavaScript和PHP上传。更多关于html的问题详细请看本专题下面的文章。php中文网欢迎大家前来学习。

3331

2023.11.03

PHP出现乱码怎么解决
PHP出现乱码怎么解决

PHP出现乱码可以通过修改PHP文件头部的字符编码设置、检查PHP文件的编码格式、检查数据库连接设置和检查HTML页面的字符编码设置来解决。更多关于php乱码的问题详情请看本专题下面的文章。php中文网欢迎大家前来学习。

4737

2023.11.09

php文件怎么在手机上打开
php文件怎么在手机上打开

php文件在手机上打开需要在手机上搭建一个能够运行php的服务器环境,并将php文件上传到服务器上。再在手机上的浏览器中输入服务器的IP地址或域名,加上php文件的路径,即可打开php文件并查看其内容。更多关于php相关问题,详情请看本专题下面的文章。php中文网欢迎大家前来学习。

3702

2023.11.13

Buffalo框架数据库开发全教程
Buffalo框架数据库开发全教程

本专题围绕Buffalo框架数据库开发,讲解database.yml多环境配置、soda与fizz迁移生成回滚、模型结构体标签、增删改查与条件查询、一对多与多对多关联、数据校验、回调钩子、事务处理及原生SQL执行能力。

200

2026.09.23

热门下载

更多
网站特效
/
网站源码
/
网站素材
/
前端模板

精品课程

更多
相关推荐
/
热门推荐
/
最新课程
MyEclipse学习中心
MyEclipse学习中心

共0课时 | 0人学习

Laravel5.2博客实战视频教程
Laravel5.2博客实战视频教程

共41课时 | 21.8万人学习

后盾网ECShop从入门到精通视频教程
后盾网ECShop从入门到精通视频教程

共42课时 | 10.9万人学习

关于我们 免责申明 举报中心 意见反馈 讲师合作 广告合作 最新更新
php中文网:公益在线php培训,帮助PHP学习者快速成长!
关注服务号
PHP中文网订阅号
每天精选资源文章推送

Copyright 2014-2026 https://www.php.cn/ All Rights Reserved | php.cn