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

使用Golang构建即时通讯后端_Websocket百万连接架构思考

夜伟同学_1495

夜伟同学_1495

发布时间:2026-02-16 08:56:59

|

717人浏览过

|

来源于php中文网

原创

Go的net/http默认无法支撑10万WebSocket连接,因其每连接一goroutine模型导致内存与文件描述符耗尽,且缺乏限流、心跳、异常驱逐机制。

使用golang构建即时通讯后端_websocket百万连接架构思考

为什么 net/http 默认无法撑住 10 万 WebSocket 连接

Go 的 http.Server 默认用每个连接一个 goroutine 模型,看似轻量,但百万级连接下,goroutine 调度、内存开销(每个约 2KB 栈)、TCP 连接状态维护(net.Conn + bufio.Reader/Writer)会迅速吃光内存和文件描述符。更关键的是,http.Serve() 内部没有连接限流、心跳复位、异常连接自动驱逐机制,长连接堆积后,新连接 accept 失败、超时、或被内核丢包。

实操建议:

  • 必须替换默认 http.Server 的 ConnState 回调,主动跟踪 StateNew/StateClosed,做连接数硬限(比如 atomic.AddInt64(&connCount, 1) > 100000 就直接 conn.Close())
  • 禁用 http.Server.ReadTimeout 和 WriteTimeout —— 它们对长连接有害;改用应用层心跳(如每 30s conn.WriteMessage(websocket.PingMessage, nil))+ SetReadDeadline() 动态刷新
  • 避免在 http.HandlerFunc 里直接升级 WebSocket:upgrader.Upgrade() 后立即 spawn goroutine 处理读写,否则 handler 返回前连接可能已被客户端断开,导致 panic: write tcp: use of closed network connection

gorilla/websocket 升级时最常踩的三个坑

它不是“开箱即用”的高性能方案,很多默认配置直面百万连接就露馅。

常见错误现象:客户端反复重连、服务端日志刷屏 websocket: close sent、CPU 突升但吞吐不涨。

立即学习“go语言免费学习笔记(深入)”;

实操建议:

  • 设置 Upgrader.CheckOrigin = func(r *http.Request) bool { return true } 前务必加域名白名单校验,否则 DDoS 攻击可伪造 Origin 耗尽连接数
  • 必须调 upgrader.Subprotocols 显式声明支持的子协议(如 []string{"v1"}),否则某些 CDN 或代理会静默拦截 Upgrade 请求
  • upgrader.WriteBufferSize 和 ReadBufferSize 别设成 0 —— 默认 4096 太小,高并发消息 burst 时频繁 malloc,建议设为 65536;但也不要盲目设大,超过 OS socket buffer(net.core.wmem_max)会触发阻塞

连接管理不能只靠 map[string]*websocket.Conn

用 map 存连接看着简单,实际在分布式部署、滚动更新、连接异常中断时完全不可靠:key 冲突、goroutine 泄漏、map 并发写 panic、节点宕机后用户状态丢失。

Alibabacloud Sdk Client Initialization For Golang
Alibabacloud Sdk Client Initialization For Golang

初始化并管理阿里云SDK Go 客户端,涵盖 sync.Once 单例、goroutine 安全、endpoint 与 region 配置、VPC 端点及调试。

下载

使用场景:需要支持单点登录踢人、消息离线缓存、跨实例广播(如群聊)。

实操建议:

  • 连接元数据(用户 ID、设备 ID、登录时间、IP)必须单独存到带 TTL 的 Redis Hash,键为 conn:{connID};连接对象本身只保留在内存中,生命周期与 TCP 连接严格一致
  • 用 sync.Map 存活跃连接映射(userID → connID),但仅作本地快速查找;所有“踢指定用户”操作,先删 Redis,再查 sync.Map 找到对应 connID,最后安全关闭连接(conn.WriteMessage(websocket.CloseMessage, websocket.FormatCloseMessage(websocket.CloseGoingAway, "")))
  • 不要依赖 defer conn.Close() 清理 —— 必须在 readPump 和 writePump 两个 goroutine 都退出后,显式从 sync.Map 删除并通知 Redis 过期

横向扩展时,WebSocket 连接无法“真正共享”

WebSocket 是有状态的长连接,TCP 层绑定在某个实例上,负载均衡器(如 Nginx、ALB)只能做连接分发,无法把同一个用户的后续请求“导回”原节点 —— 所以广播、私信、状态同步都得走外部通道。

性能影响:如果所有消息都经 Redis Pub/Sub 中转,延迟增加 2–5ms,QPS 上限受限于 Redis 单节点吞吐(通常 5–10w ops/s)。

实操建议:

  • Nginx 必须开启 proxy_set_header Upgrade $http_upgrade; 和 proxy_set_header Connection "upgrade";,否则 WebSocket 握手失败,错误信息是 HTTP/1.1 400 Bad Request
  • 用 Redis Streams 替代 Pub/Sub 做消息总线 —— 支持消费者组、ACK、重放,避免消息丢失;每个服务实例起一个消费者组成员,独立 ACK
  • 对低延迟要求高的操作(如打字状态、在线状态),用 Redis Bitmap 或 Sorted Set 做轻量聚合,避免每条状态都走消息队列

真正的难点不在代码怎么写,而在于你得时刻清楚:哪部分状态在内存、哪部分在 Redis、哪部分其实根本没存 —— 连接断了,用户重连时,该从哪恢复上下文,这个逻辑一旦漏掉一环,前端就会卡在“正在连接…”。

热门AI工具

更多
二狗PPT
二狗PPT Hot

一款AI演示文稿工具,主要用于专为中式职场打造的AI PPT生成工具,适合需要提升相关任务效率的用户。

火山引擎

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

咔片AIPPT

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

WorkBuddy

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

DeepSeek

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

AionClaw
AionClaw Hot

AionClaw是一款面向办公、创作和编程任务的AI桌面智能体。

豆包大模型

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

立刻MV
立刻MV Hot

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

UpDream
UpDream Hot

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

相关专题

更多
golang如何定义变量
golang如何定义变量

golang定义变量的方法:1、声明变量并赋予初始值“var age int =值”;2、声明变量但不赋初始值“var age int”;3、使用短变量声明“age :=值”等等。本专题为大家提供相关的文章、下载、课程内容,供大家免费下载体验。

519

2024.02.23

golang有哪些数据转换方法
golang有哪些数据转换方法

golang数据转换方法:1、类型转换操作符;2、类型断言;3、字符串和数字之间的转换;4、JSON序列化和反序列化;5、使用标准库进行数据转换;6、使用第三方库进行数据转换;7、自定义数据转换函数。本专题为大家提供相关的文章、下载、课程内容,供大家免费下载体验。

596

2024.02.23

golang常用库有哪些
golang常用库有哪些

golang常用库有:1、标准库;2、字符串处理库;3、网络库;4、加密库;5、压缩库;6、xml和json解析库;7、日期和时间库;8、数据库操作库;9、文件操作库;10、图像处理库。本专题为大家提供相关的文章、下载、课程内容,供大家免费下载体验。

1116

2024.02.23

golang和python的区别是什么
golang和python的区别是什么

golang和python的区别是:1、golang是一种编译型语言,而python是一种解释型语言;2、golang天生支持并发编程,而python对并发与并行的支持相对较弱等等。本专题为大家提供相关的文章、下载、课程内容,供大家免费下载体验。

771

2024.03.05

golang是免费的吗
golang是免费的吗

golang是免费的。golang是google开发的一种静态强类型、编译型、并发型,并具有垃圾回收功能的开源编程语言,采用bsd开源协议。本专题为大家提供相关的文章、下载、课程内容,供大家免费下载体验。

1666

2024.05.21

golang结构体相关大全
golang结构体相关大全

本专题整合了golang结构体相关大全,想了解更多内容,请阅读专题下面的文章。

4674

2025.06.09

golang相关判断方法
golang相关判断方法

本专题整合了golang相关判断方法,想了解更详细的相关内容,请阅读下面的文章。

2134

2025.06.10

golang数组使用方法
golang数组使用方法

本专题整合了golang数组用法,想了解更多的相关内容,请阅读专题下面的文章。

4026

2025.06.17

OpenJDK JVM参数怎么调优
OpenJDK JVM参数怎么调优

Java应用运行缓慢,如何调整JVM参数?本专题介绍OpenJDK JVM性能调优的基本流程,涵盖性能指标确认、运行数据采集、内存配置和垃圾回收分析,帮助你先定位瓶颈,再通过对照测试验证效果,避免直接套用参数而影响应用稳定性。

20

2026.10.16

热门下载

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

精品课程

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

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