如何用Golang实现WebSocket文件传输 剖析gorilla/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 文件传输不复杂但容易忽略细节，比如缓冲区配置、并发安全和消息顺序等问题。只要搞清楚数据是怎么流动的，剩下的就是按部就班地编码实现了。
以上就是如何用Golang实现WebSocket文件传输 剖析gorilla/websocket的用法的详细内容，更多请关注骃骐网【www.myinqi.com】。