如何用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 连接。

gorilla/websocket

Upgrader

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()

立即学习“go语言免费学习笔记（深入）”；

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

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

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

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

示例代码片段（发送）：

Getfloorplan

创建 2D、3D 平面图和 360° 虚拟游览，普通房间变成梦想之家

148

查看详情

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的用法的详细内容，更多请关注php中文网其它相关文章！