05封装

在对 context 的封装中&＃xff0c;我们只是将 request、response 结构直接放入 context 结构体中&＃xff0c;对应的方法并没有很好的封装。

函数封装并不是一件很简单、很随意的事情。相反&＃xff0c;如何封装出易用、可读性高的函数是非常需要精心考量的&＃xff0c;框架中每个函数的参数、返回值、命名&＃xff0c;都代表着我们作为作者在某个事情上的思考。想要针对某个功能&＃xff0c;封装出一系列比较完美的接口&＃xff0c;更要我们从系统性的角度思考。

我们的目标是尽量在 context 这个数据结构中&＃xff0c;封装“读取请求数据”和“封装返回数据”中的方法。

读取请求数据

头部&＃xff1a;业务无关、传输相关的信息&＃xff0c;如请求地址、编码格式、缓存时长
body&＃xff1a;与业务相关的信息

Header 信息中&＃xff0c;包含 HTTP 的一些基础信息&＃xff0c;比如请求地址、请求方法、请求 IP、请求域名、COOKIE 信息等&＃xff0c;是经常读取使用的&＃xff0c;为了方便&＃xff0c;我们需要一一提供封装。

而另外一些更细节的内容编码格式、缓存时长等&＃xff0c;由于涉及的 HTTP 协议细节内容比较多&＃xff0c;我们很难将每个细节都封装出来&＃xff0c;但是它们都是以 key&＃61;value 的形式传递到服务端的&＃xff0c;所以这里也考虑封装一个通用的方法。

Body 信息中&＃xff0c;HTTP 是已经以某种形式封装好的&＃xff0c;可能是 JSON 格式、XML 格式&＃xff0c;也有可能是 Form 表单格式。其中 Form 表单注意一下&＃xff0c;它可能包含 File 文件&＃xff0c;请求参数和返回值肯定和其他的 Form 表单字段是不一样的&＃xff0c;需要我们对其单独封装一个函数。

封装返回数据

Header 头部&＃xff0c;我们经常要设置的是返回状态码和 COOKIE&＃xff0c;所以单独为其封装。其他的 Header 同样是 key&＃61;value 形式设置的&＃xff0c;设置一个通用的方法即可。

返回数据的 Body 体是有不同形式的&＃xff0c;比如 JSON、JSONP、XML、HTML 或者其他文本格式&＃xff0c;所以我们要针对不同的 Body 体形式&＃xff0c;进行不同的封装。

对于比较完整的功能模块&＃xff0c;先定义接口&＃xff0c;再具体实现&＃xff0c;这样好处是实现解耦、开发清晰。

定义两个接口&＃xff0c;IRequest 和 IResponse&＃xff0c;分别对应“读取请求数据”和“封装返回数据” 这两个功能模块。


// 代表请求包含的方法
type IRequest interface {// 请求地址 url 中带的参数// 形如: foo.com?a&＃61;1&b&＃61;bar&c[]&＃61;barQueryInt(key string, def int) (int, bool)QueryInt64(key string, def int64) (int64, bool)QueryFloat64(key string, def float64) (float64, bool)QueryFloat32(key string, def float32) (float32, bool)QueryBool(key string, def bool) (bool, bool)QueryString(key string, def string) (string, bool)QueryStringSlice(key string, def []string) ([]string, bool)Query(key string) interface{}// 路由匹配中带的参数// 形如 /book/:idParamInt(key string, def int) (int, bool)ParamInt64(key string, def int64) (int64, bool)ParamFloat64(key string, def float64) (float64, bool)ParamFloat32(key string, def float32) (float32, bool)ParamBool(key string, def bool) (bool, bool)ParamString(key string, def string) (string, bool)Param(key string) interface{}// form 表单中带的参数FormInt(key string, def int) (int, bool)FormInt64(key string, def int64) (int64, bool)FormFloat64(key string, def float64) (float64, bool)FormFloat32(key string, def float32) (float32, bool)FormBool(key string, def bool) (bool, bool)FormString(key string, def string) (string, bool)FormStringSlice(key string, def []string) ([]string, bool)FormFile(key string) (*multipart.FileHeader, error)Form(key string) interface{}// json bodyBindJson(obj interface{}) error// xml bodyBindXml(obj interface{}) error// 其他格式GetRawData() ([]byte, error)// 基础信息Uri() stringMethod() stringHost() stringClientIp() string// headerHeaders() map[string][]stringHeader(key string) (string, bool)// COOKIECOOKIEs() map[string]stringCOOKIE(key string) (string, bool)
}

QueryXXX表示从URL后缀中获取参数&＃xff0c;ParamXXX表示从路由匹配获取参数&＃xff0c;FormXXX表示从Body的form表单获取参数。
这三类方法统一了参数与返回值&＃xff1a;

• 参数&＃xff1a; key和默认值
• 返回值&＃xff1a;匹配值和bool

具体实现

• Query请求


// 获取请求地址中所有参数
func (ctx *Context) QueryAll() map[string][]string {if ctx.request !&＃61; nil {return map[string][]string(ctx.request.URL.Query())}return map[string][]string{}
}// 获取 Int 类型的请求参数
func (ctx *Context) QueryInt(key string, def int) (int, bool) {params :&＃61; ctx.QueryAll()if vals, ok :&＃61; params[key]; ok {if len(vals) > 0 {// 使用 cast 库将 string 转换为 Intreturn cast.ToInt(vals[0]), true}}return def, false
}


• Param 请求
  找到路由节点后&＃xff0c;根据uri的分段&＃xff0c;网上寻找父节点&＃xff0c;找到其中的参数&＃xff0c;并存储到ctx中。


// 将 uri 解析为 params
func (n *node) parseParamsFromEndNode(uri string) map[string]string {ret :&＃61; map[string]string{}segments :&＃61; strings.Split(uri, "/")cnt :&＃61; len(segments)cur :&＃61; nfor i :&＃61; cnt - 1; i >&＃61; 0; i-- {if cur.segment &＃61;&＃61; "" {break}// 如果是通配符节点if isWildSegment(cur.segment) {// 设置 paramsret[cur.segment[1:]] &＃61; segments[i]}cur &＃61; cur.parent}return ret
}// 所有请求都进入这个函数, 这个函数负责路由分发
func (c *Core) ServeHTTP(response http.ResponseWriter, request *http.Request) {// 封装自定义 contextctx :&＃61; NewContext(request, response)// 寻找路由node :&＃61; c.FindRouteNodeByRequest(request)...// 设置路由参数params :&＃61; node.parseParamsFromEndNode(request.URL.Path)ctx.SetParams(params)...
}// 获取路由参数
func (ctx *Context) Param(key string) interface{} {if ctx.params !&＃61; nil {if val, ok :&＃61; ctx.params[key]; ok {return val}}return nil
}// 路由匹配中带的参数
// 形如 /book/:id
func (ctx *Context) ParamInt(key string, def int) (int, bool) {if val :&＃61; ctx.Param(key); val !&＃61; nil {// 通过 cast 进行类型转换return cast.ToInt(val), true}return def, false
}


• Bind 请求


// 将 body 文本解析到 obj 结构体中
func (ctx *Context) BindJson(obj interface{}) error {if ctx.request !&＃61; nil {// 读取文本body, err :&＃61; ioutil.ReadAll(ctx.request.Body)if err !&＃61; nil {return err}// 重新填充 request.Body&＃xff0c;为后续的逻辑二次读取做准备ctx.request.Body &＃61; ioutil.NopCloser(bytes.NewBuffer(body))// 解析到 obj 结构体中err &＃61; json.Unmarshal(body, obj)if err !&＃61; nil {return err}} else {return errors.New("ctx.request empty")}return nil
}
IResponse 接口定义

type IResponse interface {// 将obj对象转成json并发送出去&＃xff1f;Json(obj interface{}) IResponseJsonp(obj interface{}) IResponseXml(obj interface{}) IResponseHtml(template string, obj interface{}) IResponseText(format string, values ...interface{}) IResponseRedirect(path string) IResponseSetHeader(key string, val string)SetCOOKIE(key string, val string, maxAge int, path, domin string, secure, httpOnly bool) IResponseSetStatus(code int) IResponseSetOkStatus() IResponse}


对于 Header 部分&＃xff0c;我们设计了状态码的设置函数 SetStatus/SetOkStatus/Redirect&＃xff0c;还设计了 COOKIE 的设置函数 SetCOOKIE&＃xff0c;同时&＃xff0c;我们提供了通用的设置 Header 的函数 SetHeader。

对于 Body 部分&＃xff0c;我们设计了 JSON、JSONP、XML、HTML、Text 等方法来输出不同格式的 Body。

这里注意下&＃xff0c;很多方法的返回值使用 IResponse 接口本身&＃xff0c; 这个设计能允许使用方进行链式调用。链式调用的好处是&＃xff0c;能很大提升代码的阅读性&＃xff0c;比如在业务逻辑代码 controller.go 里这个调用方法&＃xff1a;

c.SetOkStatus().Json("ok, UserLoginController: " &＃43; foo)


【小结】

1. 对请求和响应进行封装&＃xff0c;提供使用的便利性
2. 请求封装有获取参数&＃xff08;url路径后缀、动态参数、表单参数&＃xff09;、获取header
3. 返回封装有设置header、设备body