需要用到环形缓冲区进行读写:golang 环形缓冲区

网上的例子大部分都是把文件全部缓存到内存上传，大文件隐患不小，这个的好处就是缓冲区小，全靠流输入输出。

go get github.com/mgr9525/go-ruisutil

func randomBoundary() string {
	var buf [30]byte
	_, err := io.ReadFull(rand.Reader, buf[:])
	if err != nil {
		panic(err)
	}
	return fmt.Sprintf("%x", buf[:])
}
/*
 * url:上传地址
 * flpath:上传文件地址
 */
func upload(url,flpath string){
	body := ruisUtil.NewCircleByteBuffer(10240)
	boundary:=randomBoundary()
	boundarybytes := []byte("\r\n--" + boundary + "\r\n")
	endbytes := []byte("\r\n--" + boundary + "--\r\n")

	reqest, err := http.NewRequest("POST", url, body)
	if err != nil { panic(err) }
	reqest.Header.Add("Connection", "keep-alive")
	reqest.Header.Add("Content-Type", "multipart/form-data; charset=utf-8; boundary="+boundary)
	go func() {
		//defer ruisRecovers("upload.run")
		f, err := os.OpenFile(flpath, os.O_RDONLY, 0666)  //其实这里的 O_RDWR应该是 O_RDWR|O_CREATE，也就是文件不存在的情况下就建一个空文件，但是因为windows下还有BUG，如果使用这个O_CREATE，就会直接清空文件，所以这里就不用了这个标志，你自己事先建立好文件。
		if err != nil { panic(err) }
		stat, err := f.Stat()    //获取文件状态
		if err != nil { panic(err) }
		defer f.Close()

		header:=fmt.Sprintf("Content-Disposition: form-data; name=\"upfile\"; filename=\"%s\"\r\nContent-Type: application/octet-stream\r\n\r\n",stat.Name())
		body.Write(boundarybytes)
		body.Write([]byte(header))

		fsz:=float64(stat.Size())
		fupsz:=float64(0)
		buf:=make([]byte,1024)
		for {
			time.Sleep(10*time.Microsecond)//减缓上传速度，看进度效果
			n,err:=f.Read(buf)
			if n>0{
				nz,_:=body.Write(buf[0:n])
				fupsz+=float64(nz)
				progress := strconv.Itoa(int((fupsz / fsz) * 100))+"%"
				fmt.Println("upload:",progress,"|",strconv.FormatFloat(fupsz,'f',0,64),"/",stat.Size())
			}
			if err==io.EOF {
				break
			}
		}
		body.Write(endbytes)
		body.Write(nil)//输入EOF,表示数据写完了
	}()
	resp,err:=http.DefaultClient.Do(reqest)
	if err != nil { panic(err) }
	defer resp.Body.Close()
	if resp.StatusCode==200{
		fmt.Println("上传成功")
	}else{
		fmt.Println("上传失败,StatusCode:",resp.StatusCode)
	}
}

调用：

upload("http://localhost:8080/upload","e:\\123.txt")