Beego文件上传至七牛云的玩法

前言Beego是一款GO语言开发的传统MVC的框架，beego对上传这块的代码封装的也非常简单易用。beego的上传贴出官方的一段代码https://beego.me/docs/mvc/con…func (c *FormController) Post() { f, h, err := c.GetFile(“uploadname”) if err != nil { log.Fatal(“getfile err “, err) } defer f.Close() c.SaveToFile(“uploadname”, “static/upload/” + h.Filename) // 保存位置在 static/upload, 没有文件夹要先创建 }这里beego通过 GetFile方法获取文件的name，既设置的 input name=“uploadname” 可以通过其第二个返回值获得文件的详细详细h.Filenameh.Headerh.size上面的例子是一个传统上传，既将文件拷贝到本地项目目录中。七牛云关于注册、登录、获取key什么的本文就不废话了。官方提供了Go的Sdk文档地址：https://developer.qiniu.com/k…安装通过go get 安装包go get -u github.com/qiniu/api.v7使用这里演示两种上传方式七牛官方的SDK提供了几个上传方法，如下所示// 本地文件上传至七牛云func (p *FormUploader) PutFilefunc (p *FormUploader) PutFileWithoutKey// 数据流方式上传至七牛云func (p *FormUploader) Putfunc (p *FormUploader) PutWithoutKey这个SDK也允许你自定义返回结果,通过重写结构体的方式type PutRet struct { Hash string json:"hash" PersistentID string json:"persistentId" Key string json:"key"}本地上传这是官方的一个demo,本地上传这里就不多阐述了，大概都能看懂// 设置上传文件localFile = “/Users/jemy/Documents/github.png”// 设置上传空间名bucket = “if-pbl”// 上传的文件名称key = “github-x.png"putPolicy := storage.PutPolicy{ Scope: bucket,}mac := qbox.NewMac(accessKey, secretKey)upToken := putPolicy.UploadToken(mac)cfg := storage.Config{}// 空间对应的机房cfg.Zone = &storage.ZoneHuadong// 是否使用https域名cfg.UseHTTPS = false// 上传是否使用CDN上传加速cfg.UseCdnDomains = false// 构建表单上传的对象formUploader := storage.NewFormUploader(&cfg)ret := storage.PutRet{}// 可选配置putExtra := storage.PutExtra{ Params: map[string]string{ “x:name”: “github logo”, },}err := formUploader.PutFile(context.Background(), &ret, upToken, key, localFile, &putExtra)if err != nil { fmt.Println(err) return}fmt.Println(ret.Key,ret.Hash)流信息上传这是我自行封装的流上传代码package qiniuimport ( “github.com/qiniu/api.v7/storage” “github.com/qiniu/api.v7/auth/qbox” “context” “io”)const ( bucket = “avatars” // accessKey = "” secretKey = “")func config() storage.Config { cfg := storage.Config{} cfg.Zone = &storage.ZoneHuadong // 是否使用https域名 cfg.UseHTTPS = false // 上传是否使用CDN上传加速 cfg.UseCdnDomains = false return cfg}func Upload(localFile io.Reader, size int64, filename string) (string, error) { putPolicy := storage.PutPolicy{ Scope: bucket, } mac := qbox.NewMac(accessKey, secretKey) upToken := putPolicy.UploadToken(mac) cig := config() formUploader := storage.NewFormUploader(&cig) ret := storage.PutRet{} putExtra := storage.PutExtra{} err := formUploader.Put(context.Background(), &ret, upToken, filename, localFile, size, &putExtra) if err != nil { return “”, err } return ret.Key, nil}注意localFile io.Reader这个参数，调用upload方法需要传一个byte。下面演示调用方法的代码func (u *UserController) UploadImage() { f, h, err := u.GetFile(“image”) if err != nil { u.Data[“json”] = common.Response{ Data: [0]int{}, Message: “上传失败”, Code: 0, } u.ServeJSON() return } defer f.Close() file, _ := h.Open() // 这里获得的实际就是一个io,通过源码看到这个open方法最终返回的是一个结构体,其内部包含了 io.Reader的接口 // type File interface { // io.Reader // io.ReaderAt // io.Seeker // io.Closer // } unix := time.Now().Unix() timeByte := []byte(strconv.Itoa(int(unix))) filename := function.Md5(timeByte) // 这里是计算了一个md5(time())的字符串作为文件名 if filename, err = qiniu.Upload(file, h.Size, filename); err != nil { // 通过h.size 即可获得文件大小 u.Data[“json”] = common.Response{ Data: [0]int{}, Message: “上传失败”, Code: 0, } } else { u.Data[“json”] = common.Response{ Data: map[string]string{ “filename”: filename, }, Message: “上传成功”, Code: 200, } } u.ServeJSON()}致谢go 自身的特点不应是做web，web使用php，java就够了。一般用go都是写接口。所以上传文件时不应先传到本地再传到七牛，我想很多初学者都在这里被坑。特此写一篇来解释其使用方法。希望本篇文章可以帮到你。谢谢