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

怎么在Redis中利用List结构实现基础的消息异步队列

夜磊同学_9063

夜磊同学_9063

发布时间:2026-04-15 17:10:07

|

937人浏览过

|

来源于php中文网

原创

必须用BRPOP/BLPOP替代RPOP/LPOP,因其阻塞特性避免空轮询;LPUSH+BRPOP构成FIFO队列;无ACK机制致崩溃丢消息;延时任务需ZSET而非List;超简单场景适用,复杂需求应选Stream或专业MQ。

怎么在redis中利用list结构实现基础的消息异步队列

能用,但必须配 BRPOP 或 BLPOP,否则就是轮询空转、浪费CPU又延迟高。

为什么不能直接用 RPOP/LPOP 做消费者?

因为 RPOP 和 LPOP 是“即查即返”型命令:队列空时立刻返回 nil,不会等。实际代码里如果写成 while(true) { $msg = $redis->rPop($queue); if ($msg) { handle($msg); } },就会变成高频空请求,Redis QPS 暴涨,而消息延迟反而不可控。

  • 真实错误现象:redis-cli 中反复执行 RPOP myq,看到大量 (nil) 返回,INFO commandstats 里 cmdstat_rpop 调用量飙升
  • 正确做法:改用阻塞式命令,让 Redis 主动挂起连接,直到有数据或超时
  • 超时参数很关键:BRPOP myq 0 表示无限等待;BRPOP myq 30 表示最多等 30 秒,超时返回 null,便于做健康检查或优雅退出

LPUSH + BRPOP 是最稳的 FIFO 组合

生产者用 LPUSH 往列表左端推入,消费者用 BRPOP 从右端阻塞弹出,天然构成先进先出(FIFO)队列。注意别混用 RPUSH + BRPOP —— 虽然也能工作,但语义上是“尾进尾出”,容易和业务逻辑对不上。

redis-tools
redis-tools

按类别查找Redis命令、检测服务器连接、监控键数量和内存占用,支持离线速查表。

下载
  • 命令顺序要匹配:LPUSH queue "task1" → LPUSH queue "task2" → BRPOP queue 0 返回 "task1"(不是 "task2")
  • 多消费者安全:多个客户端同时执行 BRPOP queue 0,Redis 内部保证同一时刻只有一个能拿到消息,无需额外加锁
  • 持久化依赖 Redis 配置:只有开启 RDB 或 AOF,重启后队列内容才不丢;默认关闭时,消息纯内存存储

消费者进程崩溃了,消息会丢吗?

会丢。List 队列本身没有 ack 机制:BRPOP 一返回,消息就从列表里删掉了。如果消费者取到消息后还没处理完就崩了,这条消息彻底消失。

  • 常见补救方式:消费前先 LRANGE queue -1 -1 看一眼最新消息(不删),处理成功再 RPOP;但并发下仍可能冲突
  • 更可靠方案:改用 Stream 结构(Redis 5.0+),支持 XREADGROUP + XAck,但 List 就是轻量级场景,别强求它扛住金融级可靠性
  • 底线建议:至少给消费者加上 try/catch,并在 catch 块里记录日志或发告警,别让失败静默发生

延时任务不能只靠 List,得换 ZSET

List 本身不带时间维度,没法原生支持“1 小时后执行”。硬要在 List 里塞时间戳然后轮询判断,等于自己实现调度器,性能差还容易漏。

  • 正确姿势:用 ZADD delay_queue <unix_timestamp> "task_json"</unix_timestamp> 把到期时间设为 score,再用 ZRANGEBYSCORE delay_queue 0 <now> LIMIT 1</now> 扫描到期任务
  • 原子性陷阱:扫描 + 删除(ZREM)两步操作在多进程下会重复消费,必须用 Lua 脚本封装成单次原子调用
  • 别把延时队列和普通队列混用同一个 key,语义混乱且难以监控

List 队列的边界很清晰:它适合中小流量、允许少量丢失、追求简单上线的异步场景。一旦需要重试、死信、分组消费或精确延时,就该考虑 Stream 或专有 MQ 了——不是 List 不好,而是它压根没设计去干那些事。

热门AI工具

更多
咔片AIPPT

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

Lovart
Lovart Hot

一款面向视觉设计创作的AI设计平台,可通过智能体和画布工作流辅助制作海报、Logo、网页、PPT及其他视觉内容。

豆包大模型

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

UpDream
UpDream Hot

一款AI视频创作工具,主要用于哔哩哔哩推出的自研AI视频创作工具,适合需要提升相关任务效率的用户。

DeepSeek

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

墨刀AI
墨刀AI Hot

一款AI图像与设计工具,主要用于产品经理的专属智能体,适合需要提升相关任务效率的用户。

WorkBuddy

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

Laper
Laper Hot

Laper是专为编剧、导演和制片人推出的 AI 原生剧本创作工具。

创客贴AI

创客贴AI是一款AI图像与设计工具,AI辅助的智能在线设计工具。

相关专题

更多
Vite 项目如何打包和部署
Vite 项目如何打包和部署

Vite项目打包部署专题汇集生产构建、产物预览、输出目录、资源路径、Nginx与GitHub Pages部署及常见白屏和路由404问题的已审核文章,帮助读者完成上线流程。

20

2026.10.28

Vite 如何搭配 Vue.js
Vite 如何搭配 Vue.js

Vite搭配Vue.js专题汇集创建Vue 3项目、配置开发环境、路径别名、Vue插件、代理、多环境构建与调试的已审核文章,帮助读者完成从初始化到日常开发的配置。

20

2026.10.28

Vite 项目目录怎么看
Vite 项目目录怎么看

Vite项目目录专题汇集入口文件、src源码、public静态资源、路径别名、项目根目录和构建输出目录相关的已审核文章,帮助读者理解各文件夹的用途与引用方式。

0

2026.10.28

Gradle插件开发入门教程
Gradle插件开发入门教程

本专题介绍Gradle插件开发的基本流程,涵盖插件类编写、自定义任务注册、扩展参数设计和插件应用方法,帮助你理解插件如何组织构建逻辑,减少多个项目之间的重复配置。

120

2026.10.22

Gradle Wrapper配置教程
Gradle Wrapper配置教程

本专题介绍Gradle Wrapper的基本作用,涵盖文件组成、生成方法、版本配置和任务调用,帮助你理解项目如何使用指定的Gradle版本,减少不同开发环境带来的构建差异。

60

2026.10.22

Golangci-lint检查器使用教程
Golangci-lint检查器使用教程

本专题整理Golangci-lint常用Linters的用途与配置方法,覆盖错误处理、无效代码、安全、复杂度、命名和依赖检查,帮助项目合理选规则。

60

2026.10.22

Gradle怎么构建Java项目
Gradle怎么构建Java项目

本专题介绍Gradle Java项目构建方法,涵盖Java插件配置、依赖声明、源码编译、测试执行和打包检查,帮助你理解各阶段的任务关系,逐步完成项目构建。

40

2026.10.22

PHP时间戳漏洞修复教程
PHP时间戳漏洞修复教程

本专题汇总PHP常见时间戳漏洞,包括2038年溢出、时区漂移、时间戳伪造、重放攻击、时间盲注与日志审计失效等,并给出升级64位环境、使用 DateTimeImmutable、统一UTC、严格超时校验、预处理绑定、hash_equals 比对等修复方案,帮助开发者快速排查和加固时间相关代码。

60

2026.10.22

Golangci-lint配置文件与规则设置
Golangci-lint配置文件与规则设置

本专题聚焦Golangci-lint YAML配置文件,讲清运行参数、规则启停、目录排除、问题过滤及严重级别设置,便于团队统一检查标准。

40

2026.10.22

热门下载

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

精品课程

更多
相关推荐
/
热门推荐
/
最新课程
phpEnv手册
phpEnv手册

共0课时 | 0人学习

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

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