讲师中心 微信公众号

工具推荐

视频效率加速
updream

一键生成高质量推广成片

AniShort
AniShort

AI短剧协同制作平台

Seko
Seko

AI短剧一键生成成片

剧云
剧云

中文短剧剧本制作平台

在Node.js开发中如何防止ioredis发布订阅事件内存泄漏?

风明同学_4802

风明同学_4802

发布时间:2026-11-15 07:19:53

|

755人浏览过

|

来源于php中文网

原创

ioredis Pub/Sub内存泄漏的根本原因是连接生命周期与事件监听器绑定未对齐:重连后旧监听器未清除、未监听ready事件导致订阅失效、message回调中持有大对象或阻塞处理,三者叠加致堆内存持续上涨。

在node.js开发中如何防止ioredis发布订阅事件内存泄漏?

为什么ioredis Pub/Sub容易引发内存泄漏

根本原因不是代码写错了,而是连接生命周期和事件监听器绑定方式没对齐。ioredis的subClient一旦调用subscribe,就会进入订阅模式并持续监听message、pmessage等事件;如果没在连接断开或销毁前手动移除监听器,这些回调函数会一直挂在EventEmitter上,闭包持有的上下文(比如大对象、数据库连接、日志实例)就无法被GC回收。

必须显式移除message/pmessage监听器

很多人以为“连接断了监听自然失效”,但ioredis重连后会复用原有实例,on('message', handler)注册的监听器不会自动清理,重连后还会继续触发——旧handler可能引用已废弃的上下文,新旧handler共存导致堆内存缓慢上涨。

  • 每次subClient.on('message', handler)前,先调用subClient.removeAllListeners('message')
  • 若使用psubscribe,也需对应调用subClient.removeAllListeners('pmessage')
  • 在subClient准备销毁(如服务关闭)时,务必执行subClient.quit() + subClient.removeAllListeners()
  • 避免在闭包中捕获大对象:比如不要把req、res或整个Express app实例传进message回调

重连后必须重新subscribe,且不能漏掉ready事件

ioredis自动重连成功后,subscribe状态不会恢复——这是协议层限制,不是bug。如果你在connect后立刻subscribe,但连接尚未真正就绪(比如AUTH未完成),订阅会静默失败,后续消息全丢,而监听器还挂着,形成“假活跃真空转”状态,长期积累就是内存泄漏温床。

JSON Toolkit
JSON Toolkit

JSON文件多功能工具。支持格式化、验证、压缩、键排序及点记法路径查询。零依赖。

下载
  • 必须监听subClient.on('ready', () => { subClient.subscribe('channel'); }),而不是connect或connect后的setTimeout
  • 重连后ready事件会再次触发,所以subscribe逻辑要能重复执行(幂等)
  • 在subscribe回调里检查err,失败时记录日志并重试,避免“无声失效”

避免在message回调里做耗时或阻塞操作

Node.js是单线程,message回调如果同步执行大量计算、JSON.parse超大字符串、或await一个没加timeout的数据库查询,会导致事件循环卡住,后续消息堆积在内存队列里来不及处理,subClient缓冲区持续增长,RSS内存稳步上升。

  • 对message内容做长度校验:if (message.length > 1024 * 1024) return;,直接丢弃超长消息
  • 异步操作必须加超时:Promise.race([db.query(...), new Promise(r => setTimeout(r, 5000))])
  • 高频消息场景下,考虑用setImmediate或queueMicrotask把处理逻辑推到下一周期,防止单次处理阻塞太久

最常被忽略的一点:Pub/Sub本身不保存消息,断连即丢失,所以别指望靠它做可靠消息传递;内存泄漏往往不是某一行代码的问题,而是“监听器没清理 + 重连没重订 + 回调里堆数据”三者叠加的结果。上线前务必用process.memoryUsage()监控heapUsed和rss变化趋势,尤其在模拟网络抖动后观察是否回落。

热门AI工具

更多
WorkBuddy

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

DeepSeek

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

讯飞智文

一款面向学习和办公场景的AI文档创作工具,可辅助生成PPT与Word文档,提高资料整理和内容制作效率。

VibeKnow
VibeKnow Hot

一款AI视频创作工具,主要用于全球首个AI知识视频创作平台,文档、文章、网页,一键生成视频,适合需要提升相关任务效率的用户。

Loomy
Loomy Hot

一款AI工具,主要用于科大讯飞发布的桌面级 AI 助理,比 OpenClaw 更易用、更安全!,适合需要提升相关任务效率的用户。

立刻MV
立刻MV Hot

立刻MV是一款AI文本写作工具,AI 音乐视频(MV)创作工具。

讯飞智作

讯飞智作是一款AI视频创作工具,AI文本配音工具,数字人课程、营销视频制作。

豆包大模型

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

SkildArt
SkildArt Hot

SkildArt是一款AI文本写作工具,一站式 AI 视觉创作平台。

相关专题

更多
node.js调试
node.js调试

node.js调试可以使用console.log()输出调试信息、断点调试和第三方调试工具。详细介绍:1、console.log()输出调试信息,通过在代码中插入console.log()语句,开发人员可以在控制台输出变量的值、函数的执行结果等信息,以便观察代码的执行流程和状态;2、断点调试,可以在代码中设置断点,以便在特定位置暂停代码的执行,观察变量的值和执行流程等。

12709

2023.09.19

JavaScript 全栈开发基础(Node.js + 前端)
JavaScript 全栈开发基础(Node.js + 前端)

本专题系统介绍 JavaScript 在全栈开发中的核心知识结构,涵盖 Node.js 基础、Express/Koa 接口构建、前端交互设计、模块化与包管理、数据库连接、前后端数据通信与部署流程。通过完整项目示例,帮助学习者掌握从浏览器到服务器的一体化开发能力,实现真正意义上的全栈入门。

454

2025.11.26

Node.js后端开发与Express框架实践
Node.js后端开发与Express框架实践

本专题针对初中级 Node.js 开发者,系统讲解如何使用 Express 框架搭建高性能后端服务。内容包括路由设计、中间件开发、数据库集成、API 安全与异常处理,以及 RESTful API 的设计与优化。通过实际项目演示,帮助开发者快速掌握 Node.js 后端开发流程。

781

2026.02.10

JavaScript Node.js流处理与高效数据管道构建实践
JavaScript Node.js流处理与高效数据管道构建实践

本专题聚焦 Node.js 在大规模数据处理场景中的应用,系统讲解 Stream 流机制、背压控制、管道(Pipe)处理以及文件与网络数据流的高效传输方式。内容包括可读流、可写流、双工流与转换流的实现原理,并结合实际案例构建高性能数据处理管道,帮助开发者提升数据处理效率与系统吞吐能力。

364

2026.04.07

TypeScript Node.js 全栈工程化与Monorepo架构实践
TypeScript Node.js 全栈工程化与Monorepo架构实践

本专题围绕 TypeScript 在 Node.js 全栈开发中的工程化实践展开,系统讲解 Monorepo 架构设计、包管理策略、模块复用机制以及服务端与前端统一类型系统的构建方法。通过真实项目案例,帮助开发者提升大型全栈项目的可维护性与协作效率。

778

2026.06.16

常用的数据库软件
常用的数据库软件

常用的数据库软件有MySQL、Oracle、SQL Server、PostgreSQL、MongoDB、Redis、Cassandra、Hadoop、Spark和Amazon DynamoDB。更多关于数据库软件的内容详情请看本专题下面的文章。php中文网欢迎大家前来学习。

4969

2023.11.02

内存数据库有哪些
内存数据库有哪些

内存数据库有Redis、Memcached、Apache Ignite、VoltDB、TimesTen、H2 Database、Aerospike、Oracle TimesTen In-Memory Database、SAP HANA和ache Cassandra。更多关于内存数据库相关问题,详情请看本专题下面的文章。php中文网欢迎大家前来学习。

4555

2023.11.14

mongodb和redis哪个读取速度快
mongodb和redis哪个读取速度快

redis 的读取速度比 mongodb 更快。原因包括:1. redis 使用简单的键值存储,而 mongodb 存储 json 格式的数据,需要解析和反序列化。2. redis 使用哈希表快速查找数据,而 mongodb 使用 b-tree 索引。因此,redis 在需要高性能读取操作的应用程序中是一个更好的选择。本专题为大家提供相关的文章、下载、课程内容,供大家免费下载体验。

8872

2024.04.02

Go-Zero API开发使用教程
Go-Zero API开发使用教程

本专题聚焦Go-Zero的API开发,拆解.api描述文件的语法结构、路由与分组定义、参数绑定与校验规则,说明统一响应体、JWT鉴权、跨域与接口文档生成的落地方式,并给出网关聚合与接口测试的实践建议。

40

2026.11.12

热门下载

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

精品课程

更多
相关推荐
/
热门推荐
/
最新课程
Go-Zero官方文档
Go-Zero官方文档

共0课时 | 0人学习

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

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