Golang实现WebSocket文件传输教程

使用 gorilla/websocket 在 Golang 中实现文件传输需遵循以下步骤：1. 建立 WebSocket 连接，通过 Upgrader 结构体将 HTTP 升级为 WebSocket；2. 发送端分块读取文件并通过 conn.WriteMessage 发送；3. 接收端持续监听并拼接数据至文件完成；4. 可扩展发送元信息以支持多文件及进度显示；5. 注意缓冲区大小、并发控制和错误处理。整个过程依赖于 WebSocket 的字节流特性，确保数据可靠传输。

WebSocket 是实现浏览器与服务器之间双向通信的利器，而文件传输正是其常见的应用场景之一。在 Golang 中，使用 gorilla/websocket 包可以非常方便地构建 WebSocket 服务端和客户端。下面我们就来看看如何用这个库实现文件传输。

建立 WebSocket 连接是第一步

要开始文件传输，首先要建立一个 WebSocket 连接。gorilla/websocket 提供了 Upgrader 结构体来将 HTTP 连接升级为 WebSocket。

var upgrader = websocket.Upgrader{
    ReadBufferSize:  1024,
    WriteBufferSize: 1024,
    CheckOrigin: func(r *http.Request) bool {
        return true // 开发阶段可以先放行所有跨域请求
    },
}

func wsHandler(w http.ResponseWriter, r *http.Request) {
    conn, _ := upgrader.Upgrade(w, r, nil)
    // 后续处理连接
}

这里的关键点在于设置好 Upgrader 的参数，并确保你的路由正确指向这个 handler。一旦连接建立成功，就可以通过 conn.ReadMessage() 和 conn.WriteMessage() 来收发数据了。

接收和发送文件的基本逻辑

WebSocket 本质上是字节流协议，所以文件传输其实就是把文件分块读取并通过 WebSocket 发送过去。接收方再把这些数据拼起来写入本地。

发送文件的大致流程如下：

• 打开本地文件，创建缓冲区
• 循环读取文件内容
• 每次读取到数据后，通过 WebSocket 发送出去
• 文件读完后发送 EOF 或者关闭通道通知对方

示例代码片段（发送）：

file, _ := os.Open("example.txt")
defer file.Close()

buffer := make([]byte, 1024)
for {
    n, err := file.Read(buffer)
    if n > 0 {
        conn.WriteMessage(websocket.BinaryMessage, buffer[:n])
    }
    if err != nil {
        break
    }
}

接收端则需要持续监听消息，直到收到结束信号或出错为止。

处理多文件、进度条等扩展功能

实际使用中可能需要支持多个文件，或者显示上传/下载进度。这时你可以考虑以下几点：

• 在发送前先发送文件名、大小等元信息（可以用 JSON 格式）
• 接收端根据这些信息创建文件并准备接收数据
• 每次收到一块数据后更新已接收大小，计算百分比，返回给前端用于显示进度条

比如可以这样发送元信息：

type FileInfo struct {
    Name string
    Size int64
}

info := FileInfo{Name: "test.txt", Size: 1234567}
data, _ := json.Marshal(info)
conn.WriteMessage(websocket.TextMessage, data)

然后继续发送文件内容。接收端先解析文本消息获取文件信息，再开始接收二进制数据。

注意事项：缓冲区大小、并发控制、错误处理

虽然 gorilla/websocket 使用起来简单，但实际部署时还是有几个细节需要注意：

• 缓冲区大小：默认的 ReadBufferSize 和 WriteBufferSize 都是 1024 字节，如果文件较大，建议适当调大以提升效率。
• 并发控制：一个连接同时只能有一个 reader 和 writer 在运行，否则会出现竞态问题。可以通过加锁或使用 goroutine + channel 控制。
• 错误处理：每次读写都应检查错误，尤其是网络中断等情况，避免程序崩溃。

例如处理错误的一个小技巧：

_, msg, err := conn.ReadMessage()
if err != nil {
    log.Println("读取消息失败:", err)
    return
}

基本上就这些。WebSocket 文件传输不复杂但容易忽略细节，比如缓冲区配置、并发安全和消息顺序等问题。只要搞清楚数据是怎么流动的，剩下的就是按部就班地编码实现了。