如何用 go 实现异步文件上传？使用 http.multipartfile 处理文件上传，它支持并发上传。创建一个 goroutine 来异步上传文件，不会阻塞主线程。使用 io.copy 将文件内容写入新文件。上传成功后打印日志消息。
如何使用 Golang 实现异步文件上传
异步文件上传是一种技术，允许你在不阻塞主线程的情况下向服务器上传文件。这对于大文件上传或需要在上传期间继续执行任务的应用很有用。Go 语言提供了内置的 http.MultipartFile 类型来处理文件上传，它支持并发上传。
代码示例
立即学习“go语言免费学习笔记（深入）”；
以下是一个使用 Go 语言实现异步文件上传的示例：
package main
import (
"context"
"fmt"
"io"
"log"
"net/http"
"github.com/gin-gonic/gin"
)
func main() {
router := gin.Default()
// 文件上传处理程序
router.POST("/upload", func(c *gin.Context) {
// 获取 multipart 文件
file, header, err := c.Request.FormFile("file")
if err != nil {
c.JSON(http.StatusBadRequest, gin.H{
"error": fmt.Sprintf("获取文件失败: %s", err.Error()),
})
return
}
// 创建一个 goroutine 来异步上传文件
go func() {
ctx := context.Background()
// 创建一个新文件并在其中写入
dst, err := os.Create(fmt.Sprintf("uploads/%s", header.Filename))
if err != nil {
log.Printf("创建文件失败: %s", err.Error())
return
}
defer dst.Close()
if _, err := io.Copy(dst, file); err != nil {
log.Printf("写入文件失败: %s", err.Error())
return
}
log.Printf("文件 %s 已成功上传", header.Filename)
}()
c.JSON(http.StatusOK, gin.H{
"status": "success",
})
})
router.Run(":8080")
}实战案例
这个示例是一个简单的文件上传服务，可以通过 POST 请求将文件上传到服务器。文件被异步上传到 uploads 目录，并且在上传成功后打印一条日志消息。
运行示例
- 使用你最喜欢的 Go 环境安装 Go。
- 克隆或下载代码示例。
- 打开终端并导航到示例目录。
- 运行
go run main.go。 - 使用浏览器或 HTTP 客户端工具发送一个
POST请求到http://localhost:8080/upload，其中包含一个名为file的文件字段。
如果文件上传成功，你应该会看到一条类似于 文件 example.txt 已成功上传 的日志消息。
