ghttp.Server
提供了事件回调注册功能,类似于其他框架的中间件功能,相比较于中间件,事件回调的特性更加简单。
ghttp.Server
支持用户对于某一事件进行自定义监听处理,按照pattern
方式进行绑定注册(pattern
格式与路由注册一致)。支持多个方法对同一事件进行监听,ghttp.Server
将会按照路由优先级及回调注册顺序进行回调方法调用。同一事件时先注册的HOOK
回调函数优先级越高。 相关方法如下:
func (s *Server) BindHookHandler(pattern string, hook string, handler HandlerFunc) error
func (s *Server) BindHookHandlerByMap(pattern string, hookmap map[string]HandlerFunc) error
当然域名对象也支持事件回调注册:
func (d *Domain) BindHookHandler(pattern string, hook string, handler HandlerFunc) error
func (d *Domain) BindHookHandlerByMap(pattern string, hookmap map[string]HandlerFunc) error
支持的Hook
事件列表:
ghttp.HookBeforeServe
在进入/初始化服务对象之前,该事件是最常用的事件,特别是针对于权限控制、跨域请求等处理。
ghttp.HookAfterServe
在完成服务执行流程之后。
ghttp.HookBeforeOutput
向客户端输出返回内容之前。
ghttp.HookAfterOutput
向客户端输出返回内容之后。
具体调用时机请参考图例所示。
由于事件的绑定也是使用的路由规则,因此它的优先级和 路由管理-路由规则 章节介绍的优先级是一样的。
但是事件调用时和路由注册调用时的机制不一样,同一个路由规则下允许绑定多个事件回调方法,该路由下的事件调用会按照优先级进行调用,假如优先级相等的路由规则,将会按照事件注册的顺序进行调用。
我们往往使用绑定/*
这样的HOOK
路由来实现全局的回调处理,这样是可以的。但是HOOK
执行的优先是最低的,路由注册的越精确,优先级越高,越模糊的路由优先级越低,/*
就属于最模糊的路由。
为降低不同的模块耦合性,所有的路由往往不是在同一个地方进行注册。例如用户模块注册的HOOK
(/user/*
),它将会被优先调用随后才可能是全局的HOOK
;如果仅仅依靠注册顺序来控制优先级,在模块多路由多的时候优先级便很难管理。
建议 相同的业务(同一业务模块) 的多个处理函数(例如: A、B、C)放到同一个HOOK回调函数中进行处理,在注册的回调函数中自行管理业务处理函数的调用顺序(函数调用顺序: A-B-C)。
虽然同样的需求,注册多个相同HOOK
的回调函数也可以实现,功能上不会有问题,但从设计的角度来讲,内聚性降低了,不便于业务函数管理。
当路由匹配到多个HOOK
方法时,默认是按照路由匹配优先级顺序执行HOOK
方法。当在HOOK
方法中调用Request.ExitHook
方法后,后续的HOOK
方法将不会被继续执行,作用类似HOOK
方法覆盖。
事件回调注册比较常见的应用是在对调用的接口进行鉴权控制/权限控制。该操作需要绑定ghttp.HookBeforeServe
事件,在该事件中会对所有匹配的接口请求(例如绑定/*
事件回调路由)服务执行前进行回调处理。当鉴权不通过时,需要调用r.ExitAll()
方法退出后续的服务执行(包括后续的事件回调执行)。
此外,在权限校验的事件回调函数中执行r.Redirect*
方法,又没有调用r.ExitAll()
方法退出业务执行,往往会产生http multiple response writeheader calls
错误提示。因为r.Redirect*
方法会往返回的header
中写入Location
头;而随后的业务服务接口往往会往header
写入Content-Type/Content-Length
头,这两者有冲突造成的。
中间件(Middleware
)与事件回调(HOOK
)是GF
框架的两大流程控制特性,两者都可用于控制请求流程,并且也都支持绑定特定的路由规则。但两者区别也是非常明显的。
Server
级别,并可处理静态文件的请求回调。
Request.Router
是匹配到的路由对象,包含路由注册信息,一般来说开发者不会用到。 Request.URL
是底层请求的URL
对象(继承自标准库http.Request
),包含请求的URL
地址信息,特别是Request.URL.Path
表示请求的URI
地址。
因此,假如在服务回调函数中使用的话,Request.Router
是有值的,因为只有匹配到了路由才会调用服务回调方法。但是在事件回调函数中,该对象可能为nil
(表示没有匹配到服务回调函数路由)。特别是在使用事件回调对请求接口鉴权的时候,应当使用Request.URL
对象获取请求的URL
信息,而不是Request.Router
。
如果仅仅是提供API
接口服务(包括前置静态文件服务代理如nginx
),不涉及到静态文件服务,那么可以忽略该小节。
需要注意的是,事件回调同样能够匹配到符合路由规则的静态文件访问(静态文件特性在gf
框架中是默认开启的,我们可以使用WebServer
相关配置来手动关闭。
例如,我们注册了一个/*
的全局匹配事件回调路由,那么/static/js/index.js
或者/upload/images/thumb.jpg
等等静态文件访问也会被匹配到,会进入到注册的事件回调函数中进行处理。
我们可以在事件回调函数中使用Request.IsFileRequest()
方法来判断该请求是否是静态文件请求,如果业务逻辑不需要静态文件的请求事件回调,那么在事件回调函数中直接忽略即可,以便进行选择性地处理。
package main
import (
"github.com/gogf/gf/v2/frame/g"
"github.com/gogf/gf/v2/net/ghttp"
"github.com/gogf/gf/v2/os/glog"
)
func main() {
// 基本事件回调使用
p := "/:name/info/{uid}"
s := g.Server()
s.BindHookHandlerByMap(p, map[string]ghttp.HandlerFunc{
ghttp.HookBeforeServe: func(r *ghttp.Request) { glog.Println(ghttp.HookBeforeServe) },
ghttp.HookAfterServe: func(r *ghttp.Request) { glog.Println(ghttp.HookAfterServe) },
ghttp.HookBeforeOutput: func(r *ghttp.Request) { glog.Println(ghttp.HookBeforeOutput) },
ghttp.HookAfterOutput: func(r *ghttp.Request) { glog.Println(ghttp.HookAfterOutput) },
})
s.BindHandler(p, func(r *ghttp.Request) {
r.Response.Write("用户:", r.Get("name"), ", uid:", r.Get("uid"))
})
s.SetPort(8199)
s.Run()
}
当访问 http://127.0.0.1:8199/john/info/10000 时,运行WebServer
进程的终端将会按照事件的执行流程打印出对应的事件名称。
package main
import (
"github.com/gogf/gf/v2/frame/g"
"github.com/gogf/gf/v2/net/ghttp"
)
// 优先调用的HOOK
func beforeServeHook1(r *ghttp.Request) {
r.SetParam("name", "GoFrame")
r.Response.Writeln("set name")
}
// 随后调用的HOOK
func 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.Get("name"))
r.Response.Writeln(r.Get("site"))
})
s.BindHookHandler("/", ghttp.HookBeforeServe, beforeServeHook1)
s.BindHookHandler("/", ghttp.HookBeforeServe, beforeServeHook2)
s.SetPort(8199)
s.Run()
}
执行后,终端输出的路由表信息如下:
SERVER | ADDRESS | DOMAIN | METHOD | P | ROUTE | HANDLER | MIDDLEWARE
|---------|---------|---------|--------|---|-------|-----------------------|-------------------|
default | :8199 | default | ALL | 1 | / | main.main.func1 |
|---------|---------|---------|--------|---|-------|-----------------------|-------------------|
default | :8199 | default | ALL | 2 | / | main.beforeServeHook1 | HOOK_BEFORE_SERVE
|---------|---------|---------|--------|---|-------|-----------------------|-------------------|
default | :8199 | default | ALL | 1 | / | main.beforeServeHook2 | HOOK_BEFORE_SERVE
|---------|---------|---------|--------|---|-------|-----------------------|-------------------|
手动访问 http://127.0.0.1:8199/ 后,页面输出内容为:
set name
set site
GoFrame
https://goframe.org
package main
import (
"fmt"
"github.com/gogf/gf/v2/frame/g"
"github.com/gogf/gf/v2/net/ghttp"
)
func main() {
s := g.Server()
// 多事件回调示例,事件1
pattern1 := "/:name/info"
s.BindHookHandlerByMap(pattern1, map[string]ghttp.HandlerFunc{
ghttp.HookBeforeServe: func(r *ghttp.Request) {
r.SetParam("uid", 1000)
},
})
s.BindHandler(pattern1, func(r *ghttp.Request) {
r.Response.Write("用户:", r.Get("name"), ", uid:", r.Get("uid"))
})
// 多事件回调示例,事件2
pattern2 := "/{object}/list/{page}.java"
s.BindHookHandlerByMap(pattern2, map[string]ghttp.HandlerFunc{
ghttp.HookBeforeOutput: func(r *ghttp.Request) {
r.Response.SetBuffer([]byte(
fmt.Sprintf("通过事件修改输出内容, object:%s, page:%s", r.Get("object"), r.GetRouterString("page"))),
)
},
})
s.BindHandler(pattern2, func(r *ghttp.Request) {
r.Response.Write(r.Router.Uri)
})
s.SetPort(8199)
s.Run()
}
通过事件1设置了访问/:name/info
路由规则时的GET
参数;通过事件2,改变了当访问的路径匹配路由/{object}/list/{page}.java
时的输出结果。执行之后,访问以下URL
查看效果:
package main
import (
"github.com/gogf/gf/v2/frame/g"
"github.com/gogf/gf/v2/net/ghttp"
)
func main() {
s := g.Server()
s.BindHandler("/priority/show", func(r *ghttp.Request) {
r.Response.Writeln("priority service")
})
s.BindHookHandlerByMap("/priority/:name", map[string]ghttp.HandlerFunc{
ghttp.HookBeforeServe: func(r *ghttp.Request) {
r.Response.Writeln("/priority/:name")
},
})
s.BindHookHandlerByMap("/priority/*any", map[string]ghttp.HandlerFunc{
ghttp.HookBeforeServe: func(r *ghttp.Request) {
r.Response.Writeln("/priority/*any")
},
})
s.BindHookHandlerByMap("/priority/show", map[string]ghttp.HandlerFunc{
ghttp.HookBeforeServe: func(r *ghttp.Request) {
r.Response.Writeln("/priority/show")
},
})
s.SetPort(8199)
s.Run()
}
在这个示例中,我们往注册了3个路由规则的事件回调,并且都能够匹配到路由注册的地址/priority/show
,这样我们便可以通过访问这个地址来看看路由执行的顺序是怎么样的。
执行后我们访问 http://127.0.0.1:8199/priority/show ,随后我们看到页面输出以下信息:
/priority/show
/priority/:name
/priority/*any
priority service
HOOK
和中间件都能实现跨域请求处理,我们这里使用HOOK
来实现简单的跨域处理。 首先我们来看一个简单的接口示例:
package main
import (
"github.com/gogf/gf/v2/frame/g"
"github.com/gogf/gf/v2/net/ghttp"
)
func Order(r *ghttp.Request) {
r.Response.Write("GET")
}
func main() {
s := g.Server()
s.Group("/api.v1", func(group *ghttp.RouterGroup) {
group.GET("/order", Order)
})
s.SetPort(8199)
s.Run()
}
接口地址是 http://localhost:8199/api.v1/order ,当然这个接口是不允许跨域的。我们打开一个不同的域名,例如:百度首页(正好用了jQuery
,方便调试),然后按F12
打开开发者面板,在console
下执行以下AJAX
请求:
$.get("http://localhost:8199/api.v1/order", function(result){
console.log(result)
});
结果如下:
返回了不允许跨域的错误,接着我们修改一下测试代码,如下:
package main
import (
"github.com/gogf/gf/v2/frame/g"
"github.com/gogf/gf/v2/net/ghttp"
)
func Order(r *ghttp.Request) {
r.Response.Write("GET")
}
func main() {
s := g.Server()
s.Group("/api.v1", func(group *ghttp.RouterGroup) {
group.Hook("/*any", ghttp.HookBeforeServe, func(r *ghttp.Request) {
r.Response.CORSDefault()
})
group.GET("/order", Order)
})
s.SetPort(8199)
s.Run()
}
我们增加了针对于路由/api.v1/*any
的绑定事件ghttp.HookBeforeServe
,该事件将会在所有服务执行之前调用,该事件的回调方法中,我们通过调用CORSDefault
方法使用默认的跨域设置允许跨域请求。该绑定的事件路由规则使用了模糊匹配规则,表示所有/api.v1
开头的接口地址都允许跨域请求。
返回刚才的百度首页,再次执行请求AJAX
请求,这次便成功了:
当在中间件或 handler 中启动新的 Goroutine 时,不能使用原始的上下文,必须使用只读副本。package mainimport ("github.com/gi...
tornado.netutil.bind_sockets(port:int,address:Optional[str]=None,family:socket.AddressFamily=AddressFamily.AF_UNSPEC:0,b...
用于处理Future对象的实用程序。Tornado之前提供了自己的Future类,但现在使用asyncio.Future。此模块包含用于与Tornado...
自定义后台表单通过 admin.site.register(Question) 注册 Question 模型,Django 能够构建一个默认的表单用于展示。通常...
Java Swing教程 -Java Swing JFormattedTextFieldJFormattedTextField是一个具有格式化功能的JTextField。我们可以指定编辑和显...
设置项目的选定状态。JCheckBoxMenuItem类表示从菜单栏部署的下拉菜单组件。类声明以下是javax.swing.JCheckBoxMenuItem类的声明...
摘要: 原创出处 www.bysocket.com 「泥瓦匠BYSocket 」欢迎转载,保留摘要,谢谢!『仓廪实而知礼节,衣食足而知荣辱 –管仲 』...
摘要: 原创出处 www.bysocket.com 「泥瓦匠BYSocket 」欢迎转载,保留摘要,谢谢!『 公司的核心竞争力在于创新 – 《启示录》 ...
MyBatis-Plus 条件构造器-AbstractWrappernotExists(String notExistsSql)notExists(boolean condition, String notExistsSql)拼...