Golang中HTTP服務的分析與設計詳解
http.ListenAndServe
type Server struct { // 請求監(jiān)聽地址 Addr string // 請求核心處理函數(shù) Handler Handler }
http.ListenAndServe(httpAddr, nil) // ListenAndServe always returns a non-nil error. // 創(chuàng)造了一個server對象并調用ListenAndServe func ListenAndServe(addr string, handler Handler) error { server := &Server{Addr: addr, Handler: handler} return server.ListenAndServe() } func (srv *Server) ListenAndServe() error { // 如果關閉了http監(jiān)聽則直接返回ErrServerClosed if srv.shuttingDown() { return ErrServerClosed } addr := srv.Addr if addr == "" { addr = ":http" } // 開啟net包的Listen監(jiān)聽方法,根據(jù)傳入的類型返回監(jiān)聽的對象 ln, err := net.Listen("tcp", addr) if err != nil { return err } return srv.Serve(ln) }
Serve方法. 接收一個監(jiān)聽者
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 // 將整個Server對象設置進ctx中,在多個goroutinue中共享 ctx := context.WithValue(baseCtx, ServerContextKey, srv) for { 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 c := srv.newConn(rw) c.setState(c.rwc, StateNew, runHooks) // before Serve can return go c.serve(connCtx) //Serve a new connection 建立新的連接 } }
c.serve
這個函數(shù)主要是判斷本次http請求是否升級為https,接著創(chuàng)建文本的reader,和寫文本的buffer,再進一步讀取本次的請求數(shù)據(jù)!
最后是調用關鍵的方法serverHandler{c.server}.ServeHttp(w,w.req)
來處理本次請求!
serverHandler
// serverHandler 代表請求對應的處理邏輯 type serverHandler struct { srv *Server } // 具體的處理函數(shù) func (sh serverHandler) ServeHTTP(rw ResponseWriter, req *Request) { handler := sh.srv.Handler //如果入口設置傳入了`Handler`,那么調用的就是傳入的,否則就是DefaultServeMux if handler == nil { handler = DefaultServeMux } if req.RequestURI == "*" && req.Method == "OPTIONS" { handler = globalOptionsHandler{} } if req.URL != nil && strings.Contains(req.URL.RawQuery, ";") { var allowQuerySemicolonsInUse int32 req = req.WithContext(context.WithValue(req.Context(), silenceSemWarnContextKey, func() { atomic.StoreInt32(&allowQuerySemicolonsInUse, 1) })) defer func() { if atomic.LoadInt32(&allowQuerySemicolonsInUse) == 0 { sh.srv.logf("http: URL query contains semicolon, which is no longer a supported separator; parts of the query may be stripped when parsed; see golang.org/issue/25192") } }() } handler.ServeHTTP(rw, req) }
流程梳理
上述大致調用的流程梳理完畢總結一下
創(chuàng)建服務->創(chuàng)建連接->監(jiān)聽請求(net.Listen)->處理請求(ServeHTTP)
- 標準庫創(chuàng)建HTTP服務是通過Server對象完成的
- Server對象在for循環(huán)中不斷監(jiān)聽每一個連接
- 每個連接都默認開啟了一個goroutine
- serverHandler結構代表請求對應的邏輯,并用其ServeHTTP進行處理執(zhí)行
- 具有默認處理Handler,DefaultServeMux
- DefaultServeMux是通過map來尋找路由的
自己動手寫一個serverHandler
core.go
package framework import "net/http" type Core struct { } func (c Core) ServeHTTP(writer http.ResponseWriter, request *http.Request) { panic("implement me") } func NewCore() *Core { return &Core{} }
main.go
package main import ( "log" "net/http" "testdemo1/coredemo/framework" ) func main() { server:=&http.Server{Addr: ":8080",Handler: framework.NewCore()} err := server.ListenAndServe() if err!=nil{ log.Fatal(err) } }
后續(xù)再往自己的serverHttp方法里自定義補充處理請求邏輯!
本文到此結束,歡迎收看下一篇
到此這篇關于Golang中HTTP服務的分析與設計詳解的文章就介紹到這了,更多相關Golang HTTP服務內容請搜索腳本之家以前的文章或繼續(xù)瀏覽下面的相關文章希望大家以后多多支持腳本之家!
相關文章
Golang如何調用windows下的dll動態(tài)庫中的函數(shù)
這篇文章主要介紹了Golang如何調用windows下的dll動態(tài)庫中的函數(shù)方式,具有很好的參考價值,希望對大家有所幫助。一起跟隨小編過來看看吧2021-05-05golang使用bcrypt包對密碼進行加密的方法實現(xiàn)
本文主要介紹了golang使用bcrypt包對密碼進行加密的方法實現(xiàn),文中通過示例代碼介紹的非常詳細,對大家的學習或者工作具有一定的參考學習價值,需要的朋友們下面隨著小編來一起學習學習吧2023-07-07gorm update傳入struct對象,零值字段不更新的解決方案
這篇文章主要介紹了gorm update傳入struct對象,零值字段不更新的解決方案,具有很好的參考價值,希望對大家有所幫助。一起跟隨小編過來看看吧2021-04-04Go語言使用defer+recover解決panic導致程序崩潰的問題
如果協(xié)程出現(xiàn)了panic,就會造成程序的崩潰,這時可以在goroutine中使用recover來捕獲panic,進行處理,本文就詳細的介紹一下,感興趣的可以了解一下2021-09-09