rver
创建⼀个http服务，⼤致需要经历两个过程，⾸先需要注册路由，即提供url模式和handler函数的映射，其次就是实例化⼀个rver对象，并开启对客户端的监听。
再看gohttp服务的代码
托福报名网址
http.HandleFunc("/", indexHandler)
即是注册路由。
http.ListenAndServe("127.0.0.1:8000", nil)
或者：
rver := &Server{Addr: addr, Handler: handler}
rver.ListenAndServe()
注册路由
阅读框架源码是学习的好⽅式，通常阅读也有两个⽅法，⼀是不求甚解，框架的主要流程要清晰，别的细枝末节，如果尚不能理解作者的⽤意，可以先忽略，不必马上深究；其次，庖丁解⽜，对于作者想要表达的主要由。美国留学专业选择
lookingnet/http包暴露的注册路由的api很简单，http.HandleFunc选取了DefaultServeMux作为multiplexer：
func HandleFunc(pattern string, handler func(ResponWriter, *Request)) {
DefaultServeMux.HandleFunc(pattern, handler)
}
那么什么是DefaultServeMux呢？实际上，DefaultServeMux是ServeMux的⼀个实例。当然http包也提供了NewServeMux⽅法创建⼀个ServeMux实例，默认则创建⼀个DefaultServeMux：
// NewServeMux allocates and returns a new ServeMux.
func NewServeMux() *ServeMux { return new(ServeMux) }
pssp// DefaultServeMux is the default ServeMux ud by Serve.
var DefaultServeMux = &defaultServeMux
var defaultServeMux ServeMux
注意，go创建实例的过程中，也可以使⽤指针⽅式，即
type Server struct{}
rver := Server{}
和下⾯的⼀样都可以创建Server的实例
var DefalutServer Server
var rver = &DefalutServer
因此DefaultServeMux的HandleFunc(pattern, handler)⽅法实际是定义在ServeMux下的：
func (mux *ServeMux) HandleFunc(pattern string, handler func(ResponWriter, *Request)) {
mux.Handle(pattern, HandlerFunc(handler))
}
上述代码中，HandlerFunc是⼀个函数类型。同时实现了Handler接⼝的ServeHTTP⽅法。使⽤HandlerFunc类型包装⼀下路由定义的indexHandler函数，其⽬的就是为了让这个函数也实现ServeHTTP⽅法，即转变成⼀个handler处理器(函数)。
type HandlerFunc func(ResponWriter, *Request)
func (f HandlerFunc) ServeHTTP(w ResponWriter, r *Request) {
f(w, r)
}
⼀旦这样做了，就意味着我们的 indexHandler 函数也有了ServeHTTP⽅法。
此外，ServeMux的Handle⽅法，将会对pattern和handler函数做⼀个map映射：
func (mux *ServeMux) Handle(pattern string, handler Handler) {
mux.mu.Lock()
defer mux.mu.Unlock()
if pattern == "" {
panic("http: invalid pattern " + pattern)
}
if handler == nil {
panic("http: nil handler")
}
if mux.m[pattern].explicit {
panic("http: multiple registrations for " + pattern)
}
if mux.m == nil {
ctg
mux.m = make(map[string]muxEntry)
}
mux.m[pattern] = muxEntry{explicit: true, h: handler, pattern: pattern}
if pattern[0] != '/' {
mux.hosts = true
}
n := len(pattern)
if n > 0 && pattern[n-1] == '/' && !mux.m[pattern[0:n-1]].explicit {
path := pattern
if pattern[0] != '/' {
path = pattern[strings.Index(pattern, "/"):]
}
url := &url.URL{Path: path}
mux.m[pattern[0:n-1]] = muxEntry{h: RedirectHandler(url.String(), StatusMovedPermanently), pattern: pattern}
英文书名怎么写}
}
由此可见，Handle函数的主要⽬的在于把handler和pattern模式绑定到map[string]muxEntry的map上，其中muxEntry保存了更多pattern和handler的信息，还记得前⾯讨论的Server结构吗？Server的m字段就是map[string]muxEntry这样⼀个map。
此时，pattern和handler的路由注册完成。接下来就是如何开始rver的监听，以接收客户端的请求。
#### 开启监听
注册好路由之后，启动web服务还需要开启服务器监听。http的ListenAndServer⽅法中可以看到创建了⼀个Server对象，并调⽤了Server对象的同名⽅法：
func ListenAndServe(addr string, handler Handler) error {
gacrver := &Server{Addr: addr, Handler: handler}
return rver.ListenAndServe()
return rver.ListenAndServe()
}
func (srv Server) ListenAndServe() error {
addr := srv.Addr
if addr == "" {
addr = ":http"
}
ln, err := net.Listen("tcp", addr)
if err != nil {
return err
}
return srv.Serve(tcpKeepAliveListener{ln.(net.TCPListener)})
}
Server的ListenAndServe⽅法中，会初始化监听地址Addr，同时调⽤Listen⽅法设置监听。最后将监听的TCP对象传⼊Serve⽅法：
func (srv *Server) Serve(l net.Listener) error {
defer l.Clo()
...
baCtx := context.Background()
ctx := context.WithValue(baCtx, ServerContextKey, srv)
ctx = context.WithValue(ctx, LocalAddrContextKey, l.Addr())
for {
rw, e := l.Accept()
...
c := wConn(rw)
c.tState(c.rwc, StateNew) // before Serve can return
go c.rve(ctx)
}
}
#### 处理请求
监听开启之后，⼀旦客户端请求到底，go就开启⼀个协程处理请求，主要逻辑都在rve⽅法之中。
rve⽅法⽐较长，其主要职能就是，创建⼀个上下⽂对象，然后调⽤Listener的Accept⽅法⽤来 获取连接数据并使⽤newConn⽅法创建连接对象。最后使⽤goroutein协程的⽅式处理连接请求。因为每⼀个连接都开起了⼀个协程，请求的上下⽂都不同，同时⼜保证func (c *conn) rve(ctx context.Context) {
defer func() {
if err := recover(); err != nil {
const size = 64 << 10
buf := make([]byte, size)
buf = buf[:runtime.Stack(buf, fal)]
c.rver.logf("http: panic rving %v: %v\n%s", c.remoteAddr, err, buf)
}
if !c.hijacked() {
c.clo()
c.tState(c.rwc, StateClod)
}
}()
...
for {
w, err := c.readRequest(ctx)
ain != c.rver.initialReadLimitSize() {
// If we read any bytes off the wire, we're active.
放松的英文c.tState(c.rwc, StateActive)
}
...
}
...
rverHandler{c.rver}.ServeHTTP(w, w.req)
w.cancelCtx()
林业大学排名if c.hijacked() {
return
}
w.finishRequest()
if !w.shouldReuConnection() {
questBodyLimitHit || w.clodRequestBodyEarly() {
c.cloWriteAndWait()
}
return
}
c.tState(c.rwc, StateIdle)
}
}
尽管rve很长，⾥⾯的结构和逻辑还是很清晰的，使⽤defer定义了函数退出时，连接关闭相关的处理。然后就是读取连接的⽹络数据，并处理读取完毕时候的状态。接下来就是调⽤`rverHandler{c.rver}.ServeHTTP(w, w.req)`⽅法处理请求了。最后就是请求处理type rverHandler struct {
srv *Server
}
func (sh rverHandler) ServeHTTP(rw ResponWriter, req Request) {
handler := sh.srv.Handler
if handler == nil {
handler = DefaultServeMux
}
if req.RequestURI == "" && req.Method == "OPTIONS" {
handler = globalOptionsHandler{}
}
handler.ServeHTTP(rw, req)
}
这⾥DefaultServeMux的ServeHTTP⽅法其实也是定义在ServeMux结构中的，相关代码如下：
func (mux *ServeMux) (w ResponWriter, r Request) {
func (mux *ServeMux) (w ResponWriter, r Request) {
if r.RequestURI == "" {
if r.ProtoAtLeast(1, 1) {
w.Header().Set("Connection", "clo")
}
w.WriteHeader(StatusBadRequest)
return
}
h, _ := mux.Handler(r)
h.ServeHTTP(w, r)
}
func (mux *ServeMux) Handler(r *Request) (h Handler, pattern string) {
if r.Method != "CONNECT" {
if p := cleanPath(r.URL.Path); p != r.URL.Path {
_, pattern = mux.handler(r.Host, p)
url := *r.URL
url.Path = p
return RedirectHandler(url.String(), StatusMovedPermanently), pattern
}
}
return mux.handler(r.Host, r.URL.Path)
}
func (mux *ServeMux) handler(host, path string) (h Handler, pattern string) {
mux.mu.RLock()
defer mux.mu.RUnlock()
// Host-specific pattern takes precedence over generic ones
if mux.hosts {
h, pattern = mux.match(host + path)
}
if h == nil {
h, pattern = mux.match(path)
}
if h == nil {
h, pattern = NotFoundHandler(), ""
}
return
}
func (mux *ServeMux) match(path string) (h Handler, pattern string) {
var n = 0
for k, v := range mux.m {
if !pathMatch(k, path) {
continue
}
if h == nil || len(k) > n {
n = len(k)
h = v.h
pattern = v.pattern
}
}
return
}
mux的ServeHTTP⽅法通过调⽤其Handler⽅法寻找注册到路由上的handler函数，并调⽤该函数的ServeHTTP⽅法，本例则是IndexHandler函数。一线英语
mux的Handler⽅法对URL简单的处理，然后调⽤handler⽅法，后者会创建⼀个锁，同时调⽤match⽅法返回⼀个handler和pattern。
在match⽅法中，mux的m字段是map[string]muxEntry图，后者存储了pattern和handler处理器函数，因此通过迭代m寻找出注册路由的patten模式与实际url匹配的handler函数并返回。
返回的结构⼀直传递到mux的ServeHTTP⽅法，接下来调⽤handler函数的ServeHTTP⽅法，即IndexHandler函数，然后把respon写到http.RequestWirter对象返回给客户端。
上述函数运⾏结束即`rverHandler{c.rver}.ServeHTTP(w, w.req)`运⾏结束。接下来就是对请求处理完毕之后上希望和连接断开的相关逻辑。
⾄此，Golang中⼀个完整的http服务介绍完毕，包括注册路由，开启监听，处理连接，路由处理函数。
### 总结
多数的web应⽤基于HTTP协议，客户端和服务器通过request-respon的⽅式交互。⼀个rver并不可少的两部分莫过于路由注册和连接处理。Golang通过⼀个ServeMux实现了的multiplexer路由多路复⽤器来管理路由。同时提供⼀个Handler接⼝提供ServeHTTP⽤ServeMux和handler处理器函数的
连接桥梁就是Handler接⼝。ServeMux的ServeHTTP⽅法实现了寻找注册路由的handler的函数，并调⽤该handler的ServeHTTP⽅法。ServeHTTP⽅法就是真正处理请求和构造响应的地⽅。
回顾go的http包实现http服务的流程，可见⼤师们的编码设计之功⼒。学习有利提⾼⾃⾝的代码逻辑组织能⼒。更好的学习⽅式除了阅读，就是实践，接下来，我们将着重讨论来构建http服务。尤其是构建http中间件函数。
