最新国产好看的视频,伊人天堂AV在线,国产Aaaaaa视频,蜜臀视频在线观看一区,人妻av色图,密臀久久久精品影片,青青视频免费观看毛片,久草在线观看视,国产三级精品色情在线

Go底層之http標準庫服務端實現(xiàn)原理分析

 更新時間:2025年06月25日 15:24:41   作者:在成都搬磚的鴨鴨  
這篇文章主要介紹了Go底層之http標準庫服務端實現(xiàn)原理,具有很好的參考價值,希望對大家有所幫助,如有錯誤或未考慮完全的地方,望不吝賜教

背景

http協(xié)議的交互框架是C-S架構,C對應客戶端模塊,S對應服務端模塊,接下來我們就基于Go1.23源碼來熟悉http標準庫中服務端的實現(xiàn)。

核心數(shù)據(jù)結構

【1】Server對象

位于net/http/server.go文件,其源碼如下:

type Server struct {
	Addr string //服務器監(jiān)聽規(guī)定TCP地址
	
	Handler Handler //處理http請求的處理器。若為nil,使用http.DefaultServeMux

	DisableGeneralOptionsHandler bool //若為true,將OPTIONS*請求交給Handler處理,否在自動響應200 OK

	TLSConfig *tls.Config //TLS配置

	ReadTimeout time.Duration //讀取整個請求(含請求體)的最大超時時間。若小于等于0,表示無超時

	ReadHeaderTimeout time.Duration //單獨讀取請求頭的超時時間。若小于等于0,繼承ReadTimeout的值

	WriteTimeout time.Duration //寫入響應的最大超時時間。若小于等于0,表示無超時

	IdleTimeout time.Duration //保持連接空閑的最大時間(用于keep-Alice)若小于等于0,繼承ReadTimeout的值

	MaxHeaderBytes int //請求頭的最大字節(jié)數(shù)。若為0,使用DefaultMaxHeaderBytes

	TLSNextProto map[string]func(*Server, *tls.Conn, Handler) //用于處理ALPN協(xié)議升級

	ConnState func(net.Conn, ConnState) //客戶端連接狀態(tài)變更時的回調函數(shù)(如新建、活躍、空閑、關閉)

	ErrorLog *log.Logger //自定義錯誤日志記錄器。若為nil,則使用標準庫的log包

	BaseContext func(net.Listener) context.Context //為每個請求生成基礎上下文

	ConnContext func(ctx context.Context, c net.Conn) context.Context //修改新連接的上下文

	inShutdown atomic.Bool //標記服務器是否正在關閉

	disableKeepAlives atomic.Bool //控制是否禁用Keep-Alive
	nextProtoOnce     sync.Once //確保HTTP/2配置只初始化一次
	nextProtoErr      error     //存儲HTTP/2配置的錯誤結果

	mu         sync.Mutex //保護listeners和activceConn
	listeners  map[*net.Listener]struct{} //當前活躍的監(jiān)聽器集合
	activeConn map[*conn]struct{} //當前活躍的連接集合
	onShutdown []func() //服務器關閉時執(zhí)行的鉤子函數(shù)

	listenerGroup sync.WaitGroup //用于等待所有監(jiān)聽器關閉的同步組
}

【2】Handler對象

位于net/http/server.go文件,其源碼如下:

/*
	Handler接口定義了HTTP請求處理器的標準行為,任何實現(xiàn)ServerHTTP方法的類型都可以處理HTTP請求。
	Request:包含HTTP請求的所有信息。
	ResponseWriter:用于構造HTTP響應。
*/
type Handler interface {
	ServeHTTP(ResponseWriter, *Request)
}

【3】ServeMux對象

位于net/http/server.go文件,其源碼如下:

/*
	ServeMux是HTTP請求路由器的核心實現(xiàn),復雜將不同URL路徑的請求分發(fā)給對應的處理函數(shù)。
	其核心作用是通過內部的路由樹(tree)和索引(index)高效匹配請求路徑,同時通過互斥
	鎖(mu)保證并發(fā)安全,并兼容舊版本路由邏輯(mux121)。
*/
type ServeMux struct {
	mu       sync.RWMutex //保護路由表的并發(fā)安全(注冊路由時寫鎖,匹配路由時讀鎖)
	tree     routingNode //路由前綴樹,存儲URL路徑與處理函數(shù)的映射關系,支持高效路徑匹配
	index    routingIndex //路由加速索引,優(yōu)化特定場景的查找性能
	patterns []*pattern  //兼容舊版本的路由模式列表
	mux121   serveMux121 //Go1.21及之前舊版本路由實現(xiàn)
}

服務端代碼示例

使用http標準庫實現(xiàn)的一個簡單http服務示例如下:

func main() {
	//路由注冊
	http.HandleFunc("POST /xxx", func(writer http.ResponseWriter, request *http.Request) {
		writer.Write([]byte("AAA"))
	})

	//服務啟用、路由匹配
	http.ListenAndServe(":8000", nil)
}

可以看到一個http服務端由兩個部分組成:路由注冊和服務啟用,其中服務啟用內部實現(xiàn)了路由匹配邏輯,接下來再深究內部。

路由注冊

路由注冊的入口為http.HandleFunc函數(shù),其源碼如下:

func HandleFunc(pattern string, handler func(ResponseWriter, *Request)) {
	if use121 { 
	    //Go1.21及以前版本路由注冊實現(xiàn)
		DefaultServeMux.mux121.handleFunc(pattern, handler)
	} else {
	    //新版本路由注冊實現(xiàn)
		DefaultServeMux.register(pattern, HandlerFunc(handler))
	}
}

舊版本路由注冊實現(xiàn)源碼如下:

func (mux *serveMux121) handleFunc(pattern string, handler func(ResponseWriter, *Request)) {
	...
	
	//將路徑和對應的回調函數(shù)關聯(lián)起來,具體關聯(lián)方法不深究
	mux.handle(pattern, HandlerFunc(handler)) 
}

新版本路由注冊實現(xiàn)源碼如下:

func (mux *ServeMux) registerErr(patstr string, handler Handler) error {
	...
	
	pat, err := parsePattern(patstr)
	if err != nil {
		return fmt.Errorf("parsing %q: %w", patstr, err)
	}

	...
	
	//關聯(lián)路徑和對應的回調函數(shù)
	mux.tree.addPattern(pat, handler) 
	mux.index.addPattern(pat)
	mux.patterns = append(mux.patterns, pat)
	return nil
}

舊版本和新版本都會將對應的回調函數(shù)轉換為http.HandlerFunc類型,這是因為http.HandlerFunc類型實現(xiàn)了http.Handler接口:

//實現(xiàn)了Handler接口
type HandlerFunc func(ResponseWriter, *Request)

func (f HandlerFunc) ServeHTTP(w ResponseWriter, r *Request) {
	f(w, r)
}

路由匹配

路由匹配的邏輯在服務啟動http.ListenAndServe里,其源碼調用邏輯鏈路為:

func ListenAndServe(addr string, handler Handler) error {
	server := &Server{Addr: addr, Handler: handler}
	return server.ListenAndServe()
}

func (srv *Server) ListenAndServe() error {
	...
	
	ln, err := net.Listen("tcp", addr)
	if err != nil {
		return err
	}
	return srv.Serve(ln)
}

func (srv *Server) Serve(l net.Listener) error {
	...
	
	for {
		rw, err := l.Accept() //阻塞等待客戶端連接
		
		...

		c := srv.newConn(rw)
		c.setState(c.rwc, StateNew, runHooks) // before Serve can return
		go c.serve(connCtx) //協(xié)程去響應客戶端連接
	}
}

func (c *conn) serve(ctx context.Context) {
	...

	for {
		//讀取客戶端請求并構造響應結構體w
		w, err := c.readRequest(ctx)
	
	    ...
        
        //處理并響應請求
		serverHandler{c.server}.ServeHTTP(w, w.req)
		
		...
	}
}

func (sh serverHandler) ServeHTTP(rw ResponseWriter, req *Request) {
	handler := sh.srv.Handler
	if handler == nil { //未定義handler就使用默認的http處理器
		handler = DefaultServeMux
	}

	...

	//處理客戶端請求并響應
	handler.ServeHTTP(rw, req)
}

//默認http處理器實現(xiàn)的處理客戶端請求并響應的方法
func (mux *ServeMux) ServeHTTP(w ResponseWriter, r *Request) {
	...
	
	var h Handler
	if use121 { //舊版本根據(jù)請求進行路由匹配
		h, _ = mux.mux121.findHandler(r)
	} else { //新版本根據(jù)請求進行路由匹配
		h, r.Pattern, r.pat, r.matches = mux.findHandler(r)
	}
    
    /*
    	這里執(zhí)行的是HandlerFunc類型的ServeHTTP方法,因為在注冊路由時都將回調函數(shù)轉換為了HandlerFunc類型。
    	type HandlerFunc func(ResponseWriter, *Request)

		func (f HandlerFunc) ServeHTTP(w ResponseWriter, r *Request) {
			f(w, r)
		}
    */
    h.ServeHTTP(w, r)
}

總結

以上為個人經驗,希望能給大家一個參考,也希望大家多多支持腳本之家。

相關文章

  • Golang極簡入門教程(二):方法和接口

    Golang極簡入門教程(二):方法和接口

    這篇文章主要介紹了Golang極簡入門教程(二):方法和接口,本文同時講解了錯誤、匿名域等內容,需要的朋友可以參考下
    2014-10-10
  • golang?debug調試的實現(xiàn)

    golang?debug調試的實現(xiàn)

    本文主要介紹了使用Go語言進行本地調試和遠程調試,文中通過圖文介紹的非常詳細,對大家的學習或者工作具有一定的參考學習價值,需要的朋友們下面隨著小編來一起學習學習吧
    2024-12-12
  • 詳解如何在Go中實現(xiàn)優(yōu)雅停止

    詳解如何在Go中實現(xiàn)優(yōu)雅停止

    和其他語言相比,Go 中有相同也有不同,相同的是實現(xiàn)思路上和其他語言沒啥差異,不同在于 Go 采用的是 goroutine + channel 的并發(fā)模型,與傳統(tǒng)的進程線程相比,實現(xiàn)細節(jié)上存在差異,本文將從實際場景和它的一般實現(xiàn)方式展開,逐步討論這個話題,需要的朋友可以參考下
    2024-04-04
  • go進行http請求偶發(fā)EOF問題分析

    go進行http請求偶發(fā)EOF問題分析

    go使用連接池進行http請求,一般都能請求成功,但偶然會出現(xiàn)請求失敗返回EOF錯誤的情況,本文主要來帶大家分析一下為什么會出現(xiàn)這樣的問題并提供解決方法,需要的可以參考下
    2025-01-01
  • go讀取request.Body內容踩坑實戰(zhàn)記錄

    go讀取request.Body內容踩坑實戰(zhàn)記錄

    很多初學者在使用Go語言進行Web開發(fā)時,都會遇到讀取 request.Body內容的問題,這篇文章主要給大家介紹了關于go讀取request.Body內容踩坑實戰(zhàn)記錄的相關資料,需要的朋友可以參考下
    2023-11-11
  • Golang實現(xiàn)深拷貝reflect原理示例探究

    Golang實現(xiàn)深拷貝reflect原理示例探究

    這篇文章主要為大家介紹了Golang實現(xiàn)reflect深拷貝原理示例探究,有需要的朋友可以借鑒參考下,希望能夠有所幫助,祝大家多多進步,早日升職加薪
    2024-01-01
  • 減少 golang 二進制文件大小操作

    減少 golang 二進制文件大小操作

    這篇文章主要介紹了減少 golang 二進制文件大小操作,具有很好的參考價值,希望對大家有所幫助。一起跟隨小編過來看看吧
    2020-12-12
  • 全面解析Go語言中crypto/sha1庫

    全面解析Go語言中crypto/sha1庫

    crypto/sha1在Go語言標準庫中是一個強大且實用的工具,適用于多種應用場景,本文就詳細的介紹了Go語言中crypto/sha1庫,具有一定的參考價值,感興趣的可以了解一下
    2024-02-02
  • Go重寫http請求重定向的方法

    Go重寫http請求重定向的方法

    當使用Go語言進行 HTTP 請求時,默認情況下,http.Client 會自動處理服務器返回的重定向響應(3xx 狀態(tài)碼),本文將詳細介紹如何在 Go 中實現(xiàn)禁止 HTTP 請求的重定向、限制重定向次數(shù)以及添加自定義重定向策略,需要的朋友可以參考下
    2024-08-08
  • golang jwt鑒權的實現(xiàn)流程

    golang jwt鑒權的實現(xiàn)流程

    本文主要介紹了golang jwt鑒權的實現(xiàn)流程,包含生成JWT令牌、客戶端存儲和發(fā)送JWT令牌、服務端驗證JWT令牌等,具有一定的參考價值,感興趣的可以了解一下
    2025-02-02

最新評論

准格尔旗| 柳河县| 平南县| 雅安市| 沧州市| 沈丘县| 剑阁县| 屯门区| 北安市| 侯马市| 怀仁县| 永嘉县| 宿松县| 泉州市| 绩溪县| 萍乡市| 汝南县| 梨树县| 邢台县| 巴青县| 洪雅县| 阳谷县| 大同县| 温泉县| 兴文县| 木兰县| 色达县| 金乡县| 遂昌县| 博客| 仪陇县| 五常市| 布尔津县| 乌鲁木齐县| 广德县| 桦南县| 泌阳县| 林芝县| 永春县| 钟祥市| 剑阁县|