本文详解如何基于 gorilla websocket 库构建健壮、可扩展的 go websocket 客户端，支持多 goroutine 并发连接、消息收发与异常处理，避免 eof 崩溃，并提供完整可运行示例。
咱们今天来聊聊怎么用Gorilla WebSocket在Go里搭一个高并发的客户端。这事儿其实挺重要的，毕竟实时通信、微服务长连接、IoT设备管理这些场景，都离不开一个靠谱的WebSocket底座。
先说个现实问题：Go标准库确实没给WebSocket一个原生席位。那个golang.org/x/net/websocket包，打Go 1.10之后就不怎么维护了，有安全缺陷，协议兼容性也让人捏把汗——说白了已经是个弃子，生产环境千万别碰它。那该怎么办？社区里早就有了事实标准，就是Gorilla WebSocket。这个库轻量、性能好、API设计清晰，而且完整遵循RFC 6455，拿来当客户端或者服务端的首选方案，实至名归。
✅ 正确连接与并发模型
核心思路其实就一条：每个WebSocket连接，得在单独的goroutine里跑。真正的并发，就该这么干。具体来说几件事：
- 用
websocket.Dial()建立连接； - 启动两个协程，一个专心读（ReadMessage），一个专心写（WriteMessage），免得互相阻塞；
- 通过
done channel或者context来控制生命周期； - 关键是，io.EOF、websocket.CloseMessage 这些终止信号要主动处理，而不是直接panic或者退出主程序。
下面这个示例，已经是可以直接拿到生产环境用的模板了。它启动N个并发连接，每个连接各自独立收发消息，你可以直接运行看看效果：
package mainimport ( "fmt" "log" "net/url" "time" "github.com/gorilla/websocket")func connectAndRun(addr string, id int) { u := url.URL{Scheme: "ws", Host: addr, Path: "/echo"} log.Printf("Client %d: dialing %s", id, u.String()) c, _, err := websocket.DefaultDialer.Dial(u.String(), nil) if err != nil { log.Printf("Client %d: dial error: %v", id, err) return } defer c.Close() // 发送心跳 + 随机消息 go func() { ticker := time.NewTicker(5 * time.Second) defer ticker.Stop() for range ticker.C { if err := c.WriteMessage(websocket.TextMessage, []byte(fmt.Sprintf("ping-%d-%d", id, time.Now().UnixMilli()))); err != nil { log.Printf("Client %d: write error: %v", id, err) return } } }() // 持续读取服务器响应 for { _, message, err := c.ReadMessage() if err != nil { // 关键：区分正常关闭与异常 if websocket.IsUnexpectedCloseError(err, websocket.CloseGoingAway, websocket.CloseAbnormalClosure) { log.Printf("Client %d: read error: %v", id, err) } else { log.Printf("Client %d: connection closed normally", id) } return } log.Printf("Client %d ← %s", id, string(message)) }}func main() { const numClients = 3 for i := 1; i <= numClients; i++ { go connectAndRun("localhost:8080", i) // 替换为目标 WebSocket 服务地址 } // 保持主 goroutine 运行（实际项目建议用 sync.WaitGroup 或 signal.Notify） select {}}⚠️ 注意事项与最佳实践
- 第一，别碰那个已经被弃用的x/net/websocket。它早就停止维护了，存在安全缺陷和协议兼容性问题。Gorilla WebSocket是官方推荐的替代方案，用起来放心。
- 第二，EOF真的不等于出错了。连接被对端正常关闭时，io.EOF必然会出现。你得把它当成一个合法的终止信号来处理，千万别panic或者直接os.Exit()。可以用
websocket.IsUnexpectedCloseError()辅助判断是否真的需要告警或重连。 - 第三，读写一定要分离。如果单协程串行调用ReadMessage和WriteMessage，死锁或者超时几乎是早晚的事。拆成独立的goroutine，再考虑加个写入超时（
c.SetWriteDeadline()），这样才稳。 - 第四，生产环境里连接复用和重连是标配。建议封装一个连接池，或者实现指数退避的重连逻辑，避免频繁建连带来的开销。
- 第五，依赖管理用Go Modules。跑一下这两行命令就好：
go mod init example.com/wsclientgo get github.com/gorilla/websocket
说到底，WebSocket客户端这件事，起手式对了，后面就顺了。从一个正确、健壮的连接模板出发，再往上叠加认证、心跳、消息序列化（JSON或者Protobuf）、还有日志追踪这些能力，一个企业级的应用就能快速搭建出来。
