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

如何用Golang构建WebSocket服务_Golang WebSocket连接与实时通信

雨涛酱_5252

雨涛酱_5252

发布时间:2026-02-07 12:46:30

|

363人浏览过

|

来源于php中文网

原创

应使用 gorilla/websocket 而非 net/http 裸升级,因其封装完整帧处理、心跳、错误处理;需正确配置 Upgrader、子协议、读写超时与并发模型,并安全广播及清理连接资源。

如何用golang构建websocket服务_golang websocket连接与实时通信

用 gorilla/websocket 建连接,别碰标准库 net/http 的裸升级

Go 标准库没有原生 WebSocket 实现,net/http 里所谓“升级”只是帮你处理了握手头,后续帧读写、掩码校验、心跳、关闭流程全得自己写。99% 的场景直接用 gorilla/websocket —— 它是事实标准,稳定、有完整错误处理、支持 ping/pong 自动响应。

常见错误现象:websocket: bad handshake(没走 Upgrader.Upgrade())、连接后立刻断开(没调 conn.SetPingHandler() 或忽略 io.EOF)、并发读写 panic(没加锁或没用 conn.SetReadDeadline())。

  • Upgrader.CheckOrigin 默认拒绝非同源请求,开发时设为 func(r *http.Request) bool { return true },上线必须收紧
  • Upgrader.Subprotocols 要和前端 new WebSocket(url, ['json']) 的子协议严格匹配,否则握手失败
  • 每个连接建议起独立 goroutine 处理读,再用 channel 向写协程投递消息,避免读写竞争

conn.ReadMessage() 和 conn.WriteMessage() 别混用阻塞模式

这两个函数默认是同步阻塞的,但 WebSocket 连接天然双向,读卡住时写也会被拖住。尤其在广播场景下,一个慢客户端会拖垮整个写逻辑。

使用场景:实时日志推送、聊天室消息分发、行情更新 —— 都要求写不被单个连接阻塞。

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

chartjs-reporter
chartjs-reporter

此技能用于在用户需要将结构化数据(查询结果、CSV 摘要、JSON 记录或 Python 字典/列表)转换为独立的 HTML 页面时使用。

下载
  • 对写操作加超时:conn.SetWriteDeadline(time.Now().Add(10 * time.Second)),写失败就关连接
  • 不要在 ReadMessage() 循环里直接调 WriteMessage(),改用带缓冲的 channel 中转
  • 二进制消息优先用 conn.WriteMessage(websocket.BinaryMessage, data),文本消息注意 UTF-8 合法性,非法字节会触发 websocket: bad message

如何安全地广播消息给所有在线连接

没有全局连接列表,靠 map + mutex 管理容易漏锁、panic 或遍历时连接已关闭。更糟的是,直接遍历并调 WriteMessage() 会因某个连接卡住而阻塞整个广播。

性能影响:1000 个连接,每次广播都同步写,延迟毛刺明显;用 channel + worker 模式可压到毫秒级抖动。

  • 用 sync.Map 存 *websocket.Conn,key 用自增 ID 或 session token,避免 map 并发读写 panic
  • 每个连接启动时注册到全局 map,defer 里反注册;注册/反注册操作必须原子
  • 广播时只往每个连接专属的 chan []byte 发消息,由独立的 write goroutine 消费,失败则关连接并清理 map

连接异常中断时,io.EOF 和 websocket.CloseMessage 怎么区分处理

客户端正常关闭会发 CloseMessage 帧,服务端收到后应主动调 conn.Close();而网络闪断、浏览器标签关闭、手机切后台,服务端往往先读到 io.EOF 或 websocket: close sent 错误。

容易踩的坑:把 io.EOF 当普通错误 log 并重试,结果反复尝试向已断开连接写数据,触发 write: broken pipe;或忽略 CloseMessage 导致连接资源泄漏。

  • 读循环中,err == io.EOF 或 strings.Contains(err.Error(), "use of closed network connection") 可安全退出
  • 收到 websocket.CloseMessage 类型帧,必须立即调 conn.WriteMessage(websocket.CloseMessage, websocket.FormatCloseMessage(websocket.CloseNormalClosure, "")) 再关连接
  • 所有连接关闭前,务必从全局 map 清除,否则内存泄漏随时间线性增长

最常被忽略的是连接关闭后的资源清理时机 —— 不是 defer 里关 conn 就完事,map 里的引用、channel 的接收端、定时器都要一并释放。

热门AI工具

更多
讯飞智作

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

VibeKnow
VibeKnow Hot

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

豆包大模型

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

火山引擎

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

DeepSeek

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

音述AI
音述AI Hot

一款AI音频处理工具,主要用于音述AI是一个以“用声音述说故事”为核心的 AI 音乐创作与声音分享社区,适合需要提升相关任务效率的用户。

二狗PPT
二狗PPT Hot

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

Laper
Laper Hot

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

WorkBuddy

一款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、图像处理库。本专题为大家提供相关的文章、下载、课程内容,供大家免费下载体验。

1136

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开源协议。本专题为大家提供相关的文章、下载、课程内容,供大家免费下载体验。

1686

2024.05.21

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

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

4734

2025.06.09

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

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

2174

2025.06.10

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

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

4066

2025.06.17

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

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

100

2026.10.16

热门下载

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

精品课程

更多
相关推荐
/
热门推荐
/
最新课程
WEB前端教程【HTML5+CSS3+JS】
WEB前端教程【HTML5+CSS3+JS】

共101课时 | 21.1万人学习

JS进阶与BootStrap学习
JS进阶与BootStrap学习

共39课时 | 4.9万人学习

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

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