事件回调注册

事件回调 - 图1

ghttp.Server提供了事件回调注册功能，类似于其他框架的中间件功能，相比较于中间件，事件回调的特性更加简单。

ghttp.Server支持用户对于某一事件进行自定义监听处理，按照pattern方式进行绑定注册(pattern格式与路由注册一致)。支持多个方法对同一事件进行监听，ghttp.Server将会按照路由优先级及回调注册顺序进行回调方法调用。同一事件时先注册的HOOK回调函数优先级越高。 相关方法如下：

  1. func (s *Server) BindHookHandler(pattern string, hook string, handler HandlerFunc) error
  2. func (s *Server) BindHookHandlerByMap(pattern string, hookmap map[string]HandlerFunc) error

当然域名对象也支持事件回调注册：

  1. func (d *Domain) BindHookHandler(pattern string, hook string, handler HandlerFunc) error
  2. func (d *Domain) BindHookHandlerByMap(pattern string, hookmap map[string]HandlerFunc) error

支持的Hook事件列表：

  1. BeforeServe/ghttp.HOOK_BEFORE_SERVE

    在进入/初始化服务对象之前，该事件是最常用的事件，特别是针对于权限控制、跨域请求等处理。

  2. AfterServe/ghttp.HOOK_AFTER_SERVE

    在完成服务执行流程之后。

  3. BeforeOutput/ghttp.HOOK_BEFORE_OUTPUT

    向客户端输出返回内容之前。

  4. AfterOutput/ghttp.HOOK_AFTER_OUTPUT

    向客户端输出返回内容之后。

  5. BeforeClose/ghttp.HOOK_BEFORE_CLOSE

    （已废弃）在http请求关闭之前。

  6. AfterClose/ghttp.HOOK_AFTER_CLOSE

    （已废弃）在http请求关闭之后。

具体调用时机请参考图例所示。

HOOK_BEFORE_CLOSE及HOOK_AFTER_CLOSE事件在gf框架v1.6.0版本后被废弃。

事件优先级

由于事件的绑定也是使用的路由规则，因此它的优先级和【路由控制】章节介绍的优先级是一样的。

但是事件调用时和路由注册调用时的机制不一样，同一个路由规则下允许绑定多个事件回调方法，该路由下的事件调用会按照优先级进行调用，假如优先级相等的路由规则，将会按照事件注册的顺序进行调用。

关于全局回调

我们往往使用绑定/*这样的HOOK路由来实现全局的回调处理，这样是可以的。但是HOOK执行的优先是最低的，路由注册的越精确，优先级越高，越模糊的路由优先级越低，/*就属于最模糊的路由。

为降低不同的模块耦合性，所有的路由往往不是在同一个地方进行注册。例如用户模块注册的HOOK(/user/*)，它将会被优先调用随后才可能是全局的HOOK；如果仅仅依靠注册顺序来控制优先级，在模块多路由多的时候优先级便很难管理。

关于业务函数调用顺序

建议 相同的业务(同一业务模块) 的多个处理函数(例如: A、B、C)放到同一个HOOK回调函数中进行处理，在注册的回调函数中自行管理业务处理函数的调用顺序(函数调用顺序: A-B-C)。

虽然同样的需求，注册多个相同HOOK的回调函数也可以实现，功能上不会有问题，但从设计的角度来讲，内聚性降低了，不便于业务函数管理。

Request.ExitHook方法

当路由匹配到多个HOOK方法时，默认是按照路由匹配优先级顺序执行HOOK方法。当在HOOK方法中调用Request.ExitHook方法后，后续的HOOK方法将不会被继续执行，作用类似HOOK方法覆盖。

接口鉴权控制

事件回调注册比较常见的应用是在对调用的接口进行鉴权控制/权限控制。该操作需要绑定HOOK_BEFORE_SERVE事件，在该事件中会对所有匹配的接口请求(例如绑定/*事件回调路由)服务执行前进行回调处理。当鉴权不通过时，需要调用r.ExitAll()方法退出后续的服务执行(包括后续的事件回调执行)。

此外，在权限校验的事件回调函数中执行r.Redirect*方法，又没有调用r.ExitAll()方法退出业务执行，往往会产生http multiple response writeheader calls错误提示。因为r.Redirect*方法会往返回的header中写入Location头；而随后的业务服务接口往往会往header写入Content-Type/Content-Length头，这两者有冲突造成的。

Request.URL与Request.Router

Request.Router是匹配到的路由对象，包含路由注册信息，一般来说开发者不会用到。 Request.URL是底层请求的URL对象（继承自标准库http.Request），包含请求的URL地址信息，特别是Request.URL.Path表示请求的URI地址。

因此，假如在服务回调函数中使用的话，Request.Router是有值的，因为只有匹配到了路由才会调用服务回调方法。但是在事件回调函数中，该对象可能为nil（表示没有匹配到服务回调函数路由）。特别是在使用事件回调对请求接口鉴权的时候，应当使用Request.URL对象获取请求的URL信息，而不是Request.Router。

静态文件事件

如果仅仅是提供API接口服务（包括前置静态文件服务代理如nginx），不涉及到静态文件服务，那么可以忽略该小节。

需要注意的是，事件回调同样能够匹配到符合路由规则的静态文件访问（静态文件特性在gf框架中是默认开启的，我们可以使用WebServer相关配置来手动关闭，具体查看【Server配置管理】章节）。

例如，我们注册了一个/*的全局匹配事件回调路由，那么/static/js/index.js或者/upload/images/thumb.jpg等等静态文件访问也会被匹配到，会进入到注册的事件回调函数中进行处理。

我们可以在事件回调函数中使用Request.IsFileRequest()方法来判断该请求是否是静态文件请求，如果业务逻辑不需要静态文件的请求事件回调，那么在事件回调函数中直接忽略即可，以便进行选择性地处理。

示例1，基本使用

  1. package main
  3. import (
  4.     "github.com/gogf/gf/g"
  5.     "github.com/gogf/gf/g/os/glog"
  6.     "github.com/gogf/gf/g/net/ghttp"
  7. )
  9. func main() {
  10.     // 基本事件回调使用
  11.     p := "/:name/info/{uid}"
  12.     s := g.Server()
  13.     s.BindHookHandlerByMap(p, map[string]ghttp.HandlerFunc{
  14.         ghttp.HOOK_BEFORE_SERVE  : func(r *ghttp.Request){ glog.Println(ghttp.HOOK_BEFORE_SERVE) },
  15.         ghttp.HOOK_AFTER_SERVE   : func(r *ghttp.Request){ glog.Println(ghttp.HOOK_AFTER_SERVE) },
  16.         ghttp.HOOK_BEFORE_OUTPUT : func(r *ghttp.Request){ glog.Println(ghttp.HOOK_BEFORE_OUTPUT) },
  17.         ghttp.HOOK_AFTER_OUTPUT  : func(r *ghttp.Request){ glog.Println(ghttp.HOOK_AFTER_OUTPUT) },
  18.         ghttp.HOOK_BEFORE_CLOSE  : func(r *ghttp.Request){ glog.Println(ghttp.HOOK_BEFORE_CLOSE) },
  19.         ghttp.HOOK_AFTER_CLOSE   : func(r *ghttp.Request){ glog.Println(ghttp.HOOK_AFTER_CLOSE) },
  20.     })
  21.     s.BindHandler(p, func(r *ghttp.Request) {
  22.        r.Response.Write("用户:", r.Get("name"), ", uid:", r.Get("uid"))
  23.     })
  24.     s.SetPort(8199)
  25.     s.Run()
  26. }

当访问http://127.0.0.1:8199/john/info/10000时，运行Web Server进程的终端将会按照事件的执行流程打印出对应的事件名称。

示例2，相同事件注册

  1. package main
  3. import (
  4.     "github.com/gogf/gf/g"
  5.     "github.com/gogf/gf/g/net/ghttp"
  6. )
  8. // 优先调用的HOOK
  9. func beforeServeHook1(r *ghttp.Request) {
  10.     r.SetParam("name", "GoFrame")
  11.     r.Response.Writeln("set name")
  12. }
  14. // 随后调用的HOOK
  15. func beforeServeHook2(r *ghttp.Request) {
  16.     r.SetParam("site", "https://goframe.org")
  17.     r.Response.Writeln("set site")
  18. }
  20. // 允许对同一个路由同一个事件注册多个回调函数，按照注册顺序进行优先级调用。
  21. // 为便于在路由表中对比查看优先级，这里讲HOOK回调函数单独定义为了两个函数。
  22. func main() {
  23.     s := g.Server()
  24.     s.BindHandler("/", func(r *ghttp.Request) {
  25.         r.Response.Writeln(r.GetParam("name").String())
  26.         r.Response.Writeln(r.GetParam("site").String())
  27.     })
  28.     s.BindHookHandler("/", ghttp.HOOK_BEFORE_SERVE, beforeServeHook1)
  29.     s.BindHookHandler("/", ghttp.HOOK_BEFORE_SERVE, beforeServeHook2)
  30.     s.SetPort(8199)
  31.     s.Run()
  32. }

执行后，终端输出的路由表信息如下：

  1.   SERVER  | ADDRESS | DOMAIN  | METHOD | P | ROUTE |        HANDLER        |    HOOK      
  2. |---------|---------|---------|--------|---|-------|-----------------------|-------------|
  3.   default | :8199   | default | ALL    | 1 | /     | main.main.func1       |              
  4. |---------|---------|---------|--------|---|-------|-----------------------|-------------|
  5.   default | :8199   | default | ALL    | 2 | /     | main.beforeServeHook1 | BeforeServe  
  6. |---------|---------|---------|--------|---|-------|-----------------------|-------------|
  7.   default | :8199   | default | ALL    | 1 | /     | main.beforeServeHook2 | BeforeServe  
  8. |---------|---------|---------|--------|---|-------|-----------------------|-------------|

手动访问 http://127.0.0.1:8199/ 后，页面输出内容为：

  1. set name
  2. set site
  3. GoFrame
  4. https://goframe.org

示例3，改变业务逻辑

  1. package main
  3. import (
  4.     "fmt"
  5.     "github.com/gogf/gf/g"
  6.     "github.com/gogf/gf/g/net/ghttp"
  7. )
  9. func main() {
  10.     s := g.Server()
  12.     // 多事件回调示例，事件1
  13.     pattern1 := "/:name/info"
  14.     s.BindHookHandlerByMap(pattern1, map[string]ghttp.HandlerFunc {
  15.         "BeforeServe"  : func(r *ghttp.Request) {
  16.             r.SetQuery("uid", "1000")
  17.         },
  18.     })
  19.     s.BindHandler(pattern1, func(r *ghttp.Request) {
  20.         r.Response.Write("用户:", r.Get("name"), ", uid:", r.GetQueryString("uid"))
  21.     })
  23.     // 多事件回调示例，事件2
  24.     pattern2 := "/{object}/list/{page}.java"
  25.     s.BindHookHandlerByMap(pattern2, map[string]ghttp.HandlerFunc {
  26.         "BeforeOutput" : func(r *ghttp.Request){
  27.             r.Response.SetBuffer([]byte(
  28.                 fmt.Sprintf("通过事件修改输出内容, object:%s, page:%s", r.Get("object"), r.GetRouterString("page"))),
  29.             )
  30.         },
  31.     })
  32.     s.BindHandler(pattern2, func(r *ghttp.Request) {
  33.         r.Response.Write(r.Router.Uri)
  34.     })
  35.     s.SetPort(8199)
  36.     s.Run()
  37. }

通过事件1设置了访问/:name/info路由规则时的GET参数；通过事件2，改变了当访问的路径匹配路由/{object}/list/{page}.java时的输出结果。

示例4，事件回调注册优先级

  1. package main
  3. import (
  4.     "github.com/gogf/gf/g"
  5.     "github.com/gogf/gf/g/net/ghttp"
  6.     "github.com/gogf/gf/g/os/glog"
  7. )
  9. func main() {
  10.     s := g.Server()
  11.     s.BindHandler("/priority/show", func(r *ghttp.Request) {
  12.         r.Response.Write("priority test")
  13.     })
  15.     s.BindHookHandlerByMap("/priority/:name", map[string]ghttp.HandlerFunc {
  16.         "BeforeServe"  : func(r *ghttp.Request) {
  17.             glog.Println(r.Router.Uri)
  18.         },
  19.     })
  20.     s.BindHookHandlerByMap("/priority/*any", map[string]ghttp.HandlerFunc {
  21.         "BeforeServe"  : func(r *ghttp.Request) {
  22.             glog.Println(r.Router.Uri)
  23.         },
  24.     })
  25.     s.BindHookHandlerByMap("/priority/show", map[string]ghttp.HandlerFunc {
  26.         "BeforeServe"  : func(r *ghttp.Request) {
  27.             glog.Println(r.Router.Uri)
  28.         },
  29.     })
  30.     s.SetPort(8199)
  31.     s.Run()
  32. }

在这个示例中，我们往注册了3个路由规则的事件回调，并且都匹配路由注册的地址/priority/show，这样我们便可以通过访问这个地址来看看路由执行的顺序是怎么样的。

执行后我们访问http://127.0.0.1:8199/priority/show，随后我们可以在服务端的终端上看到以下输出信息：

  1. 2018-08-03 15:16:25.971 27391: http server started listening on [:8199]
  2. 2018-08-03 15:16:28.385 /priority/show
  3. 2018-08-03 15:16:28.385 /priority/:name
  4. 2018-08-03 15:16:28.385 /priority/*any

示例5，使用事件回调允许跨域请求

首先我们来看一个简单的REST接口示例：

  1. package main
  3. import (
  4.     "github.com/gogf/gf/g"
  5.     "github.com/gogf/gf/g/frame/gmvc"
  6.     "github.com/gogf/gf/g/net/ghttp"
  7. )
  9. type Order struct {
  10.     gmvc.Controller
  11. }
  13. func (o *Order) Get() {
  14.     o.Response.Write("GET")
  15. }
  17. func main() {
  18.     s := g.Server()
  19.     s.BindControllerRest("/api.v1/{.struct}", new(Order))
  20.     s.SetPort(8199)
  21.     s.Run()
  22. }

接口地址是http://localhost/api.v1/order，当然这个接口是不允许跨域的。我们打开一个不同的域名，例如：百度首页(正好用了jQuery，方便调试)，然后按F12打开开发者面板，在console下执行以下AJAX请求：

  1. $.get("http://localhost:8199/api.v1/order", function(result){
  2.     console.log(result)
  3. });

结果如下： 事件回调 - 图2 返回了不允许跨域的错误，接着我们修改一下测试代码，如下：

  1. package main
  3. import (
  4.     "github.com/gogf/gf/g"
  5.     "github.com/gogf/gf/g/frame/gmvc"
  6.     "github.com/gogf/gf/g/net/ghttp"
  7. )
  9. type Order struct {
  10.     gmvc.Controller
  11. }
  13. func (o *Order) Get() {
  14.     o.Response.Write("GET")
  15. }
  17. func main() {
  18.     s := g.Server()
  19.     s.BindHookHandlerByMap("/api.v1/*any", map[string]ghttp.HandlerFunc {
  20.        "BeforeServe"  : func(r *ghttp.Request) {
  21.            r.Response.CORSDefault()
  22.        },
  23.     })
  24.     s.BindControllerRest("/api.v1/{.struct}", new(Order))
  25.     s.SetPort(8199)
  26.     s.Run()
  27. }

我们增加了针对于路由/api.v1/*any的绑定事件BeforeServe，该事件将会在所有服务执行之前调用，该事件的回调方法中，我们通过调用CORSDefault方法使用默认的跨域设置允许跨域请求。该绑定的事件路由规则使用了模糊匹配规则，表示所有/api.v1开头的接口地址都允许跨域请求。

返回刚才的百度首页，再次执行请求AJAX请求，这次便成功了： 事件回调 - 图3