如何在golang中跟踪上传进度

huangapple
go评论106阅读模式
英文:

How do i track the upload progress in golang

问题

我正在尝试在GOLANG中跟踪上传进度，这是我目前得到的代码部分：

  1. func Upload(w http.ResponseWriter, req *http.Request) {
  3.     mr, err := req.MultipartReader()
  4.     if err != nil {
  5.         return
  6.     }
  8.     for {
  9.         // var part *multipart.Part
  10.         part, err := mr.NextPart()
  11.         mr.partsRead
  13.         if err == io.EOF {
  14.             break
  15.         }
  16.         println(part)
  18.     }
  20. }
英文:

i'm trying to track the upload progress in GOLANG, that's what i got at the moment

  1. func Upload(w http.ResponseWriter, req *http.Request) {
  3.     mr, err := req.MultipartReader()
  4.     if err != nil {
  5.         return
  6.     }
  8.     for {
  9.     	// var part *multipart.Part
  10.     	part, err := mr.NextPart()
  11.     	mr.partsRead
  13.     	if err == io.EOF {
  14.     		break
  15.     	}
  16.     	println(part)
  18.     }
  20. }

答案1

得分: 8

这将起作用，一个stream用于计算读取的字节数和总进度，你需要将stream指向某个地方，在这个代码示例中，我将其指向了一个文件。

  1. func Upload(w http.ResponseWriter, req *http.Request) {
  3.     mr, err := req.MultipartReader()
  4.     if err != nil {
  5.         return
  6.     }
  7.     length := req.ContentLength
  8.     for {
  9.          
  10.         part, err := mr.NextPart()
  11.         if err == io.EOF {
  12.             break
  13.         }
  14.         var read int64
  15.         var p float32
  16.         dst, err := os.OpenFile("dstfile", os.O_WRONLY|os.O_CREATE, 0644)
  17.         if err != nil {
  18.             return
  19.         }
  20.         for {
  21.             buffer := make([]byte, 100000)
  22.             cBytes, err := part.Read(buffer)
  23.             if err == io.EOF {
  24.                 break
  25.             }
  26.             read = read + int64(cBytes)
  27.             //fmt.Printf("read: %v \n",read )
  28.             p = float32(read) / float32(length) *100
  29.             fmt.Printf("progress: %v \n",p )
  30.             dst.Write(buffer[0:cBytes])
  31.         }
  32.     }
  33. }
英文:

This will work, a stream to calc the bytes read and the total progress you need to point the stream somewhere, in this code example I pointed it to a file.

  1. func Upload(w http.ResponseWriter, req *http.Request) {
  3.     mr, err := req.MultipartReader()
  4.     if err != nil {
  5.         return
  6.     }
  7.     length := req.ContentLength
  8.     for {
  9.          
  10.         part, err := mr.NextPart()
  11.         if err == io.EOF {
  12.             break
  13.         }
  14.         var read int64
  15.         var p float32
  16.         dst, err := os.OpenFile("dstfile", os.O_WRONLY|os.O_CREATE, 0644)
  17.         if err != nil {
  18.             return
  19.         }
  20.         for {
  21.             buffer := make([]byte, 100000)
  22.             cBytes, err := part.Read(buffer)
  23.             if err == io.EOF {
  24.                 break
  25.             }
  26.             read = read + int64(cBytes)
  27.             //fmt.Printf("read: %v \n",read )
  28.             p = float32(read) / float32(length) *100
  29.             fmt.Printf("progress: %v \n",p )
  30.             dst.Write(buffer[0:cBytes])
  31.         }
  32.     }
  33. }

huangapple
  • 本文由 发表于 2012年11月19日 19:33:39
  • 转载请务必保留本文链接：https://go.coder-hub.com/13452914.html
  • go
  • http
  • progress
  • upload
匿名

发表评论

匿名网友

:?: :razz: :sad: :evil: :!: :smile: :oops: :grin: :eek: :shock: :???: :cool: :lol: :mad: :twisted: :roll: :wink: :idea: :arrow: :neutral: :cry: :mrgreen:

确定