有人曾和我说过,一门语言应该可以本身实现一个HTTP服务。PHP作不到,但GO却垂手可得。
只须要几行代码,GO就能够实现一个简单的HTTP服务。nginx
package main import ( "fmt" "net/http" ) func IndexHandler(w http.ResponseWriter, r *http.Request) { fmt.Fprintln(w, "hello world") } func main() { http.HandleFunc("/", IndexHandler) http.ListenAndServe(":8001", nil) }
这样,便可监听8001端口,而且当有请求访问的时候完成响应。(这几乎就完成了nginx的主要功能,不过没有作负载平衡)
观察这段代码,咱们基本可以从命名大概了解每一个函数的做用。服务器
http.HandleFunc("/", IndexHandler)
这至关于绑定url的函数,当请求的url是"/"时,那么将这个请求交给IndexHandler来处理。cookie
http.ListenAndServe(":8001", nil)
顾名思义,监听8001端口而且启动服务。并发
func IndexHandler(w http.ResponseWriter, r *http.Request) { fmt.Fprintln(w, "hello world") }
处理函数,当有请求的时候输出hello world。
经过以上分析,GO搭建一个HTTP服务只需用到一个net/http包便可。同时结合上篇文章,要完成http服务须要如下几点tcp
前3点是一个HTTP服务必需要的结构,第4点是每个HTTP服务的核心所在。
咱们只须要了解3个问题,就知道GO是如何将Web服务运做起来。函数
GO是经过一个函数 ListenAndServe
作到的。
首先初始化一个server对象,而后调用net.Listen("tcp", addr)
底层创建TCP链接,监听咱们设置的端口。高并发
这块的源码post
func (srv *Server) Serve(l net.Listener) error { defer l.Close() var tempDelay time.Duration // how long to sleep on accept failure for { rw, e := l.Accept() if e != nil { if ne, ok := e.(net.Error); ok && ne.Temporary() { if tempDelay == 0 { tempDelay = 5 * time.Millisecond } else { tempDelay *= 2 } if max := 1 * time.Second; tempDelay > max { tempDelay = max } log.Printf("http: Accept error: %v; retrying in %v", e, tempDelay) time.Sleep(tempDelay) continue } return e } tempDelay = 0 c, err := srv.newConn(rw) if err != nil { continue } go c.serve() } }
这段代码首先起了一个for()
。接收请求Accept()
,如有请求,则创建一个Conn链接,并用协程启动服务。这时再次进入下一个循环,如有请求则新创建一个链接并启动一个协程服务。若没有请求,则休息一段时间后再次循环。正是利用了go协程特性,用户的每个请求都有一个新的goroutine去服务,互不影响,达到了自然支持高并发特性。url
在创建conn以后,conn会首先解析request,c.readRequest()
,而后得到相应的handle:handler := c.server.Handler
,也就是咱们刚才在调用函数ListenAndServe
时候的第二个参数,咱们前面例子传递的是nil,也就是为空,那么默认获取handler = DefaultServeMux
,那么这个变量用来作什么的呢?对,这个变量就是一个路由器,它用来匹配url跳转到其相应的handle函数,那么这个咱们有设置过吗?有,咱们调用的代码里面第一句不是调用了http.HandleFunc("/", IndexHandler)
嘛。这个做用就是注册了请求/的路由规则,当请求uri为"/",路由就会转到函数IndexHandler
,DefaultServeMux
会调用ServeHTTP
方法,这个方法内部其实就是调用IndexHandler
自己,最后经过写入response
的信息反馈到客户端。code