当前位置：首页 > 文章列表 > Golang > Go教程 > Golang实现WebSocket服务教程

Golang实现WebSocket服务教程

2025-07-09 20:18:23 0浏览收藏

从现在开始，我们要努力学习啦！今天我给大家带来《Golang构建WebSocket服务教程》，感兴趣的朋友请继续看下去吧！下文中的内容我们主要会涉及到等等知识点，如果在阅读本文过程中有遇到不清楚的地方，欢迎留言呀！我们一起讨论，一起学习！

使用gorilla/websocket库可快速构建WebSocket服务，具体步骤如下：1. 初始化连接需配置Upgrader参数并注册处理函数；2. 通过ReadMessage和WriteMessage收发消息，建议分开goroutine处理；3. 部署时需设置超时与心跳机制；4. 使用全局map管理连接并加锁；5. 生产环境建议结合Nginx、使用加密协议并监控连接状态。整个流程基于HTTP升级实现，重点在于连接管理和性能优化。

Golang如何构建WebSocket服务使用gorilla/websocket库实践指南

构建WebSocket服务在Go语言中其实非常直接，尤其是使用 gorilla/websocket 这个社区广泛使用的库。它封装了底层细节，让你可以快速实现一个功能完善的WebSocket服务端。

下面是一些你实际开发中会用到的关键步骤和注意事项，适用于想快速上手并稳定运行的场景。

如何初始化WebSocket连接

WebSocket本质上是基于HTTP协议升级而来的长连接。所以你的处理函数需要先响应HTTP请求，然后尝试将其“升级”为WebSocket连接。

var upgrader = websocket.Upgrader{
    ReadBufferSize:  1024,
    WriteBufferSize: 1024,
}

这个 Upgrader 是用来控制升级过程的一些参数，比如缓冲区大小、跨域设置等。如果你的服务要接受前端页面的连接，记得配置允许跨域：

upgrader.CheckOrigin = func(r *http.Request) bool {
    return true // 或者根据来源做判断
}

然后写一个处理函数来完成升级动作：

func handleWebSocket(w http.ResponseWriter, r *http.Request) {
    conn, err := upgrader.Upgrade(w, r, nil)
    if err != nil {
        http.Error(w, "Could not open websocket connection", http.StatusBadRequest)
        return
    }
    // 后续处理连接
}

别忘了注册这个处理函数到某个路由上：

http.HandleFunc("/ws", handleWebSocket)

如何接收和发送消息

一旦连接建立，就可以通过 conn.ReadMessage() 和 conn.WriteMessage() 来收发消息了。通常我们会为每个连接启动一个 goroutine 来分别处理读写操作。

举个例子：

func handleWebSocket(w http.ResponseWriter, r *http.Request) {
    conn, _ := upgrader.Upgrade(w, r, nil)

    go func() {
        for {
            messageType, p, err := conn.ReadMessage()
            if err != nil {
                // 处理断开或错误
                break
            }
            fmt.Printf("收到消息：%s\n", string(p))
        }
    }()

    go func() {
        for {
            // 示例：定时发消息给客户端
            err := conn.WriteMessage(websocket.TextMessage, []byte("Hello"))
            if err != nil {
                break
            }
            time.Sleep(time.Second * 3)
        }
    }()
}

读写操作最好分开协程执行，避免阻塞。
注意捕获错误，比如连接关闭后继续读写会报错。
如果你要处理大量并发连接，建议加上连接池或者使用 channel 控制消息队列。

实际部署时需要注意的问题

超时设置
WebSocket连接不是无限存活的。你可以设置心跳机制来维持连接：
```
conn.SetReadDeadline(time.Now().Add(60 * time.Second))
conn.SetPongHandler(func(appData string) error {
    conn.SetReadDeadline(time.Now().Add(60 * time.Second))
    return nil
})
```
客户端也需要配合发送 ping 消息，否则服务端会判定为超时断开。
连接管理
如果你需要广播消息或跟踪在线用户，建议维护一个全局的连接集合，并加锁保护：
- 使用 map[*websocket.Conn]struct{} 存储连接
- 增删时加 sync.Mutex
- 在连接断开时及时清理
生产环境建议
- 配合反向代理（如Nginx）时，注意设置好 Upgrade 和 Connection 请求头
- 使用 HTTPS + WSS（加密WebSocket）
- 监控连接状态，防止内存泄漏