天天看點

Gin接收資料接收參數接受檔案2.接收多個檔案

接收參數

擷取querystring參數

querystring指的是URL中?後面攜帶的參數,例如:/user/search?username=小王子&address=沙河
           

擷取form參數

請求的資料通過form表單來送出,例如向/user/search發送一個POST請求
           

擷取path參數

請求的參數通過URL路徑傳遞,例如:/user/search/小王子/沙河
           

注:以上三種都有自己單獨擷取參數的方法,但不常用

gin架構提供了一種

參數綁定

的方法,能夠更友善的擷取請求相關參數,提高開發效率,我們可以基于請求的Content-Type識别請求資料類型并利用反射機制自動提取請求中QueryString、form表單、JSON、XML等參數到結構體中。 下面的示例代碼示範了.ShouldBind()強大的功能,它能夠基于請求自動提取JSON、form表單和QueryString類型的資料,并把值綁定到指定的結構體對象。

// Binding from JSON
type Login struct {
	User     string `form:"user" json:"user" binding:"required"`
	Password string `form:"password" json:"password" binding:"required"`
}

func main() {
	router := gin.Default()

	
	router.POST("/login", func(c *gin.Context) {
		var login Login
		if err := c.ShouldBind(&login); err == nil {
			c.JSON(http.StatusOK, gin.H{
				"user":     login.User,
				"password": login.Password,
			})
		} else {
			c.JSON(http.StatusBadRequest, gin.H{"error": err.Error()})
		}
	})
		// Listen and serve on 0.0.0.0:8080
	router.Run(":8080")
	}
           

ShouldBind會按照下面的順序解析請求中的資料完成綁定:

  1. 如果是 GET 請求,隻使用 Form 綁定引擎(query)。
  2. 如果是 POST 請求,首先檢查 content-type 是否為 JSON 或 XML,然後再使用 Form(form-data)。

接受檔案

1. 接收單個檔案

使用`ctx.FormFile方法,包含了儲存檔案示例

func main() {
	router := gin.Default()
	// 處理multipart forms送出檔案時預設的記憶體限制是32 MiB
	// 可以通過下面的方式修改
	// router.MaxMultipartMemory = 8 << 20  // 8 MiB
	router.POST("/upload", func(c *gin.Context) {
		// 單個檔案
		file, err := c.FormFile("f1")
		if err != nil {
			c.JSON(http.StatusInternalServerError, gin.H{
				"message": err.Error(),
			})
			return
		}

		log.Println(file.Filename)
		dst := fmt.Sprintf("C:/tmp/%s", file.Filename)
		// 上傳檔案到指定的目錄
		c.SaveUploadedFile(file, dst)
		c.JSON(http.StatusOK, gin.H{
			"message": fmt.Sprintf("'%s' uploaded!", file.Filename),
		})
	})
	router.Run()
}
           

or

使用

ctx.Request.FormFile

方法,包含了讀取檔案示例

func (ctrl *HotUpdateCtrl) hotAdd(ctx *gin.Context) {
	//接收上傳檔案
	file, header, err := ctx.Request.FormFile("hotpatchfile")
	if err != nil {
		restgo.ResultFailMsg(ctx, MsgErrUpFileInvalid)
	}

	filename := header.Filename
	logger.Infof("receive %s", filename)

	name := ctx.PostForm("name")
	defer rows.Close()

	if len(name) == 0 {
		restgo.ResultFailMsg(ctx, NameErrUpFileInvalid)
		return
	}

	rd := bufio.NewReader(file)
	buf := []byte{}
	for {
		line, err := rd.ReadBytes('\n')
		buf = append(buf, line...)
		if err == io.EOF {
			logger.Infof("%s檔案讀完", filename)
			break
		}
		if err != nil {
			restgo.ResultFailMsg(ctx, FileErrUpFileInvalid)
		}
	}
	sEnc := base64.StdEncoding.EncodeToString(buf)
	sql := "insert into ct_cmd_conf.hotpatch(Base64hotpatch,name) values(?,?)"
	_, err = util.DBPool().Exec(sql, sEnc, name)
	if err != nil {
		logger.Errorln(err, sql)
		restgo.ResultFail(ctx, ErrOpAddFail, MsgErrInternal)
		return
	}
	restgo.ResultOkMsg(ctx, nil, MsgSuccUpFile)

}
           

2.接收多個檔案

func main() {
	router := gin.Default()
	// 處理multipart forms送出檔案時預設的記憶體限制是32 MiB
	// 可以通過下面的方式修改
	// router.MaxMultipartMemory = 8 << 20  // 8 MiB
	router.POST("/upload", func(c *gin.Context) {
		// Multipart form
		form, _ := c.MultipartForm()
		files := form.File["file"]

		for index, file := range files {
			log.Println(file.Filename)
			dst := fmt.Sprintf("C:/tmp/%s_%d", file.Filename, index)
			// 上傳檔案到指定的目錄
			c.SaveUploadedFile(file, dst)
		}
		c.JSON(http.StatusOK, gin.H{
			"message": fmt.Sprintf("%d files uploaded!", len(files)),
		})
	})
	router.Run()
}