使用io.copy配合os.File与网络连接实现golang文件流传输,避免内存溢出。通过http可直接用http.ServeFile或手动设置响应头并流式输出;TCP场景下服务端监听接收连接后发送文件,客户端读取写入本地。示例代码展示HTTP下载处理器及TCP收发逻辑。默认32KB缓冲区可通过io.CopyBuffer自定义增大至64KB提升高延迟网络吞吐,需设置超时机制避免资源占用。关键点包括错误处理、defer释放资源、按场景选协议。完整流程涵盖打开文件、设头、复制数据、关闭连接,适用于大文件高效稳定传输。

在golang中实现文件流传输,核心是使用io.Copy或io.CopyBuffer配合os.File与网络连接(如net.Conn或http.ResponseWriter),逐块读取文件内容并发送,避免一次性加载大文件到内存。这种方式高效、稳定,适用于HTTP服务、rpc通信或自定义TCP协议场景。
使用HTTP实现文件流下载
通过http.ServeFile可以直接传输文件,但若需自定义响应头或控制传输过程,推荐手动流式输出。
- 打开本地文件,使用
os.Open - 设置响应头,告知客户端为文件下载
- 使用
io.Copy将文件内容写入http.ResponseWriter
示例代码:
func downloadHandler(w http.ResponseWriter, r *http.Request) { file, err := os.Open("example.zip") if err != nil { http.Error(w, "文件未找到", http.StatusNotFound) return } defer file.Close() w.Header().Set("Content-Disposition", "attachment; filename=example.zip") w.Header().Set("Content-Type", "application/octet-stream") io.Copy(w, file) }
通过TCP连接传输文件流
在自定义协议或内部服务间传输大文件时,可使用TCP连接进行流式发送。
立即学习“go语言免费学习笔记(深入)”;
- 服务端监听端口,接收连接
- 收到请求后打开文件,逐块发送数据
- 客户端读取数据并写入本地文件
服务端发送文件示例:
conn, _ := listener.Accept() file, _ := os.Open("data.tar.gz") defer file.Close() io.Copy(conn, file) conn.Close()
客户端接收示例:
conn, _ := net.Dial("tcp", "server:8080") out, _ := os.Create("received.tar.gz") defer out.Close() io.Copy(out, conn) conn.Close()
优化传输性能
默认io.Copy使用32KB缓冲区,可使用io.CopyBuffer指定更大缓冲区提升吞吐量,尤其在高延迟网络中有效。
示例:
buffer := make([]byte, 64*1024) // 64KB buffer _, err := io.CopyBuffer(w, file, buffer)
同时注意设置适当的超时机制,防止连接长时间占用资源。
基本上就这些。按实际场景选择HTTP或TCP方式,合理利用缓冲和连接管理,就能稳定实现文件流传输。不复杂但容易忽略细节,比如错误处理和资源释放。


