首页
/ Mongoose WebSocket服务中的发送缓冲区无限增长问题分析

Mongoose WebSocket服务中的发送缓冲区无限增长问题分析

2025-05-20 05:51:31作者:秋阔奎Evelyn

问题背景

在使用Mongoose库开发WebSocket服务时,开发者发现当客户端浏览器进入"休眠标签页"状态后,服务器端的内存使用量会持续增长,最终导致内存耗尽。这个问题特别容易在使用Microsoft Edge浏览器时复现,因为Edge默认会启用"非活动标签页休眠"功能。

问题现象

当WebSocket连接建立后,服务器会定期向客户端发送数据。如果客户端浏览器标签页进入休眠状态,会出现以下现象:

  1. 服务器TCP发送缓冲区逐渐填满
  2. Mongoose检测到TCP缓冲区满后,停止直接调用send系统调用
  3. Mongoose内部发送缓冲区开始积累数据
  4. 内部缓冲区大小持续线性增长,直到耗尽系统内存

技术原理分析

Mongoose库设计了一个高效的IO缓冲机制,其工作流程如下:

  1. 当应用层调用mg_ws_send发送数据时,Mongoose会先将数据存入连接结构体的发送缓冲区(c->send)
  2. 在每次事件循环中,Mongoose通过poll/select/epoll检查每个连接的写状态
  3. 如果TCP缓冲区有空间,Mongoose会将内部缓冲区的数据写入TCP层
  4. 如果TCP缓冲区满,Mongoose会暂停写入,保留数据在内部缓冲区

当客户端进入休眠状态时,TCP层无法确认收到的数据包(ACK),导致:

  1. 服务器TCP发送缓冲区无法被清空
  2. Mongoose检测到TCP缓冲区满状态(is_writeable=false)
  3. 但应用层仍持续调用mg_ws_send添加新数据
  4. 内部缓冲区(c->send)不断增长,没有上限限制

解决方案

针对这个问题,开发者可以采取以下几种解决方案:

方案一:监控发送缓冲区大小

在发送数据前检查c->send.len的大小,如果超过阈值则暂停发送:

if (c->send.len < MAX_BUFFER_SIZE) {
    mg_ws_send(c, data, len, WEBSOCKET_OP_TEXT);
} else {
    // 记录警告或采取其他措施
}

方案二:使用Mongoose内置的流量控制机制

Mongoose本身已经实现了类似的流量控制机制,特别是在处理大文件传输时。可以参考HTTP静态文件服务的实现方式:

// 类似Mongoose内部处理大文件的方式
if (c->send.len == 0) {
    // 只有当发送缓冲区为空时才添加新数据
    mg_send(c, data, len);
}

方案三:优化数据发送方式

利用Mongoose提供的格式化输出功能,减少中间缓冲区的使用:

// 直接格式化输出到WebSocket,避免中间缓冲区
mg_ws_printf(c, WEBSOCKET_OP_TEXT, "格式化消息: %d", value);

最佳实践建议

  1. 对于持续数据流服务,必须实现发送缓冲区监控
  2. 设置合理的发送缓冲区大小阈值(如1MB)
  3. 考虑实现连接健康检查机制,检测长时间不响应的连接
  4. 使用Mongoose提供的高级API(mg_ws_printf等)减少内存拷贝
  5. 在定时器回调中增加连接状态检查逻辑

总结

这个问题揭示了在网络编程中处理慢客户端的重要性。Mongoose提供了灵活的缓冲机制,但开发者需要根据应用场景实现适当的流量控制。通过监控发送缓冲区大小和合理使用API,可以有效避免内存无限增长的问题,构建更健壮的WebSocket服务。

登录后查看全文
热门项目推荐

项目优选

收起
kernelkernel
deepin linux kernel
C
22
6
docsdocs
OpenHarmony documentation | OpenHarmony开发者文档
Dockerfile
162
2.05 K
nop-entropynop-entropy
Nop Platform 2.0是基于可逆计算理论实现的采用面向语言编程范式的新一代低代码开发平台,包含基于全新原理从零开始研发的GraphQL引擎、ORM引擎、工作流引擎、报表引擎、规则引擎、批处理引引擎等完整设计。nop-entropy是它的后端部分,采用java语言实现,可选择集成Spring框架或者Quarkus框架。中小企业可以免费商用
Java
8
0
ShopXO开源商城ShopXO开源商城
🔥🔥🔥ShopXO企业级免费开源商城系统,可视化DIY拖拽装修、包含PC、H5、多端小程序(微信+支付宝+百度+头条&抖音+QQ+快手)、APP、多仓库、多商户、多门店、IM客服、进销存,遵循MIT开源协议发布、基于ThinkPHP8框架研发
JavaScript
96
15
ohos_react_nativeohos_react_native
React Native鸿蒙化仓库
C++
199
279
leetcodeleetcode
🔥LeetCode solutions in any programming language | 多种编程语言实现 LeetCode、《剑指 Offer(第 2 版)》、《程序员面试金典(第 6 版)》题解
Java
60
16
Git4ResearchGit4Research
Git4Research旨在构建一个开放、包容、协作的研究社区,让更多人能够参与到科学研究中,共同推动知识的进步。
HTML
22
1
apintoapinto
基于golang开发的网关。具有各种插件,可以自行扩展,即插即用。此外,它可以快速帮助企业管理API服务,提高API服务的稳定性和安全性。
Go
22
0
RuoYi-Vue3RuoYi-Vue3
🎉 (RuoYi)官方仓库 基于SpringBoot,Spring Security,JWT,Vue3 & Vite、Element Plus 的前后端分离权限管理系统
Vue
950
557
risc-v64-naruto-pirisc-v64-naruto-pi
基于QEMU构建的RISC-V64 SOC,支持Linux,baremetal, RTOS等,适合用来学习Linux,后续还会添加大量的controller,实现无需实体开发板,即可学习Linux和RISC-V架构
C
19
5