本已更新，本次更新最大亮点是把多种文件存储方式集成在框架中，放弃之前单一种方式做成独立插件安装，单个插件虽然有代码少的优点，但是在实际业务开发时，当切换其他存储位置时，之前存储位置文件无法访问，且代码结构相对零散。所以从实现业务需求出发，我们决定把多种存储方式集成在一起，统一代码结构，统一调用，后台统一管理，切换方便。

在软件开发中文件上传存储、访问文件是一个必不可少的功能，好用文件存储管理可让开发省去很多的时间，这也是GoFly框架本次更新重视文件文件存储管理的原因。

，开发时可以直接通过后台配置不同存储位置参数，点“文件存储方式”切换并提交“保存”即可完成不同文件存储位置变更。

​ ，账号：gofly   密码：gofly123

框架把多种文件存储位置集成后，提供给业务开发统一调用函数，只需在后台选择存储位置和配置相关参数即可，代码部分就不用单独处理。

参数：c请求上下文，file上传文件流

//处理文件上传，bin返回地址
url, cover_url, err := uploads.New().UploadFile(c, file)

注意：如果在选择文件上传云服务器，但某个功能文件需要单独本地存储，则New()添加参数如下：

//处理文件上传，bin返回地址
url, cover_url, err := uploads.New("local").UploadFile(c, file)
if err != nil {
  gf.Failed().SetMsg("上传文件失败").SetData(err).Regin(c)
  return
}

其中New("local")参数local可以改为：alioss、tencentcos、qiniuoss等其他云存储名。

参数：url是删除文件路径，不包含域名的路径。


// 上传文件
func (api *Upfile) LocalFile(c *gf.GinCtx) {
	//file文件流
	file, err := c.FormFile("file")
	if err != nil {
		gf.Failed().SetMsg("获取数据失败").SetData(err).Regin(c)
		return
	}
	//判断文件是否已经传过
	fileContent, _ := file.Open()
	defer fileContent.Close()
	var byteContainer []byte = make([]byte, 1000000)
	fileContent.Read(byteContainer)
	m_d5 := md5.New()
	m_d5.Write(byteContainer)
	sha1_str := hex.EncodeToString(m_d5.Sum(nil))
	//查找该用户是否传过
	attachment, _ := gf.Model("business_attachment").Where("business_id", businessID).
		Where("sha1", sha1_str).Fields("id,pid,name,title,type,url,filesize,mimetype,cover_url as cover").Find()
	if attachment != nil { //文件是否已经存在
		//更新到最前面
		maxId, _ := gf.Model("business_attachment").Where("business_id", businessID).Order("weigh desc").Value("id")
		if maxId != nil {
			gf.Model("business_attachment").Data(map[string]interface{}{"weigh": maxId.Int() + 1, "pid": 1}).Where("id", attachment["id"]).Update()
		}
		gf.Success().SetMsg("文件已上传").SetData(attachment).Regin(c)
	} else {
		//这里处理文件上传 并返回地址， uploads.New().UploadFile就是把文件上传到配置设定位置
		url, cover_url, err := uploads.New().UploadFile(c, file)
		if err != nil {
			gf.Failed().SetMsg("上传文件失败").SetData(err).Regin(c)
			return
		}
		filename_arr := strings.Split(file.Filename, ".")
		//文件类型
		fileData := gf.Map{
			"type":        0, //图片
			"pid":         1, //存储在默认文件夹
			"sha1":        sha1_str,
			"title":       filename_arr[0],
			"name":        file.Filename,
			"url":         url,       //附件路径
			"cover_url":   cover_url, //封面
			"storage":     "local",
			"createtime":  time.Now().Unix(),
			"filesize":    file.Size,
			"mimetype":    file.Header["Content-Type"][0],
		}
		//保存数据
		file_id, _ := gf.Model("business_attachment").Data(fileData).InsertAndGetId()
		//更新排序
		gf.Model("business_attachment").Data(map[string]interface{}{"weigh": file_id}).Where("id", file_id).Update()
		//处理预览url地址
		gf.Success().SetMsg("文件上传成功").SetData(gf.GetFullUrl(url)).Regin(c)
	}
}

如果某个功能需单独存储在指定位置，和系统设置的全局存储位置不同，比如把使用频率或者访问速度要求较低的，我们可以把他存储在本地，那么把uploads.New("local").UploadFile(c, file)的New函数中添加存储位置名，本地存储名为：local 则上传本地调用的代码如下：

//处理文件上传，并返回地址
url, cover_url, err := uploads.New("local").UploadFile(c, file)
if err != nil {
	gf.Failed().SetMsg("上传文件失败").SetData(err).Regin(c)
	return
}

框架已经为各端客户端封装好了，可以直接调用上传文件接口，使用GoFly框架开发时没有特殊要求就不需要写上传文件接口代码，直接调用现成就实现上传。

接口：域名+admin/datacenter/upfile/upload

接口：域名+business/datacenter/upfile/upload

4.3 非管理后台客户端（微信小程序、app、h5应用）

集成上传文件的代码位置在：utils\extend\uploads，在uploads目录下有个index.go是统一调用函数入口及配置存储代码。目录下的local.go为本地上传功能代码、tencentCOS.go为腾讯云存储功能代码。

下面介绍集成新的上传方式步骤，这里就以腾讯云存储集成流程演示：

在utils\extend\uploads创建一个名为：

package uploads

import (
	"context"
	"errors"
	"fmt"
	"gofly/utils/gf"
	"mime/multipart"
	"net/http"
	"net/url"
	"path"
	"path/filepath"
	"time"

	"github.com/tencentyun/cos-go-sdk-v5"
)

// 腾讯云 COS
type TencentCOS struct {
	Client *cos.Client
	Ready  bool
	Config Config
}

// 初始化客户端
func (m *TencentCOS) InitClient(config Config) {
	m.Ready = false
	m.Config = config
	u, _ := url.Parse(fmt.Sprintf("https://%v.cos.%v.myqcloud.com", m.Config.BucketName, m.Config.Region))
	b := &cos.BaseURL{BucketURL: u}
	m.Client = cos.NewClient(b, &http.Client{
		Transport: &cos.AuthorizationTransport{
			// 用户的 SecretId，建议使用子账号密钥，授权遵循最小权限指引，降低使用风险。
			// 子账号密钥获取可参考 https://cloud.tencent.com/document/product/598/37140
			SecretID: m.Config.KeyId,
			// 用户的 SecretKey，建议使用子账号密钥，授权遵循最小权限指引，降低使用风险。
			// 子账号密钥获取可参考 https://cloud.tencent.com/document/product/598/37140
			SecretKey: m.Config.Secret,
		},
	})
	m.Ready = true
}

// 上传文件
func (m *TencentCOS) UploadFile(c *gf.GinCtx, file *multipart.FileHeader) (url, cover_url string, err error) {
	if !m.Ready {
		err = errors.New("not ready")
		return
	}
	fd, err := file.Open()
	if err != nil {
		return
	}
	defer fd.Close()
	//注意:文件名称必须以tencentcos开头
	path_name := fmt.Sprintf("%v/%v/%v", m.Config.DirPath, time.Now().Format("20060102"), MakeFileName(file, "tencentcos"))
	url = path_name
	_, err = m.Client.Object.Put(context.Background(), path_name, fd, nil)
	return
}

// 下载文件
func (m *TencentCOS) DownloadFile(fileUrl string) error {
	if !m.Ready {
		return errors.New("not ready")
	}
	localFileUrl, cloudFileUrl := InitFileUrl(fileUrl, m.Config)
	_, err := m.Client.Object.GetToFile(context.Background(), cloudFileUrl, localFileUrl, nil)
	return err
}

// 删除文件
func (m *TencentCOS) RemoveFile(fileUrl string) error {
	if !m.Ready {
		return errors.New("not ready")
	}
	_, cloudFileUrl := InitFileUrl(fileUrl, m.Config)
	_, err := m.Client.Object.Delete(context.Background(), cloudFileUrl)
	return err
}

// 移动文件
func (m *TencentCOS) MoveFile(fileUrl string, targerDir string) (string, error) {
	// 本地移动
	fileUrl, _ = InitFileUrl(fileUrl, m.Config)
	targerUrl := path.Join(targerDir, filepath.Base(fileUrl))
	targerUrl, _ = InitFileUrl(targerUrl, m.Config)
	MoveFile(fileUrl, targerUrl)

	// 腾讯云移动
	_, fileUrl = InitFileUrl(fileUrl, m.Config)
	_, targerUrl = InitFileUrl(targerUrl, m.Config)

	// 移动对象
	var err error
	bucketURL := m.Client.BaseURL.BucketURL
	sourceURL := fmt.Sprintf("%s/%s", bucketURL.Host, fileUrl)
	_, _, err = m.Client.Object.Copy(context.Background(), targerUrl, sourceURL, nil)
	if err != nil {
		return "", err
	}
	_, err = m.Client.Object.Delete(context.Background(), fileUrl, nil)
	if err != nil {
		return "", err
	}
	return targerUrl, nil
}


写好上传、删除等相关接口后，需要把

.go在统一调用index.go文件注册，具体如下

// =====================
// 附件上传入口
// =====================
package uploads

import (
	"gofly/utils/gf"
	"mime/multipart"
	"os"
	"path/filepath"
	"strconv"
	"strings"

	"gofly/utils/tools/gcfg"
	"gofly/utils/tools/gctx"
	"gofly/utils/tools/gfile"
	"gofly/utils/tools/grand"
	"gofly/utils/tools/gtime"
)

var (
	ctx = gctx.New()
)

// 配置
type Config struct {
	Endpoint       string //自定义服务请求的访问域名
	KeyId          string
	Secret         string
	BucketName     string //空间名称
	DestBucketName string //移动目标空间名称
	Region         string //所属地域
	LocalBaseUrl   string
	BaseUrl        string
	DirPath        string //上传文件路径
	UseHTTPS       bool   // 是否使用https域名进行资源管理
	Zone           int    //指定仓库内的存储区域，比如华东区域
}

type StaticCloud interface {
	InitClient(config Config)
	UploadFile(c *gf.GinCtx, file *multipart.FileHeader) (url, cover_url string, err error)
	DownloadFile(fileUrl string) error
	RemoveFile(fileUrl string) error
	MoveFile(fileUrl string, targerDir string) (string, error)
}

// 规划文件路径，localUrl=本地路径，cloudUrl=云路径
func InitFileUrl(fileUrl string, config Config) (localUrl string, cloudUrl string) {
	if fileUrl[0:2] == "./" {
		localUrl = fileUrl
		cloudUrl = fileUrl[2:]
	} else if fileUrl[0:1] == "/" {
		localUrl = "." + fileUrl
		cloudUrl = fileUrl[1:]
	} else if fileUrl[0:4] == "http" {
		cloudUrl = strings.ReplaceAll(fileUrl, config.BaseUrl, "")
		localUrl = "./" + cloudUrl
	} else {
		localUrl = fileUrl
		cloudUrl = fileUrl
	}
	return localUrl, cloudUrl
}

// 初始配置，如果传uptype(上传方式)，则直接示例传入上传方式，不传则从配置文件获取设置的上传方式
func New(uptype ...string) StaticCloud {
	var staticCloud StaticCloud
	var upTypeStr string = ""
	var config = Config{}
	if len(uptype) > 0 && uptype[0] != "" {
		upTypeStr = uptype[0]
	} else {
		confType, _ := gcfg.Instance("upload").Get(ctx, "Type")
		upTypeStr = confType.String()
	}
	switch upTypeStr {
	case "alioss":
		alioss, _ := gcfg.Instance("upload").Get(ctx, "alioss")
		mapConf := alioss.Map()
		config = Config{
			BaseUrl:    gf.String(mapConf["ABaseUrl"]),
			Endpoint:   gf.String(mapConf["AEndpoint"]),
			KeyId:      gf.String(mapConf["AKeyId"]),
			Secret:     gf.String(mapConf["ASecret"]),
			BucketName: gf.String(mapConf["ABucketName"]),
			DirPath:    gf.String(mapConf["ADirPath"]),
		}
		staticCloud = &AliOSS{}
	case "tencentcos":
		tencentcos, _ := gcfg.Instance("upload").Get(ctx, "tencentcos")
		mapConf := tencentcos.Map()
		config = Config{
			BaseUrl:    gf.String(mapConf["TBaseUrl"]),
			Endpoint:   gf.String(mapConf["TEndpoint"]),
			KeyId:      gf.String(mapConf["TKeyId"]),
			Secret:     gf.String(mapConf["TSecret"]),
			BucketName: gf.String(mapConf["TBucketName"]),
			Region:     gf.String(mapConf["TRegion"]),
			DirPath:    gf.String(mapConf["TDirPath"]),
		}
		staticCloud = &TencentCOS{}
	case "qiniuoss":
		qiniuoss, _ := gcfg.Instance("upload").Get(ctx, "qiniuoss")
		mapConf := qiniuoss.Map()
		config = Config{
			BaseUrl:    gf.String(mapConf["QBaseUrl"]),
			Endpoint:   gf.String(mapConf["QEndpoint"]),
			KeyId:      gf.String(mapConf["QKeyId"]),
			Secret:     gf.String(mapConf["QSecret"]),
			BucketName: gf.String(mapConf["QBucketName"]),
			DirPath:    gf.String(mapConf["QDirPath"]),
			UseHTTPS:   gf.Bool(mapConf["QUseHTTPS"]),
			Zone:       gf.Int(mapConf["QZone"]),
		}
		staticCloud = &QiniuOSS{}
	default:
		local, _ := gcfg.Instance("upload").Get(ctx, "local")
		mapConf := local.Map()
		config = Config{
			BaseUrl: gf.String(mapConf["LBaseUrl"]),
			DirPath: gf.String(mapConf["LDirPath"]),
		}
		staticCloud = &Local{}
	}
	staticCloud.InitClient(config)
	return staticCloud
}

func MoveFile(fileUrl string, targerUrl string) error {
	// 检查目标目录是否存在，不存在则创建
	targerDir := filepath.Dir(targerUrl)
	if _, err := os.Stat(targerDir); os.IsNotExist(err) {
		err := os.MkdirAll(targerDir, 0777)
		if err != nil {
			return err
		}
	}
	// 移动文件至目标文件夹
	return os.Rename(fileUrl, targerUrl)
}

// 上传云本地零时文件存储
// func MomentLocal(file *multipart.FileHeader) string {
// 	return ""
// }

// 删除附件统一入口，结果返回：bool
func DelFile(fileUrl string) error {
	//处理地址
	filseName := gfile.Name(fileUrl)
	uptype := ""
	if strings.HasPrefix(filseName, "local") { //本地存储
		uptype = "local"
	} else if strings.HasPrefix(filseName, "alioss") { //阿里云
		uptype = "alioss"
	} else if strings.HasPrefix(filseName, "tencentcos") { //腾讯云
		uptype = "tencentcos"
	} else if strings.HasPrefix(filseName, "qiniuoss") { //七牛云
		uptype = "qiniuoss"
	} else { //默认返回设置上传方式的地址
		UpType, _ := gcfg.Instance("upload").Get(ctx, "Type")
		uptype = UpType.String()
	}
	return New(uptype).RemoveFile(fileUrl)
}

// 生成文件名,ext文件名前缀
func MakeFileName(file *multipart.FileHeader, ext ...string) string {
	name := strings.ToLower(strconv.FormatInt(gtime.TimestampNano(), 36) + grand.S(6))
	extStr := ""
	if len(ext) > 0 && ext[0] != "" {
		extStr = ext[0]
	}
	return extStr + name + gfile.Ext(file.Filename)
}


// 删除附件统一入口，结果返回：bool
func DelFile(fileUrl string) error {
	//处理地址
	filseName := gfile.Name(fileUrl)
	uptype := ""
	if strings.HasPrefix(filseName, "local") { //本地存储
		uptype = "local"
	} else if strings.HasPrefix(filseName, "alioss") { //阿里云
		uptype = "alioss"
	} else if strings.HasPrefix(filseName, "tencentcos") { //腾讯云
		uptype = "tencentcos"
	} else if strings.HasPrefix(filseName, "qiniuoss") { //七牛云
		uptype = "qiniuoss"
	}else { //默认返回设置上传方式的地址
		UpType, _ := gcfg.Instance("upload").Get(ctx, "Type")
		uptype = UpType.String()
	}
	return New(uptype).RemoveFile(fileUrl)
}


在后端资源目录：resource\config\upload.yaml添加腾讯云存储配置参数：

# 存储方式
Type: local
# 配置传输文件最大值，如上传文件最大上限，单位为MB
MaxBodySize: 600
# 允许上传的文件类型
AllowedExt: .jpg,.jpeg,.png,.pdf,.ico
# 本地存储配置
local: 
  LBaseUrl: http://localhost:8200
  LDirPath: /resource/uploads/
# 阿里云静态云存储配置
alioss:
  ABaseUrl: https://hcoder.oss-cn-beijing.aliyuncs.com/
  AEndpoint: oss-cn-beijing.aliyuncs.com
  AKeyId: 
  ASecret: 
  ABucketName: 
  ADirPath: 
# 腾讯云静态云存储配置
tencentcos:
  TBaseUrl: https://gofly-1257246782.cos.ap-nanjing.myqcloud.com
  TEndpoint: 
  TKeyId: AKIDGUYaP1TmtpY4NSJxlWK0eAbzEKEvRkw0
  TSecret: 
  TBucketName: gofly-1257246782
  TRegion: ap-nanjing
  TDirPath: /goflys
# 七牛云存储配置
qiniuoss:
  QBaseUrl: http://t3wcppubp.hn-bkt.clouddn.com/
  QEndpoint: 
  QKeyId: dtxSwoGm1hwkn5FvhEI8QBvIKxn08_5iYypjC4u8
  QSecret: 
  QBucketName: goflys
  QDirPath: image
  QDestBucketName: <nil>
  QUseHTTPS: false
  QZone: 4

4.把新增存储方式添加管理后台

后端添加好后，需要把新增加存储方式添加到管理后台，方便配置和管理。在管理后台前端代码位置：src\views\datacenter\configuration\components\UploadConfig.vue添加代码：

在js代码中handleChangeType函数条件腾讯云的数据配置，代码如下

    //切换上传方式
    const handleChangeType=(value:any)=>{
      if(value=="local"){
        formData.value=Object.assign({},formData.value,{BaseUrl:baseData.local.LBaseUrl,DirPath:baseData.local.LDirPath})
      }else if(value=="tencentcos"){
        formData.value=Object.assign({},formData.value,{BaseUrl:baseData.tencentcos.TBaseUrl,Endpoint:baseData.tencentcos.TEndpoint,
          KeyId:baseData.tencentcos.TKeyId,Secret:baseData.tencentcos.TSecret,BucketName:baseData.tencentcos.TBucketName,
          Region:baseData.tencentcos.TRegion,DirPath:baseData.tencentcos.TDirPath})
      }else if(value=="alioss"){
        formData.value=Object.assign({},formData.value,{BaseUrl:baseData.alioss.ABaseUrl,Endpoint:baseData.alioss.AEndpoint,
          KeyId:baseData.alioss.AKeyId,Secret:baseData.alioss.ASecret,BucketName:baseData.alioss.ABucketName,
          DirPath:baseData.alioss.ADirPath})
      }else if(value=="qiniuoss"){
        formData.value=Object.assign({},formData.value,{BaseUrl:baseData.qiniuoss.QBaseUrl,Endpoint:baseData.qiniuoss.QEndpoint,
          KeyId:baseData.qiniuoss.QKeyId,Secret:baseData.qiniuoss.QSecret,BucketName:baseData.qiniuoss.QBucketName,
        DestBucketName:baseData.qiniuoss.QDestBucketName,UseHTTPS:baseData.qiniuoss.QUseHTTPS,Zone:baseData.qiniuoss.QZone,
        DirPath:baseData.qiniuoss.QDirPath})
      }
      console.log(formData.value)
    }

到此我们就把扩展新存储介绍完了，大家可以通过本文介绍了解，Gin集成的GoFly框架文件存储使用和继续扩展新存储方式的方法。

Gin框架集成腾讯云COS对象存储、本地存储等多种文件存储方式方便开发时快速调用和使用多种方式之间切换，本文介绍如何使用及集成思路

Go语言web框架gin集成腾讯云COS对象存储、本地存储等多种文件存储方式，方便项目开发切换和配置，统一上传和删除等管理接口

后端

开发工具

云计算

GoFly框架v3.01版本集成多文件存储方式，支持本地、阿里云、腾讯云等存储切换，提供统一API调用接口。开发时只需配置参数即可实现文件上传、删除等操作，无需修改业务代码。框架已封装好各端上传接口，支持快速扩展新存储方式，提升开发效率。

云服务器

文件存储

存储管理

软件开发

云存储

服务器

Unix

对象存储COS新用户低至1元！


11.11畅享AI算力 云启新增长

域名特惠新用户低至1元！


domain

4核4G3M云服务器 新用户低至38元/年！

文章

问答

视频

学习中心

腾讯云实验室

直播

竞赛

腾讯云代码分析专区

腾讯iOA零信任安全管理系统专区

腾讯云架构师技术同盟交流圈

腾讯云数据库专区

腾讯云顾问专区

腾讯云原生专区

腾讯混元专区

腾讯云TCE专区

腾讯云Lighthouse专区

腾讯云HAI专区

腾讯云Edgeone专区

腾讯云存储专区

腾讯云智能专区

腾讯轻联专区 

腾讯云开发专区

TAPD专区

腾讯轻量云游戏服专区

腾讯云最具价值专家

腾讯云架构师技术同盟

腾讯云创作之星

腾讯云开发者先锋

腾讯云代码助手

云原生构建

TAPD 敏捷项目管理

Cloud Studio

SDK中心

API中心

命令行工具

涵盖代码开发、场景应用、自动测试全流程，助你从零构建专属AI助手

一站式MCP教程库，解锁AI应用新玩法

聚焦“写作效率、视觉美观与运行性能”三方面进行全面升级，为您提供更高效、稳定的创作环境

Gin框架集成腾讯云COS对象存储、本地存储等多种文件存储方式方便开发时快速调用和使用多种方式之间切换，本文介绍如何使用及集成思路

Gin框架集成腾讯云COS对象存储、本地存储等多种文件存储方式方便开发时快速调用和使用多种方式之间切换，本文介绍如何使用及集成思路

社区

活动

圈层

关于

腾讯云开发者

热门产品

热门推荐

更多推荐