如何用 Go 实现异步文件上传?使用 http.MultipartFile 处理文件上传,它支持并发上传。创建一个 goroutine 来异步上传文件,不会阻塞主线程。使用 io.Copy 将文件内容写入新文件。上传成功后打印日志消息。
如何使用 Golang 实现异步文件上传
异步文件上传是一种技术,允许你在不阻塞主线程的情况下向服务器上传文件。这对于大文件上传或需要在上传期间继续执行任务的应用很有用。Go 语言提供了内置的 http.MultipartFile
类型来处理文件上传,它支持并发上传。
代码示例
以下是一个使用 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 run main.go
。POST
请求到 http://localhost:8080/upload
,其中包含一个名为 file
的文件字段。如果文件上传成功,你应该会看到一条类似于 文件 example.txt 已成功上传
的日志消息。
以上是如何使用 Golang 实现异步文件上传?的详细内容。更多信息请关注PHP中文网其他相关文章!