validator库参数校验若干实用技巧

1. 表单的基本验证

若要将请求主体绑定到结构体中,请使用模型绑定,目前支持JSON、XML、YAML和标准表单值(foo=bar&boo=baz)的绑定。
Gin使用 go-playground/validator 验证参数,查看完整文档

需要在绑定的字段上设置tag,比如,绑定格式为json,需要这样设置 json:"fieldname"
此外,Gin还提供了两套绑定方法:

  • Must bind
    • Methods - Bind, BindJSON, BindXML, BindQuery, BindYAML
    • Behavior - 这些方法底层使用 MustBindWith,如果存在绑定错误,请求将被以下指令中止 c.AbortWithError(400, err).SetType(ErrorTypeBind),响应状态代码会被设置为400,请求头Content-Type被设置为text/plain; charset=utf-8。注意,如果你试图在此之后设置响应代码,将会发出一个警告 [GIN-debug] [WARNING] Headers were already written. Wanted to override status code 400 with 422,如果你希望更好地控制行为,请使用ShouldBind相关的方法
  • Should bind
    • Methods - ShouldBind, ShouldBindJSON, ShouldBindXML, ShouldBindQuery, ShouldBindYAML
    • Behavior - 这些方法底层使用 ShouldBindWith,如果存在绑定错误,则返回错误,开发人员可以正确处理请求和错误。

当我们使用绑定方法时,Gin会根据Content-Type推断出使用哪种绑定器,如果你确定你绑定的是什么,你可以使用MustBindWith或者BindingWith
你还可以给字段指定特定规则的修饰符,如果一个字段用binding:"required"修饰,并且在绑定时该字段的值为空,那么将返回一个错误。

  1. // 绑定为json
  2. type Login struct {
  3. User string `form:"user" json:"user" xml:"user" binding:"required"`
  4. Password string `form:"password" json:"password" xml:"password" binding:"required"`
  5. }
  6. type SignUpParam struct {
  7. Age uint8 `json:"age" binding:"gte=1,lte=130"`
  8. Name string `json:"name" binding:"required"`
  9. Email string `json:"email" binding:"required,email"`
  10. Password string `json:"password" binding:"required"`
  11. RePassword string `json:"re_password" binding:"required,eqfield=Password"`
  12. }
  13. func main() {
  14. router := gin.Default()
  15. // Example for binding JSON ({"user": "manu", "password": "123"})
  16. router.POST("/loginJSON", func(c *gin.Context) {
  17. var json Login
  18. if err := c.ShouldBindJSON(&json); err != nil {
  19. c.JSON(http.StatusBadRequest, gin.H{"error": err.Error()})
  20. return
  21. }
  22. if json.User != "manu" || json.Password != "123" {
  23. c.JSON(http.StatusUnauthorized, gin.H{"status": "unauthorized"})
  24. return
  25. }
  26. c.JSON(http.StatusOK, gin.H{"status": "you are logged in"})
  27. })
  28. // Example for binding a HTML form (user=manu&password=123)
  29. router.POST("/loginForm", func(c *gin.Context) {
  30. var form Login
  31. // This will infer what binder to use depending on the content-type header.
  32. if err := c.ShouldBind(&form); err != nil {
  33. c.JSON(http.StatusBadRequest, gin.H{"error": err.Error()})
  34. return
  35. }
  36. if form.User != "manu" || form.Password != "123" {
  37. c.JSON(http.StatusUnauthorized, gin.H{"status": "unauthorized"})
  38. return
  39. }
  40. c.JSON(http.StatusOK, gin.H{"status": "you are logged in"})
  41. })
  42. r.POST("/signup", func(c *gin.Context) {
  43. var u SignUpParam
  44. if err := c.ShouldBind(&u); err != nil {
  45. c.JSON(http.StatusOK, gin.H{
  46. "msg": err.Error(),
  47. })
  48. return
  49. }
  50. // 保存入库等业务逻辑代码...
  51. c.JSON(http.StatusOK, "success")
  52. })
  53. // Listen and serve on 0.0.0.0:8080
  54. router.Run(":8080")
  55. }

2. 错误翻译

  1. package main
  2. import (
  3. "fmt"
  4. "net/http"
  5. "github.com/gin-gonic/gin"
  6. "github.com/gin-gonic/gin/binding"
  7. "github.com/go-playground/locales/en"
  8. "github.com/go-playground/locales/zh"
  9. ut "github.com/go-playground/universal-translator"
  10. "github.com/go-playground/validator/v10"
  11. enTranslations "github.com/go-playground/validator/v10/translations/en"
  12. zhTranslations "github.com/go-playground/validator/v10/translations/zh"
  13. )
  14. // 定义一个全局翻译器T
  15. var trans ut.Translator
  16. // InitTrans 初始化翻译器
  17. func InitTrans(locale string) (err error) {
  18. // 修改gin框架中的Validator引擎属性,实现自定制
  19. if v, ok := binding.Validator.Engine().(*validator.Validate); ok {
  20. zhT := zh.New() // 中文翻译器
  21. enT := en.New() // 英文翻译器
  22. // 第一个参数是备用(fallback)的语言环境
  23. // 后面的参数是应该支持的语言环境(支持多个)
  24. // uni := ut.New(zhT, zhT) 也是可以的
  25. uni := ut.New(enT, zhT, enT)
  26. // locale 通常取决于 http 请求头的 'Accept-Language'
  27. var ok bool
  28. // 也可以使用 uni.FindTranslator(...) 传入多个locale进行查找
  29. trans, ok = uni.GetTranslator(locale)
  30. if !ok {
  31. return fmt.Errorf("uni.GetTranslator(%s) failed", locale)
  32. }
  33. // 注册翻译器
  34. switch locale {
  35. case "en":
  36. err = enTranslations.RegisterDefaultTranslations(v, trans)
  37. case "zh":
  38. err = zhTranslations.RegisterDefaultTranslations(v, trans)
  39. default:
  40. err = enTranslations.RegisterDefaultTranslations(v, trans)
  41. }
  42. return
  43. }
  44. return
  45. }
  46. type SignUpParam struct {
  47. Age uint8 `json:"age" binding:"gte=1,lte=130"`
  48. Name string `json:"name" binding:"required"`
  49. Email string `json:"email" binding:"required,email"`
  50. Password string `json:"password" binding:"required"`
  51. RePassword string `json:"re_password" binding:"required,eqfield=Password"`
  52. }
  53. func main() {
  54. if err := InitTrans("zh"); err != nil {
  55. fmt.Printf("init trans failed, err:%v\n", err)
  56. return
  57. }
  58. r := gin.Default()
  59. r.POST("/signup", func(c *gin.Context) {
  60. var u SignUpParam
  61. if err := c.ShouldBind(&u); err != nil {
  62. // 获取validator.ValidationErrors类型的errors
  63. errs, ok := err.(validator.ValidationErrors)
  64. if !ok {
  65. // 非validator.ValidationErrors类型错误直接返回
  66. c.JSON(http.StatusOK, gin.H{
  67. "msg": err.Error(),
  68. })
  69. return
  70. }
  71. // validator.ValidationErrors类型错误则进行翻译
  72. c.JSON(http.StatusOK, gin.H{
  73. "msg":errs.Translate(trans),
  74. })
  75. return
  76. }
  77. // 保存入库等具体业务逻辑代码...
  78. c.JSON(http.StatusOK, "success")
  79. })
  80. _ = r.Run(":8999")
  81. }

3. 进一步改进校验方法

上面的错误提示看起来是可以了,但是还是差点意思,首先是错误提示中的字段并不是请求中使用的字段,例如:RePassword是我们后端定义的结构体中的字段名,而请求中使用的是re_password字段。如何是错误提示中的字段使用自定义的名称,例如jsontag指定的值呢?
只需要在初始化翻译器的时候像下面一样添加一个获取json tag的自定义方法即可。

  1. // InitTrans 初始化翻译器
  2. func InitTrans(locale string) (err error) {
  3. // 修改gin框架中的Validator引擎属性,实现自定制
  4. if v, ok := binding.Validator.Engine().(*validator.Validate); ok {
  5. // 注册一个获取json tag的自定义方法
  6. v.RegisterTagNameFunc(func(fld reflect.StructField) string {
  7. name := strings.SplitN(fld.Tag.Get("json"), ",", 2)[0]
  8. if name == "-" {
  9. return ""
  10. }
  11. return name
  12. })
  13. zhT := zh.New() // 中文翻译器
  14. enT := en.New() // 英文翻译器
  15. // 第一个参数是备用(fallback)的语言环境
  16. // 后面的参数是应该支持的语言环境(支持多个)
  17. // uni := ut.New(zhT, zhT) 也是可以的
  18. uni := ut.New(enT, zhT, enT)
  19. }

但是还是有点瑕疵,那就是最终的错误提示信息中心还是有我们后端定义的结构体名称——SignUpParam,这个名称其实是不需要随错误提示返回给前端的,前端并不需要这个值。我们需要想办法把它去掉。
定义一个去掉结构体名称前缀的自定义方法:

  1. func removeTopStruct(fields map[string]string) map[string]string {
  2. res := map[string]string{}
  3. for field, err := range fields {
  4. res[field[strings.Index(field, ".")+1:]] = err
  5. }
  6. return res
  7. }
  8. ...
  9. if err := c.ShouldBind(&u); err != nil {
  10. // 获取validator.ValidationErrors类型的errors
  11. errs, ok := err.(validator.ValidationErrors)
  12. if !ok {
  13. // 非validator.ValidationErrors类型错误直接返回
  14. c.JSON(http.StatusOK, gin.H{
  15. "msg": err.Error(),
  16. })
  17. return
  18. }
  19. // validator.ValidationErrors类型错误则进行翻译
  20. // 并使用removeTopStruct函数去除字段名中的结构体名称标识
  21. c.JSON(http.StatusOK, gin.H{
  22. "msg": removeTopStruct(errs.Translate(trans)),
  23. })
  24. return
  25. }