Go Gin 实现文件的上传下载流读取

文件上传

router

router.POST("/resources/common/upload", service.UploadResource)

service

type: POST

data:{ “saveDir”:“保存的路径”， “fileName”:“文件名称不带后缀” }// 上传文件func UploadResource(c *gin.Context) { saveDirParam := c.PostForm("saveDir") // 文件目录 fileNameParam := c.PostForm("fileName") // 文件名称 //目录 var saveDir = "" //名称 var saveName = "" //完整路径 var savePath = "" //获取文件 file, header, errFile := c.Request.FormFile("file") //处理获取文件错误 if errFile != nil || common.IsEmpty(header.Filename) { c.JSON(http.StatusOK, gin.H{ "success": false, "message": "请选择文件", "dir": saveDir, "name": saveName, "path": savePath, }) return } //目录请求参数为空 if common.IsEmpty(saveDirParam) { c.JSON(http.StatusOK, gin.H{ "success": false, "message": "请求参数错误！", "dir": saveDir, "name": saveName, "path": savePath, }) return } //如果上传的名称为空，则自动生成名称 if common.IsEmpty(fileNameParam) { fileNameParam = GenerateResourceNo() } //获取上传文件的后缀(类型) uploadFileNameWithSuffix := path.Base(header.Filename) uploadFileType := path.Ext(uploadFileNameWithSuffix) //文件保存目录 saveDir = "/attachment" + saveDirParam //保存的文件名称 saveName = fileNameParam + uploadFileType savePath = saveDir + "/" + saveName //打开目录 localFileInfo, fileStatErr := os.Stat(saveDir) //目录不存在 if fileStatErr != nil || !localFileInfo.IsDir() { //创建目录 errByMkdirAllDir := os.MkdirAll(saveDir, 0755) if errByMkdirAllDir != nil { logs.Error("%s mkdir error.....", saveDir, errByMkdirAllDir.Error()) c.JSON(http.StatusOK, gin.H{ "success": false, "dir": saveDir, "name": saveName, "path": savePath, "message": "创建目录失败", }) return } } ////上传文件前 先删除该资源之前上传过的资源文件 ////（编辑-重新选择文件-需要先删除该资源之前上传过的资源文件） ////该代码执行的条件----上传的名称是唯一的，否则会出现误删 ////获取文件的前缀 //fileNameOnly := fileNameParam //deleteFileWithName(fileNameOnly, saveDir) //deleteFileWithName(fileNameOnly, model.WebConfig.ResourcePath+"/"+ // model.WebConfig.WebConvertToPath) out, err := os.Create(savePath) if err != nil { logs.Error(err) } defer out.Close() _, err = io.Copy(out, file) if err != nil { c.JSON(http.StatusOK, gin.H{ "success": false, "dir": saveDir, "name": saveName, "path": savePath, "message": err.Error(), }) return } //没有错误的情况下 c.JSON(http.StatusOK, gin.H{ "success": true, "dir": saveDir, "name": saveName, "path": savePath, "message": "上传成功", }) return}

js提交例子：

注:需导入jquery.js 和 ajaxfileupload.js

//上传文件 $.ajaxFileUpload( { url: '/resources/common/upload', //用于文件上传的服务器端请求地址 secureuri: false, //是否需要安全协议，一般设置为false fileElementId: fileUploadDomId, //文件上传域的ID data: { "saveDir":fileSaveDir, "fileName":fileSaveName }, dataType: 'json', //返回值类型 一般设置为json contentType:'application/json',//提交的数据类型 async: false, success: function (data, status) //服务器成功响应处理函数 { if (data.success){ fileSaveName=fileSaveDir+"/"+data.name; console.log("上传成功，返回的文件的路径：",fileSaveName) }else{ console.log("上传失败，返回的文件的路径：",fileSaveName) return } }, error: function (data, status, e)//服务器响应失败处理函数 { console.log("e==",e); return } } );

文件的下载

router

Type:‘GET'

普通链接格式非restful风格

参数url:下载的文件的路径

• Jquery解码：decodeURIComponent(url);
• Jquery编码：encodeURIComponent(url);
  

例：http://127.0.0.0.1:8080//pub/common/download?url=“/attachment/demo.docx”

router.GET("/pub/common/download", service.PubResFileStreamGetService)

service

//下载次数func UserFileDownloadCommonService(c *gin.Context) { filePath := c.Query("url") //打开文件 fileTmp, errByOpenFile := os.Open(filePath) defer fileTmp.Close() //获取文件的名称 fileName:=path.Base(filePath) if common.IsEmpty(filePath) || common.IsEmpty(fileName) || errByOpenFile != nil { logs.Error("获取文件失败") c.Redirect(http.StatusFound, "/404") return } c.Header("Content-Type", "application/octet-stream") //强制浏览器下载 c.Header("Content-Disposition", "attachment; filename="+fileName) //浏览器下载或预览 c.Header("Content-Disposition", "inline;filename="+fileName) c.Header("Content-Transfer-Encoding", "binary") c.Header("Cache-Control", "no-cache") c.File(filePath) return}

文件流读取

router

Type:‘GET'

普通链接格式非restful风格

参数url:下载的文件的路径

• Jquery解码：decodeURIComponent(url);
• Jquery编码：encodeURIComponent(url);
  

例：http://127.0.0.0.1:8080//pub/common/file_stream?url=“/attachment/demo.docx”

router.GET("/pub/common/file_stream", service.PubResFileStreamGetService)

service

//map for Http Content-Type Http 文件类型对应的content-Typevar HttpContentType = map[string]string{ ".avi": "video/avi", ".mp3": " audio/mp3", ".mp4": "video/mp4", ".wmv": " video/x-ms-wmv", ".asf": "video/x-ms-asf", ".rm": "application/vnd.rn-realmedia", ".rmvb": "application/vnd.rn-realmedia-vbr", ".mov": "video/quicktime", ".m4v": "video/mp4", ".flv": "video/x-flv", ".jpg": "image/jpeg", ".png": "image/png",}//根据文件路径读取返回流文件 参数urlfunc PubResFileStreamGetService(c *gin.Context) {filePath := c.Query("url")//获取文件名称带后缀fileNameWithSuffix := path.Base(filePath)//获取文件的后缀fileType := path.Ext(fileNameWithSuffix)//获取文件类型对应的http ContentType 类型fileContentType := HttpContentType[fileType]if common.IsEmpty(fileContentType) { c.String(http.StatusNotFound, "file http contentType not found") return}c.Header("Content-Type", fileContentType)c.File(filePath)}

到此这篇关于Go Gin实现文件上传下载的示例代码的文章就介绍到这了,更多相关Go Gin 文件上传下载内容请搜索以前的文章或继续浏览下面的相关文章希望大家以后多多支持！