接收參數
擷取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會按照下面的順序解析請求中的資料完成綁定:
- 如果是 GET 請求,隻使用 Form 綁定引擎(query)。
- 如果是 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()
}