一文詳解Golang中net/http包的實現(xiàn)原理
前言
Go語言自帶的net/http包提供了HTTP客戶端和服務端的實現(xiàn)，實現(xiàn)一個簡單的http服務非常容易，其自帶了一些列結構和方法來幫助開發(fā)者簡化HTTP服務開發(fā)的相關流程，因此我們不需要依賴任何第三方組件就能構建并啟動一個高并發(fā)的HTTP服務器，net/http包在編寫web應用中有很重要的作用，這篇文章會學習如何用 net/http 自己編寫實現(xiàn)一個 HTTP Server 并探究其實現(xiàn)原理，具體講解Go語言是如何接收和處理請求的，希望能夠對大家的學習或工作具有一定的幫助,需要的朋友可以參考下。
http包執(zhí)行流程
net/http包的web工作原理大致就是如下四個部分組成了：端口監(jiān)聽、請求解析、路由分配、響應處理。更加代碼化的說就是：創(chuàng)建 ServerSocket， 綁定并listen，accept連接，創(chuàng)建go協(xié)程服務一個連接。
具體流程如下：
- 服務端創(chuàng)建
Listen Socket，綁定并監(jiān)聽指定的IP地址和端口，等待客戶端請求到來；ListenAndServer(...) - 客戶端與
Listen Socket連接，確認請求后，客戶端得到Client Socket,客戶端通過這個與Listen Socket通信；srv.Server(...) - 服務端創(chuàng)建一個協(xié)程來處理客戶端請求，首先從
Client Socket讀取Http請求的協(xié)議頭和數(shù)據(jù)，交給響應的Handler處理， Handler處理完畢后，結果通過Client Socket寫給客戶端。c.server(...)
http包源碼分析
在上面的流程中中，起關鍵作用的函數(shù)為http.ListenAndServe，Go就是利用這個方法，實現(xiàn)了web服務中的端口監(jiān)聽、請求解析、路由分配、響應處理四大功能。
端口監(jiān)聽
服務器中的http.ListenAndServer()方法啟動服務：
func ListenAndServe(addr string, handler Handler) error {
server := &Server{Addr: addr, Handler: handler}
return server.ListenAndServe()
}生成Server結構體，調用其方法ListenAndServer
func (srv *Server) ListenAndServe() error {
if srv.shuttingDown() {
return ErrServerClosed
}
addr := srv.Addr
if addr == "" {
addr = ":http"
}
ln, err := net.Listen("tcp", addr)
if err != nil {
return err
}
return srv.Serve(ln)
}net.Listen來進行對地址的監(jiān)聽，返回一個listener,傳遞給server.Server()方法。
func (srv *Server) Serve(l net.Listener) error {
if fn := testHookServerServe; fn != nil {
fn(srv, l) // call hook with unwrapped listener
}
origListener := l
l = &onceCloseListener{Listener: l}
defer l.Close()
if err := srv.setupHTTP2_Serve(); err != nil {
return err
}
if !srv.trackListener(&l, true) {
return ErrServerClosed
}
defer srv.trackListener(&l, false)
baseCtx := context.Background()
if srv.BaseContext != nil {
baseCtx = srv.BaseContext(origListener)
if baseCtx == nil {
panic("BaseContext returned a nil context")
}
}
var tempDelay time.Duration // how long to sleep on accept failure
ctx := context.WithValue(baseCtx, ServerContextKey, srv)
for { //循環(huán)邏輯，接收請求處理
//有新的連接
rw, err := l.Accept()
if err != nil {
select {
case <-srv.getDoneChan():
return ErrServerClosed
default:
}
if ne, ok := err.(net.Error); ok && ne.Temporary() {
if tempDelay == 0 {
tempDelay = 5 * time.Millisecond
} else {
tempDelay *= 2
}
if max := 1 * time.Second; tempDelay > max {
tempDelay = max
}
srv.logf("http: Accept error: %v; retrying in %v", err, tempDelay)
time.Sleep(tempDelay)
continue
}
return err
}
connCtx := ctx
if cc := srv.ConnContext; cc != nil {
connCtx = cc(connCtx, rw)
if connCtx == nil {
panic("ConnContext returned nil")
}
}
tempDelay = 0
//創(chuàng)建新的連接
c := srv.newConn(rw)
c.setState(c.rwc, StateNew) // before Serve can return
//啟動新的goroutine進行處理
go c.serve(connCtx)
}
}主要進行了兩項工作，一項是在for死循環(huán)里面，通過l.Accept()來接受請求返回連接Conn，并處理相關的報錯，根據(jù)該連接創(chuàng)建對應的goroutine來執(zhí)行conn.serve(ctx)，各個請求之間是相互不影響的，提高并發(fā)性能。 另一項工作是新建context用于管理這些生成的goroutine，context作為參數(shù)被傳入；
請求解析
// Serve a new connection.
func (c *conn) serve(ctx context.Context) {
// ...
}函數(shù)代碼比較多，就不貼出來了，具體可以到/net/http/server.go文件中查看，其中使用了defer func() {...}()匿名函數(shù)來實現(xiàn)錯誤輸入和恢復、連接關閉；
該方法用于服務一個新的連接。首先，通過readRequest來讀取數(shù)據(jù)，解析請求中的Header、Body和一些校驗。接著，使用serverHandler方法來處理request和response。 主要功能實現(xiàn)是serverHandler{c.server}.ServeHTTP(w, w.req)，其構造serverHandler類型，并調用ServeHTTP方法；值得注意的是，這里不允許服務器同時處理多個請求；
路由分配
使用者注冊一個HandlerFunc，被轉為Handler
func HandleFunc(pattern string, handler func(ResponseWriter, *Request)) {
DefaultServeMux.HandleFunc(pattern, handler)
}ServeMux的Handle方法，將會對pattern和Handler做map映射。
handler會創(chuàng)建一個鎖，同時調用match方法返回一個Handler和pattern。
func (mux *ServeMux) Handle(pattern string, handler Handler) {
mux.mu.Lock()
defer mux.mu.Unlock()
if pattern == "" {
panic("http: invalid pattern")
}
if handler == nil {
panic("http: nil handler")
}
if _, exist := mux.m[pattern]; exist {
panic("http: multiple registrations for " + pattern)
}
if mux.m == nil {
mux.m = make(map[string]muxEntry)
}
e := muxEntry{h: handler, pattern: pattern}
mux.m[pattern] = e
if pattern[len(pattern)-1] == '/' {
mux.es = appendSorted(mux.es, e)
}
if pattern[0] != '/' {
mux.hosts = true
}
}響應處理
其實就是如何根據(jù)路由，找到對應的handler。
在match方法中，對于handler，優(yōu)先查找m表，若不能找到結果，則在es表中進行匹配，路徑長的優(yōu)先匹配。
func (mux *ServeMux) match(path string) (h Handler, pattern string) {
// Check for exact match first.
v, ok := mux.m[path]
if ok {
return v.h, v.pattern
}
// Check for longest valid match.
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
}服務端處理完請求后，處理器可以通過ResponseWriter接口創(chuàng)建HTTP響應，ResponseWriter接口具有如下三個方法：
type ResponseWriter interface {
Header() Header
Write([]byte) (int, error)
WriteHeader(statusCode int)
}到此這篇關于一文詳解Golang中net/http包的實現(xiàn)原理的文章就介紹到這了,更多相關Golang net http包內(nèi)容請搜索腳本之家以前的文章或繼續(xù)瀏覽下面的相關文章希望大家以后多多支持腳本之家！
相關文章
這篇文章主要為大家詳細介紹了使語言實現(xiàn)各種常見hash算法的相關知識,文中的示例代碼講解詳細,具有一定的借鑒價值,需要的小伙伴可以參考下2024-01-01
這篇文章主要介紹了Go語言基礎知識,包括基本語法、語句、數(shù)組等的定義與用法,需要的朋友可以參考下2016-07-07
golang的時區(qū)和神奇的time.Parse的使用方法
這篇文章主要介紹了golang的時區(qū)和神奇的time.Parse的使用方法，文中通過示例代碼介紹的非常詳細，對大家的學習或者工作具有一定的參考學習價值，需要的朋友們下面隨著小編來一起學習學習吧2021-04-04
在實際工作,我們需要讀取大數(shù)據(jù)文件,文件可能上G百G,所以我們不可能一次性的讀取到內(nèi)存,接下來本文給大家介紹了golang實現(xiàn)大文件讀取的示例,需要的朋友可以參考下2024-04-04
Go語言使用ioutil.ReadAll函數(shù)需要注意基本說明
這篇文章主要為大家介紹了Go語言使用ioutil.ReadAll函數(shù)需要注意基本說明，有需要的朋友可以借鑒參考下，希望能夠有所幫助，祝大家多多進步，早日升職加薪2023-07-07
go語言中有Timer和Ticker這樣的兩種計時器,兩種計時器分別實現(xiàn)了不同的計時功能,本文主要介紹了go語言中Timer和Ticker兩種計時器的使用,感興趣的可以了解一下2024-08-08
代碼中的加鎖操作因為涉及內(nèi)核態(tài)的上下文切換會比較耗時、代價比較高。針對基本數(shù)據(jù)類型我們還可以使用原子操作來保證并發(fā)安全，本文就來和大家詳細聊聊，需要的可以參考下2022-12-12
這篇文章主要為大家詳細介紹了Golang實現(xiàn)斷點續(xù)傳、復制文件功能，文中示例代碼介紹的非常詳細，具有一定的參考價值，感興趣的小伙伴們可以參考一下2022-07-07
Cobra是一個強大的開源工具，能夠幫助我們快速構建出優(yōu)雅且功能豐富的命令行應用，本文為大家介紹了如何使用Cobra打造強大命令行應用，感興趣的小伙伴可以了解一下2023-07-07
這篇文章主要給大家介紹了關于Golang中Set類型實現(xiàn)的相關資料，文中通過示例代碼介紹的非常詳細，對大家的學習或者工作具有一定的參考學習價值，需要的朋友們下面隨著小編來一起學習學習吧。2017-09-09