Gin接收数据

接收参数

获取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()
}