一文詳解Golang中net/http包的實現(xiàn)原理
前言
Go語言自帶的net/http包提供了HTTP客戶端和服務(wù)端的實現(xiàn)，實現(xiàn)一個簡單的http服務(wù)非常容易，其自帶了一些列結(jié)構(gòu)和方法來幫助開發(fā)者簡化HTTP服務(wù)開發(fā)的相關(guān)流程，因此我們不需要依賴任何第三方組件就能構(gòu)建并啟動一個高并發(fā)的HTTP服務(wù)器，net/http包在編寫web應(yīng)用中有很重要的作用，這篇文章會學(xué)習(xí)如何用 net/http 自己編寫實現(xiàn)一個 HTTP Server 并探究其實現(xiàn)原理，具體講解Go語言是如何接收和處理請求的，希望能夠?qū)Υ蠹业膶W(xué)習(xí)或工作具有一定的幫助,需要的朋友可以參考下。
http包執(zhí)行流程
net/http包的web工作原理大致就是如下四個部分組成了：端口監(jiān)聽、請求解析、路由分配、響應(yīng)處理。更加代碼化的說就是：創(chuàng)建 ServerSocket， 綁定并listen，accept連接，創(chuàng)建go協(xié)程服務(wù)一個連接。
具體流程如下：
- 服務(wù)端創(chuàng)建
Listen Socket，綁定并監(jiān)聽指定的IP地址和端口，等待客戶端請求到來；ListenAndServer(...) - 客戶端與
Listen Socket連接，確認請求后，客戶端得到Client Socket,客戶端通過這個與Listen Socket通信；srv.Server(...) - 服務(wù)端創(chuàng)建一個協(xié)程來處理客戶端請求，首先從
Client Socket讀取Http請求的協(xié)議頭和數(shù)據(jù)，交給響應(yīng)的Handler處理， Handler處理完畢后，結(jié)果通過Client Socket寫給客戶端。c.server(...)
http包源碼分析
在上面的流程中中，起關(guān)鍵作用的函數(shù)為http.ListenAndServe，Go就是利用這個方法，實現(xiàn)了web服務(wù)中的端口監(jiān)聽、請求解析、路由分配、響應(yīng)處理四大功能。
端口監(jiān)聽
服務(wù)器中的http.ListenAndServer()方法啟動服務(wù)：
func ListenAndServe(addr string, handler Handler) error {
server := &Server{Addr: addr, Handler: handler}
return server.ListenAndServe()
}生成Server結(jié)構(gòu)體，調(diào)用其方法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，并處理相關(guān)的報錯，根據(jù)該連接創(chuàng)建對應(yī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)錯誤輸入和恢復(fù)、連接關(guān)閉；
該方法用于服務(wù)一個新的連接。首先，通過readRequest來讀取數(shù)據(jù)，解析請求中的Header、Body和一些校驗。接著，使用serverHandler方法來處理request和response。 主要功能實現(xiàn)是serverHandler{c.server}.ServeHTTP(w, w.req)，其構(gòu)造serverHandler類型，并調(diào)用ServeHTTP方法；值得注意的是，這里不允許服務(wù)器同時處理多個請求；
路由分配
使用者注冊一個HandlerFunc，被轉(zhuǎn)為Handler
func HandleFunc(pattern string, handler func(ResponseWriter, *Request)) {
DefaultServeMux.HandleFunc(pattern, handler)
}ServeMux的Handle方法，將會對pattern和Handler做map映射。
handler會創(chuàng)建一個鎖，同時調(diào)用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
}
}響應(yīng)處理
其實就是如何根據(jù)路由，找到對應(yīng)的handler。
在match方法中，對于handler，優(yōu)先查找m表，若不能找到結(jié)果，則在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
}服務(wù)端處理完請求后，處理器可以通過ResponseWriter接口創(chuàng)建HTTP響應(yīng)，ResponseWriter接口具有如下三個方法：
type ResponseWriter interface {
Header() Header
Write([]byte) (int, error)
WriteHeader(statusCode int)
}到此這篇關(guān)于一文詳解Golang中net/http包的實現(xiàn)原理的文章就介紹到這了,更多相關(guān)Golang net http包內(nèi)容請搜索腳本之家以前的文章或繼續(xù)瀏覽下面的相關(guān)文章希望大家以后多多支持腳本之家！
相關(guān)文章
Golang語言使用像JAVA?Spring注解一樣的DI和AOP依賴注入實例
這篇文章主要為大家介紹了Golang語言使用像JAVA?Spring注解一樣的DI和AOP依賴注入實例,有需要的朋友可以借鑒參考下,希望能夠有所幫助,祝大家多多進步,早日升職加薪2023-10-10
Golang使用gin框架實現(xiàn)一個完整的聊天室功能
由于我們項目的需要,我就研究了一下關(guān)于websocket的相關(guān)內(nèi)容,去實現(xiàn)一個聊天室的功能,經(jīng)過幾天的探索,現(xiàn)在使用Gin框架實現(xiàn)了一個完整的聊天室+消息實時通知系統(tǒng),感興趣的小伙伴歡迎閱讀本文2023-08-08
這篇文章主要介紹了Golang Http 驗證碼示例，文中通過示例代碼介紹的非常詳細，對大家的學(xué)習(xí)或者工作具有一定的參考學(xué)習(xí)價值，需要的朋友們下面隨著小編來一起學(xué)習(xí)學(xué)習(xí)吧2020-08-08
基于HLS創(chuàng)建Golang視頻流服務(wù)器的優(yōu)缺點
HLS 是 HTTP Live Streaming 的縮寫，是蘋果開發(fā)的一種基于 HTTP 的自適應(yīng)比特率流媒體傳輸協(xié)議。這篇文章主要介紹了基于 HLS 創(chuàng)建 Golang 視頻流服務(wù)器,需要的朋友可以參考下2021-08-08
淺談Go語言多態(tài)的實現(xiàn)與interface使用
如果大家系統(tǒng)的學(xué)過C++、Java等語言以及面向?qū)ο蟮脑挘嘈艖?yīng)該對多態(tài)不會陌生。多態(tài)是面向?qū)ο蠓懂牣?dāng)中經(jīng)常使用并且非常好用的一個功能，它主要是用在強類型語言當(dāng)中，像是Python這樣的弱類型語言，變量的類型可以隨意變化，也沒有任何限制，其實區(qū)別不是很大2021-06-06
這篇文章主要介紹了Go?將在下個版本支持新型排序算法：pdqsort,而就Go支持pdqsort算法，在HN上引起了不少的討論，有人表示，我們研究排序算法這么久了，很驚訝我們還能想出能產(chǎn)生實際改進的優(yōu)化方案。對此，你怎么看，快快上手體驗一下吧2022-04-04
本文主要介紹了Golang?Map中的key為什么是無序的，文中通過示例代碼介紹的非常詳細，具有一定的參考價值，感興趣的小伙伴們可以參考一下2022-02-02
在Go語言中,panic用于觸發(fā)不可恢復(fù)的錯誤,終止函數(shù)執(zhí)行并逐層向上觸發(fā)defer,最終若未被recover捕獲,程序會崩潰,recover用于在defer函數(shù)中捕獲panic,恢復(fù)程序流程,建議優(yōu)先返回error,僅在嚴重錯誤或不可恢復(fù)場景下使用panic,并在關(guān)鍵位置recover,感興趣的朋友一起看看吧2025-03-03
前面給大家介紹過使用javascript實現(xiàn)的簡單的數(shù)獨解法，小伙伴們都非常喜歡，今天我們再來分享一則go語言實現(xiàn)的簡單的數(shù)獨解法，有需要的小伙伴來參考下。2015-03-03
我們都知道go語言中內(nèi)存管理工作都是由Go在底層完成的，這樣我們可以不用過多的關(guān)注底層的內(nèi)存問題。本文主要總結(jié)一下?Golang內(nèi)存逃逸分析，需要的朋友可以參考以下內(nèi)容，希望對大家有幫助2022-09-09