Go语言Web框架gwk介绍 (三)

OStack程序员社区-中国程序员成长平台 › 门户 › 编程› Go›Go教程

原作者: [db:作者] 来自: [db:来源] 收藏邀请

上一篇忘了ChanResult

ChanResult

可以用来模拟BigPipe，定义如下

type ChanResult struct {
    Wait        sync.WaitGroup
    Chan        chan string
    ContentType string
    Start       []byte
    End         []byte
    Timeout     time.Duration
}

ChanResult会先输出Start，然后读取Chan中的字符串输出到客户端，最后输出End。

还忘了Controller的事件。

如果Controller的每个Action执行前后需要执行一些相同的代码怎么办？这就需要用到ActionSubscriber接口:

type ActionSubscriber interface {
    OnActionExecuting(action *ActionContext)
    OnActionExecuted(action *ActionContext)
    OnException(action *ActionContext)
}

OnActionExecuting在具体的Action执行之前执行，OnActionExecuted在具体的Action执行之后执行，OnException在具体的Action执行出错后执行。

通过ActionSubscriber可以做权限验证，数据验证，记录日志，同一错误处理等等。

------

gwk的内部逻辑十分简单，它的核心对象是HttpServer，HttpContent, HttpProcessor。下面分别介绍。

HttpServer

前面的例子里已经演示了怎么用函数NewDefaultServer创建一个缺省配置的HttpServer实例，NewDefaultServer会调用函数ReadDefaultConfigFile来尝试读取默认的配置文件，如果./conf/web.conf存在，则解析这个配置文件，如果解析出错或者文件不存在则调用函数NewDefaultConfig获得缺省配置。

你也可以用NewHttpServer传入WebConfig参数创建HttpServer实例。

func NewHttpServer(config *WebConfig) (srv *HttpServer, err error)

WebConfig的定义在后面介绍。

创建好HttpServer后，调用它的Start方法来监听http请求，启动Web服务。如果你的代码运行在Google App Engine这样不需要监听端口的平台，可以调用Setup方法来初始化HttpServer。Start方法内部实际上是先调用Setup方法，再调用http.Server的ListenAndServe方法。

HttpServer内部会创建一个http.Server实例，可以通过InnerServer方法来获得这个http.Server。

HttpServer有一个Variables字段，如果你有什么整个HttpServer共享的全局变量，可以放在Variables中。

//server variables
Variables map[string]interface{}

HttpServer实现了http.Handler接口，ServeHTTP函数的内部流程是:

创建HttpContext
循环执行每一个HttpProcessor的Execute方法

我们先介绍HttpContext。

HttpContext

HttpContext是对当前http请求的封装，定义如下:

type HttpContext struct {
    Server *HttpServer
    Request *http.Request
    Resonse http.ResponseWriter
    Method string
    RequestPath string
    PhysicalPath string
    RouteData RouteData
    ViewData map[string]interface{}
    Result HttpResult
    Error error
    Flash map[string]interface{}
    Session Session
    SessionIsNew bool
}

Server: 当前的HttpServer
Request: http.Request
Resonse: http.ResponseWriter
Method: http请求的method，比如GET，PUT，DELETE，POST...
RequestPath: http请求url的path部分
PhysicalPath: 请求对应的物理文件，只有请求的是静态文件时，该字段才有值
RouteData: RequestPath解析后的路由参数
ViewData: 存放传递给View模板的数据
Result: 此次请求的HttpResult
Error: 此次请求中的Error
Flash: 可以存放临时变量，生命周期为此次请求
Session: Session
SessionIsNew: Session是否此次在请求创建

HttpContext还定义了若干方法简化一些常见的操作:

RouteValue，读取RouteData里的数据

func (ctx *HttpContext) RouteValue(name string) (string, bool)

FormValue，调用http.Request的FormValue，FV也是相同的逻辑

func (ctx *HttpContext) FV(name string) string 
func (ctx *HttpContext) FormValue(name string) string

另外还有FormInt，FormIntOr，FormBool，FormBoolOr，FormFloat，FormFloatOr，前面已经做过介绍。

ReqHeader，读取Http request header的数据

func (ctx *HttpContext) ReqHeader(name string) string

SetHeader，设置Http resonse header的数据

func (ctx *HttpContext) SetHeader(key string, value string)

AddHeader，向http response header添加数据

func (ctx *HttpContext) AddHeader(key string, value string)

ContentType，设置http response header的"Content-Type"

func (ctx *HttpContext) ContentType(ctype string)

Status，设置返回http status code

func (ctx *HttpContext) Status(code int)

Accept，读取http request header的"Accept"

func (ctx *HttpContext) Accept() string

Write，调用http response的Write方法

func (ctx *HttpContext) Write(b []byte) (int, error)

Expires，设置http response header的"Expires"

func (ctx *HttpContext) Expires(t string)

SetCookie，设置cookie

func (ctx *HttpContext) SetCookie(cookie *http.Cookie)

Cookie，读取Cookie

func (ctx *HttpContext) Cookie(name string) (*http.Cookie, error)

SessionId，返回SessionId，只有启用了Session才有效

func (ctx *HttpContext) SessionId() string

GetFlash，读取Flash中的变量

func (ctx *HttpContext) GetFlash(key string) (v interface{}, ok bool)

SetFlash，设置Flash中的变量

func (ctx *HttpContext) SetFlash(key string, v interface{})

ReadBody，读取整个http request的内容

func (ctx *HttpContext) ReadBody() ([]byte, error)

Flush，Flush当前Response中的数据到客户端

func (ctx *HttpContext) Flush() {

前面介绍的ChanResult就是调用Flush把内容输出到客户端，代码基本逻辑如下:

ctx.Write(c.Start)
ctx.Flush()

if c.Timeout < time.Millisecond {
    c.Timeout = defaultChanResultTimeout
}

waitchan := make(chan bool)
donechan := make(chan bool)

go func() {
    for s := range c.Chan {
        ctx.Write([]byte(s))
        ctx.Flush()
    }
    donechan <- true
}()

go func() {
    c.Wait.Wait()
    close(c.Chan)
    waitchan <- true
}()

select {
case <-waitchan:
case <-time.After(c.Timeout):
}

<-donechan
ctx.Write(c.End)

HttpProcessor

HttpProcessor的定义如下

type HttpProcessor interface {
    Execute(ctx *HttpContext)
    Register(server *HttpServer)
}

Execute负责处理http请求，Register会在HttpServer初始化时调用一次，如果你的HttpProcessor需要执行一些初始化代码，可以放在Register方法中。

调用RegisterProcessor可以注册一个HttpProcessor

func RegisterProcessor(name string, p HttpProcessor)

注册的HttpProcessor存在ProcessTable类型的全局变量中

type ProcessTable []*Process

type Process struct {
    Name string
    Path string
    Method string 
    Handler HttpProcessor
}

如果一个Processor需要特定的条件才执行，可以设置它的Path和Method字段，Method是要匹配的http method，既GET、PUT、POST、DELETE...，"*"或者""匹配所有的http method，Path是要匹配的Request Path，目前版本是前缀匹配，以后可能改成支持通配符。

HttpServer启动时，默认注册三个HttpProcessor：StaticProcessor、RouteProcessor、RenderProcessor。

StaticProcessor

StaticProcessor负责处理静态文件，如果请求的路径能匹配到物理文件，则将HttpContext的的Result设置为FileResult。

StaticProcessor支持缓存静态文件以及自定义http response header。缓存静态文件在缓存一节详细介绍，自定义输出的http header是指为每个静态文件的Response设置你定义的http header，比如统一为静态文件设置Cache-Control。下面是配置的例子：

#static processor config
static_processor: {

    cache_enable:   true
    cache_expire:   3600

    header: {
        Cache-Control:  max-age=43200
        X-Title:        gwk-demo
    }
}
# -->end static processor

RouteProcessor

RouteProcessor负责按照你定义的路由规则调用具体的处理代码，逻辑很简单，只有几十行代码。

RenderProcessor

RenderProcessor负责执行HttpResult的Execute，也只有几十行代码。HttpResult没有赋值的话则返回404错误。

自定义HttpProcessor

你可以增删HttpProcessor或者调整顺序来改变默认的处理逻辑，比如你的程序是一个web api服务，不需要处理静态文件，则可以去掉RouteProcessor。ProcessTable定义了Append、InsertBefore、InsertAfter、Remove方法来简化对HttpProcessor的调整。

http gzip压缩

CompressProcessor可以对http输出做gzip压缩，需要注册到RenderProcessor之前才有效，其本质是用compressResponseWriter来代替默认的ResponseWriter。

type CompressProcessor struct {
    Enable   bool
    Level    int
    MimeType string
}

type compressResponseWriter struct {
    rw            http.ResponseWriter
    writer        compresser
    contentType   string
    format        string
    headerWritten bool
}

CompressProcessor设计时考虑能够按照MimeType或者RequestPath来过滤需要压缩的内容，但一直没实现，因为访问量小流量小的网站开不开启gzip压缩意义不大，访问量大的网站一般会用一些http反向代理或者http缓存的服务，自己没必要处理gzip压缩。

通过自定义HttpProcessor，你可以为全网站做统一的权限验证，访问限制，日志处理，错误处理等等。

除了HttpProcessor，你还可以通过gwk的事件机制来实现这些逻辑。