- 请求输入
Request.URL与Request.RouterExit,ExitAll与ExitHook
- 使用示例
- 示例1,请求数据校验
- 请求参数绑定+数据校验示例
- 示例2,流程共享变量
- 示例1,请求数据校验
请求输入
请求输入依靠 ghttp.Request 对象实现,ghttp.Request继承了底层的http.Request对象,并且包含了会话相关的Cookie和Session对象(每个请求都会有两个独立的Cookie和Session对象)。此外,每个请求有一个唯一的Id(请求Id,全局唯一),用以标识每一个请求。此外,成员对象包含一个与当前请求对应的返回输出对象指针Response,用于数据的返回。
相关方法:https://godoc.org/github.com/gogf/gf/g/net/ghttp
type Requestfunc (r *Request) AddPost(key string, value string)func (r *Request) AddQuery(key string, value string)func (r *Request) AddRouterString(key, value string)func (r *Request) BasicAuth(user, pass string, tips ...string) boolfunc (r *Request) IsAjaxRequest() boolfunc (r *Request) IsExited() boolfunc (r *Request) IsFileRequest() boolfunc (r *Request) SetPost(key string, value string)func (r *Request) SetQuery(key string, value string)func (r *Request) SetRouterString(key, value string)func (r *Request) WebSocket() (*WebSocket, error)func (r *Request) Exit()func (r *Request) ExitAll()func (r *Request) ExitHook()func (r *Request) SetParam(key string, value interface{})func (r *Request) GetParam(key string) gvar.VarReadfunc (r *Request) Get(key string, def ...string) stringfunc (r *Request) GetVar(key string, def ...interface{}) gvar.VarReadfunc (r *Request) GetArray(key string, def ...[]string) []stringfunc (r *Request) GetClientIp() stringfunc (r *Request) GetFloat32(key string, def ...float32) float32func (r *Request) GetFloat64(key string, def ...float64) float64func (r *Request) GetFloats(key string, def ...[]float64) []float64func (r *Request) GetHost() stringfunc (r *Request) GetInt(key string, def ...int) intfunc (r *Request) GetInterfaces(key string, def ...[]interface{}) []interface{}func (r *Request) GetInts(key string, def ...[]int) []intfunc (r *Request) GetJson() *gjson.Jsonfunc (r *Request) GetMap(def ...map[string]string) map[string]stringfunc (r *Request) GetRaw() []bytefunc (r *Request) GetReferer() stringfunc (r *Request) GetString(key string, def ...string) stringfunc (r *Request) GetStrings(key string, def ...[]string) []stringfunc (r *Request) GetToStruct(object interface{}, mapping ...map[string]string)func (r *Request) GetUint(key string, def ...uint) uintfunc (r *Request) GetPost(key string, def ...[]string) []stringfunc (r *Request) GetPostArray(key string, def ...[]string) []stringfunc (r *Request) GetPostBool(key string, def ...bool) boolfunc (r *Request) GetPostFloat32(key string, def ...float32) float32func (r *Request) GetPostFloat64(key string, def ...float64) float64func (r *Request) GetPostFloats(key string, def ...[]float64) []float64func (r *Request) GetPostInt(key string, def ...int) intfunc (r *Request) GetPostInterfaces(key string, def ...[]interface{}) []interface{}func (r *Request) GetPostInts(key string, def ...[]int) []intfunc (r *Request) GetPostMap(def ...map[string]string) map[string]stringfunc (r *Request) GetPostString(key string, def ...string) stringfunc (r *Request) GetPostStrings(key string, def ...[]string) []stringfunc (r *Request) GetPostToStruct(object interface{}, mapping ...map[string]string)func (r *Request) GetPostUint(key string, def ...uint) uintfunc (r *Request) GetQuery(key string, def ...[]string) []stringfunc (r *Request) GetQueryArray(key string, def ...[]string) []stringfunc (r *Request) GetQueryBool(key string, def ...bool) boolfunc (r *Request) GetQueryFloat32(key string, def ...float32) float32func (r *Request) GetQueryFloat64(key string, def ...float64) float64func (r *Request) GetQueryFloats(key string, def ...[]float64) []float64func (r *Request) GetQueryInt(key string, def ...int) intfunc (r *Request) GetQueryInterfaces(key string, def ...[]interface{}) []interface{}func (r *Request) GetQueryInts(key string, def ...[]int) []intfunc (r *Request) GetQueryMap(def ...map[string]string) map[string]stringfunc (r *Request) GetQueryString(key string, def ...string) stringfunc (r *Request) GetQueryStrings(key string, def ...[]string) []stringfunc (r *Request) GetQueryToStruct(object interface{}, mapping ...map[string]string)func (r *Request) GetQueryUint(key string, def ...uint) uintfunc (r *Request) GetRequest(key string, def ...[]string) []stringfunc (r *Request) GetRequestArray(key string, def ...[]string) []stringfunc (r *Request) GetRequestBool(key string, def ...bool) boolfunc (r *Request) GetRequestFloat32(key string, def ...float32) float32func (r *Request) GetRequestFloat64(key string, def ...float64) float64func (r *Request) GetRequestFloats(key string, def ...[]float64) []float64func (r *Request) GetRequestInt(key string, def ...int) intfunc (r *Request) GetRequestInterfaces(key string, def ...[]interface{}) []interface{}func (r *Request) GetRequestInts(key string, def ...[]int) []intfunc (r *Request) GetRequestMap(def ...map[string]string) map[string]stringfunc (r *Request) GetRequestString(key string, def ...string) stringfunc (r *Request) GetRequestStrings(key string, def ...[]string) []stringfunc (r *Request) GetRequestToStruct(object interface{}, mapping ...map[string]string)func (r *Request) GetRequestUint(key string, def ...uint) uintfunc (r *Request) GetRequestVar(key string, def ...interface{}) *gvar.Varfunc (r *Request) GetRouterArray(key string) []stringfunc (r *Request) GetRouterString(key string) string
以上方法可以分为以下几类:
Get*: 常用方法,简化参数获取,GetRequest*的别名;GetQuery*: 获取GET方式传递过来的Key-Value查询参数;GetPost*: 获取POST方式传递过来的Key-Value表单参数;GetRequest*: 优先查找Router路由参数中是否有指定键名的参数,如果没有则查找GET参数,如果没有则查找POST参数,如果都不存在则返回空或者默认值;GetRaw: 获取客户端提交的原始数据(二进制[]byte类型),与HTTP Method无关,例如客户端提交JSON/XML数据格式时可以通过该方法获取原始的提交数据;GetJson: 自动将原始请求信息解析为gjson.Json对象指针返回,gjson.Json对象指针具体在【gjson模块】章节中介绍;GetToStruct: 将请求参数绑定到指定的struct对象上,注意给定的参数为对象指针;SetParam/GetParam: 用于设置/获取请求流程中得共享变量,该共享变量只在该请求流程中有效,请求结束则销毁;Exit*: 用于请求流程退出控制,详见本章后续说明;
其中,获取的参数方法可以对指定键名的数据进行自动类型转换,例如:http://127.0.0.1:8199/?amount=19.66,通过Get/GetQueryString将会返回19.66的字符串类型,GetQueryFloat32/GetQueryFloat64将会分别返回float32和float64类型的数值19.66。但是,GetQueryInt/GetQueryUint将会返回19(如果参数为float类型的字符串,将会按照向下取整进行整型转换)。
Request.URL与Request.Router
Request.Router是匹配到的路由对象,包含路由注册信息,一般来说开发者不会用得到。Request.URL是底层请求的URL对象(继承自标准库http.Request),包含请求的URL地址信息,特别是Request.URL.Path表示请求的URI地址。
因此,假如在服务回调函数中使用的话,Request.Router是有值的,因为只有匹配到了路由才会调用服务回调方法。但是在事件回调函数中,该对象可能为nil(表示没有匹配到服务回调函数路由)。特别是在使用事件回调对请求接口鉴权的时候,应当使用Request.URL对象获取请求的URL信息,而不是Request.Router。
Exit, ExitAll与ExitHook
Exit: 仅退出当前执行的逻辑方法,如: 当前HOOK方法、服务方法,不退出后续的逻辑处理,可用于替代return;ExitAll: 强行退出当前执行流程,当前执行方法的后续逻辑以及后续所有的逻辑方法将不再执行,常用于权限控制;ExitHook: 当路由匹配到多个HOOK方法时,默认是按照路由匹配优先级顺序执行HOOK方法。当在HOOK方法中调用ExitHook方法后,后续的HOOK方法将不会被继续执行,作用类似HOOK方法覆盖;
使用示例
示例1,请求数据校验
请求参数绑定+数据校验示例
https://github.com/gogf/gf/blob/master/geg/net/ghttp/server/request/request_validation.go
package mainimport ("github.com/gogf/gf/g""github.com/gogf/gf/g/net/ghttp""github.com/gogf/gf/g/util/gvalid")func main() {type User struct {Uid int `gvalid:"uid@min:1"`Name string `params:"username" gvalid:"username @required|length:6,30"`Pass1 string `params:"password1" gvalid:"password1@required|password3"`Pass2 string `params:"password2" gvalid:"password2@required|password3|same:password1#||两次密码不一致,请重新输入"`}s := g.Server()s.BindHandler("/user", func(r *ghttp.Request){user := new(User)r.GetToStruct(user)if err := gvalid.CheckStruct(user, nil); err != nil {r.Response.WriteJson(err.Maps())} else {r.Response.Write("ok")}})s.SetPort(8199)s.Run()}
从
v1.8.0开始,参数标签支持params/param/p三种标签。
其中,
- 这里使用了
r.GetToStruct(user)方法将请求参数绑定到指定的user对象上,注意这里的user是User的结构体实例化指针;在struct tag中,使用params标签来指定参数名称与结构体属性名称对应关系; GetToStruct方法支持自动对结构体对象初始化,注意此时参数类型为**User,如下:user := (*User)(nil)r.GetToStruct(&user)
- 通过
gvalid标签为gavlid数据校验包特定的校验规则标签,具体请参考【数据校验】章节;其中,密码字段的校验规则为password3,表示:密码格式为任意6-18位的可见字符,必须包含大小写字母、数字和特殊字符; - 当校验染回结果非
nil时,表示校验不通过,这里使用r.Response.WriteJson方法返回json结果;
执行后,试着访问URL: http://127.0.0.1:8199/user?uid=1&name=john&password1=123&password2=456,输出结果为:
{"password1":{"password3":"密码格式不合法,密码格式为任意6-18位的可见字符,必须包含大小写字母、数字和特殊字符"},"password2":{"password3":"密码格式不合法,密码格式为任意6-18位的可见字符,必须包含大小写字母、数字和特殊字符","same":"两次密码不一致,请重新输入"},"username":{"length":"字段长度为6到30个字符"}}
假如我们访问访问URL: http://127.0.0.1:8199/user?uid=1&name=johng-cn&password1=John$123&password2=John$123,输出结果为:
ok
示例2,流程共享变量
package mainimport ("github.com/gogf/gf/g""github.com/gogf/gf/g/net/ghttp")// 优先调用的HOOKfunc beforeServeHook1(r *ghttp.Request) {r.SetParam("name", "GoFrame")r.Response.Writeln("set name")}// 随后调用的HOOKfunc beforeServeHook2(r *ghttp.Request) {r.SetParam("site", "https://goframe.org")r.Response.Writeln("set site")}// 允许对同一个路由同一个事件注册多个回调函数,按照注册顺序进行优先级调用。// 为便于在路由表中对比查看优先级,这里讲HOOK回调函数单独定义为了两个函数。func main() {s := g.Server()s.BindHandler("/", func(r *ghttp.Request) {r.Response.Writeln(r.GetParam("name").String())r.Response.Writeln(r.GetParam("site").String())})s.BindHookHandler("/", ghttp.HOOK_BEFORE_SERVE, beforeServeHook1)s.BindHookHandler("/", ghttp.HOOK_BEFORE_SERVE, beforeServeHook2)s.SetPort(8199)s.Run()}
执行后,访问 http://127.0.0.1:8199/ 后,页面输出内容为:
set nameset siteGoFramehttps://goframe.org
