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

golang構(gòu)建HTTP服務(wù)的實(shí)現(xiàn)步驟

 更新時(shí)間:2021年12月10日 10:58:43   作者:冷月醉雪  
其實(shí)很多框架都是在 最簡(jiǎn)單的http服務(wù)上做擴(kuò)展的的,基本上都是遵循h(huán)ttp協(xié)議,本文主要介紹了golang構(gòu)建HTTP服務(wù),具有一定的參考價(jià)值,感興趣的小伙伴們可以參考一下

???一個(gè)go最簡(jiǎn)單的Http服務(wù)器程序

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("127.0.0.0:8000", nil)
}

HTTP

? ?除去細(xì)節(jié),理解HTTP構(gòu)建的網(wǎng)絡(luò)應(yīng)用只要關(guān)注兩個(gè)端--客戶(hù)端(client)和服務(wù)端(server),兩個(gè)端的交互來(lái)自client的request,以及server端的response。所謂的http服務(wù)器,主要在于如何接受client的request,并向client返回response。

? ?接收request的過(guò)程中,最重要的莫過(guò)于路由(router),即實(shí)現(xiàn)一個(gè)Multiplexer器。Go中既可以使用內(nèi)置的mutilplexer--DefaultServeMux,也可以自定義。Multiplexer路由的目的就是為了找到處理器函數(shù)(hander),后者將對(duì)request進(jìn)行處理,同時(shí)構(gòu)建response。

? 簡(jiǎn)單總結(jié)就是這個(gè)流程:

? 因此,理解go中的http服務(wù),,最重要的就是要理解Multiplexer和hander,Golang中的Multiplexer基于ServerMux結(jié)構(gòu),同時(shí)也實(shí)現(xiàn)了Handler接口。

? ·hander函數(shù):具有func(w http.ResponseWriter, r *http.Requests)簽名的函數(shù)

? ·handler處理器(函數(shù)):經(jīng)過(guò)HanderFunc結(jié)構(gòu)包裝的handler函數(shù),它實(shí)現(xiàn)了ServeHTTP接口方法的函數(shù)。調(diào)用handler處理器的ServeHTTP方法時(shí),即調(diào)用handler函數(shù)本身。

? ·handler對(duì)象:實(shí)現(xiàn)了Hander接口ServeHTTP方法的結(jié)構(gòu)。

? ?Golang的http處理流程可以用下面一張圖表示,后面內(nèi)容是針對(duì)圖進(jìn)行說(shuō)明:

Handler

? ?Golang沒(méi)有繼承,類(lèi)多態(tài)的方法可以通過(guò)接口實(shí)現(xiàn)。所謂接口則是定義聲明了函數(shù)簽名,任何結(jié)構(gòu)只要實(shí)現(xiàn)了與接口函數(shù)簽名相同的方法,就等同于實(shí)現(xiàn)了接口。go的http服務(wù)都是基于handler進(jìn)行處理的。

type Handler interface {
    ServeHTTP(ResponseWriter, *Request)
}

??? 任何結(jié)構(gòu)體,只要實(shí)現(xiàn)了ServeHTTP方法,這個(gè)結(jié)構(gòu)就可以稱(chēng)之為handler對(duì)象。ServeMux會(huì)使用handler并調(diào)用其ServeHTTP方法處理請(qǐng)求并返回響應(yīng)。

ServeMux

? ?了解了Handler之后,再看ServeMux。ServeMux源碼很簡(jiǎn)單:

type ServeMux struct {
    mu    sync.RWMutex
    m     map[string]muxEntry
    hosts bool 
}
 
type muxEntry struct {
    explicit bool
    h        Handler
    pattern  string
}

???ServeMux結(jié)構(gòu)中最重要的字段為m,這是一個(gè)map,key是一些url模式,value是一個(gè)muxEntry結(jié)構(gòu),后者里定義存儲(chǔ)了具體的url模式和handler。?

? ?當(dāng)然,所謂的ServeMux也實(shí)現(xiàn)了ServeHTTP接口,也算是一個(gè)handler,不過(guò)ServeMux的ServeHTTP方法不是用來(lái)處理request和respone,而是用來(lái)找到路由注冊(cè)的handler。

Server

? ?除了ServeMux和Handler,還有一個(gè)結(jié)構(gòu)Server需要了解。從http.ListenAndServe的源碼可以看出,它創(chuàng)建了一個(gè)server對(duì)象,并調(diào)用server對(duì)象的ListenAndServe方法:

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

???查看server的結(jié)構(gòu)如下:

type Server struct {
    Addr         string        
    Handler      Handler       
    ReadTimeout  time.Duration 
    WriteTimeout time.Duration 
    TLSConfig    *tls.Config   
 
    MaxHeaderBytes int
 
    TLSNextProto map[string]func(*Server, *tls.Conn, Handler)
 
    ConnState func(net.Conn, ConnState)
    ErrorLog *log.Logger
    disableKeepAlives int32     nextProtoOnce     sync.Once 
    nextProtoErr      error     
}

???server結(jié)構(gòu)存儲(chǔ)了服務(wù)器處理請(qǐng)求常見(jiàn)的字段。其中Handler字段也保留Hander接口。如果Server接口沒(méi)有提供Handler結(jié)構(gòu)對(duì)象,那么會(huì)使用DefaultServeMux做Multiplexer。

創(chuàng)建HTTP服務(wù)

??? 創(chuàng)建一個(gè)http服務(wù),大致需要經(jīng)歷兩個(gè)過(guò)程,首先需要注冊(cè)路由,即提供url模式和handler函數(shù)的映射,其次就是實(shí)例化一個(gè)server對(duì)象,并開(kāi)啟對(duì)客戶(hù)端的監(jiān)聽(tīng)。

http.HandleFunc("/", indexHandler)
http.ListenAndServe("127.0.0.1:8000", nil)
 
或者:
 
server := &Server{Addr: addr, Handler: handler}
 
server.ListenAndServe()

http注冊(cè)路由

? ? net/http包暴露的注冊(cè)路由的api很簡(jiǎn)單,http.HandleFunc選取了DefaultServeMux作為multiplexer:

func HandleFunc(pattern string, handler func(ResponseWriter, *Request)) {
    DefaultServeMux.HandleFunc(pattern, handler)
}

???實(shí)際上,DefaultServeMux是ServeMux的一個(gè)實(shí)例。當(dāng)然http包也提供了NewServeMux方法創(chuàng)建一個(gè)ServeMux實(shí)例,默認(rèn)則創(chuàng)建一個(gè)DefaultServeMux:

// NewServeMux allocates and returns a new ServeMux.
func NewServeMux() *ServeMux {
    return new(ServeMux)
}
 
// DefaultServeMux is the default ServeMux used by Serve.
var DefaultServeMux = &defaultServeMux
 
var defaultServeMux ServeMux

???注意,go創(chuàng)建實(shí)例的過(guò)程中,也可以使用指針?lè)绞?,?/p>

   type Server struct{}
   server := Server{}

? ?和下面的一樣都可以創(chuàng)建Server的實(shí)例

 var DefaultServer Server
  var server = &DefalutServer

???因此DefaultServeMux的HandleFunc(pattern,handler)方法實(shí)際是定義在ServeMux下的:

func (mux *ServeMux) HandleFunc(pattern string, handler func(ResponseWriter, *Request)) {
    mux.Handle(pattern, HandlerFunc(handler))
}

???上述代碼中,HandlerFunc是一個(gè)函數(shù)類(lèi)型。同時(shí)實(shí)現(xiàn)了Handler接口的ServeHTTP方法。使用HandlerFunc類(lèi)型包裝一下路由定義的indexHandler函數(shù),其目的就是為了讓這個(gè)函數(shù)也實(shí)現(xiàn)ServeHTTP方法,即轉(zhuǎn)變成一個(gè)handler處理器(函數(shù))。

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

???一旦這樣做了,就意味著我們的indexHandler函數(shù)也有了ServeHTTP方法。
? ?此外,ServeMux的Handle方法,將會(huì)對(duì)pattern和handler函數(shù)做一個(gè)map映射:

func (mux *ServeMux) Handle(pattern string, handler Handler) {
    mux.mu.Lock()
    defer mux.mu.Unlock()
 
    if pattern == "" {
        panic("http: invalid pattern " + pattern)
    }
    if handler == nil {
        panic("http: nil handler")
    }
    if mux.m[pattern].explicit {
        panic("http: multiple registrations for " + pattern)
    }
 
    if mux.m == nil {
        mux.m = make(map[string]muxEntry)
    }
    mux.m[pattern] = muxEntry{explicit: true, h: handler, pattern: pattern}
 
    if pattern[0] != '/' {
        mux.hosts = true
    }
 
    n := len(pattern)
    if n > 0 && pattern[n-1] == '/' && !mux.m[pattern[0:n-1]].explicit {
 
        path := pattern
        if pattern[0] != '/' {
            path = pattern[strings.Index(pattern, "/"):]
        }
        url := &url.URL{Path: path}
        mux.m[pattern[0:n-1]] = muxEntry{h: RedirectHandler(url.String(), StatusMovedPermanently), pattern: pattern}
    }
}

???由此可見(jiàn),Handle函數(shù)的主要目的在于把handler和pattern模式綁定到map[string]muxEntry的map上,其中muxEntry保存了更多pattern和handler的信息。Server的m字段就是map[string]muxEntry這樣一個(gè)map。
? ?此時(shí),pattern和handler的路由注冊(cè)完成。

開(kāi)啟監(jiān)聽(tīng)

? ? 注冊(cè)好路由之后,啟動(dòng)web服務(wù)還需要開(kāi)啟服務(wù)器監(jiān)聽(tīng)。http的ListenAndServer方法中可以看到創(chuàng)建了一個(gè)Server對(duì)象,并調(diào)用了Server對(duì)象的同名方法:

func ListenAndServe(addr string, handler Handler) error {
    server := &Server{Addr: addr, Handler: handler}
    return server.ListenAndServe()
}
 
func (srv Server) ListenAndServe() error {
    addr := srv.Addr
    if addr == "" {
        addr = ":http"
    }
    ln, err := net.Listen("tcp", addr)
    if err != nil {
        return err
    }
    return srv.Serve(tcpKeepAliveListener{ln.(net.TCPListener)})
}

???Server的ListenAndServer方法中,會(huì)初始化監(jiān)聽(tīng)地址Addr,同時(shí)調(diào)用Listen方法設(shè)置監(jiān)聽(tīng)。最后將監(jiān)聽(tīng)的TCP對(duì)象傳入Serve方法:

func (srv *Server) Serve(l net.Listener) error {
    defer l.Close()
    ...
 
    baseCtx := context.Background()
    ctx := context.WithValue(baseCtx, ServerContextKey, srv)
    ctx = context.WithValue(ctx, LocalAddrContextKey, l.Addr())
    for {
        rw, e := l.Accept()
        ...
        c := srv.newConn(rw)
        c.setState(c.rwc, StateNew) // before Serve can return
        go c.serve(ctx)
    }
}

處理請(qǐng)求

???監(jiān)聽(tīng)開(kāi)啟之后,一旦客戶(hù)端請(qǐng)求到底,go就開(kāi)啟一個(gè)協(xié)程處理請(qǐng)求,主要邏輯都在server方法之中。

? ?serve方法比較長(zhǎng),其主要職能就是,創(chuàng)建一個(gè)上下文對(duì)象,然后調(diào)用Listener的Accept方法用來(lái)獲取連接數(shù)據(jù)并使用newConn方法創(chuàng)建連接對(duì)象。最后使用goroutein協(xié)程的方式處理連接請(qǐng)求。因此每一個(gè)連接都開(kāi)啟了一個(gè)協(xié)程,請(qǐng)求的上下文都不同,同時(shí)又保證了go的高并發(fā)。serve也是一個(gè)長(zhǎng)長(zhǎng)的方法:

func (c *conn) serve(ctx context.Context) {
    c.remoteAddr = c.rwc.RemoteAddr().String()
    defer func() {
        if err := recover(); err != nil {
            const size = 64 << 10
            buf := make([]byte, size)
            buf = buf[:runtime.Stack(buf, false)]
            c.server.logf("http: panic serving %v: %v\n%s", c.remoteAddr, err, buf)
        }
        if !c.hijacked() {
            c.close()
            c.setState(c.rwc, StateClosed)
        }
    }()
 
    ...
 
    for {
        w, err := c.readRequest(ctx)
        if c.r.remain != c.server.initialReadLimitSize() {
            // If we read any bytes off the wire, we're active.
            c.setState(c.rwc, StateActive)
        }
        ...
        
        }
        
        ...
    
        serverHandler{c.server}.ServeHTTP(w, w.req)
        w.cancelCtx()
        if c.hijacked() {
            return
        }
        w.finishRequest()
        if !w.shouldReuseConnection() {
            if w.requestBodyLimitHit || w.closedRequestBodyEarly() {
                c.closeWriteAndWait()
            }
            return
        }
        c.setState(c.rwc, StateIdle)
    }
}

???盡管serve很長(zhǎng),里面的結(jié)構(gòu)和邏輯還是很清晰的,使用defer定義了函數(shù)退出時(shí),連接關(guān)閉相關(guān)的處理。然后就是讀取連接的網(wǎng)絡(luò)數(shù)據(jù),并處理讀取完畢時(shí)候的狀態(tài)。接下來(lái)就是調(diào)用serverHandler{c.server}.ServeHTTP(w,w.req)方法處理請(qǐng)求了。最后就是請(qǐng)求處理完畢的邏輯。serverHandler是一個(gè)重要的結(jié)構(gòu),它僅有一個(gè)字段,即Server結(jié)構(gòu),同時(shí)它也實(shí)現(xiàn)了Hander接口方法ServeHTTP,同時(shí)它也實(shí)現(xiàn)了Handler接口方法ServeHTTP,并在該接口方法中做了一個(gè)重要的事情,初始化multiplexer路由多路復(fù)用器。如果server對(duì)象沒(méi)有制定Handler,則使用默認(rèn)的DefaultServeMux作為路由Multiplexer。并調(diào)用初始化Handler的ServeHTTP方法。

type serverHandler struct {
    srv *Server
}
 
func (sh serverHandler) ServeHTTP(rw ResponseWriter, req Request) {
    handler := sh.srv.Handler
    if handler == nil {
        handler = DefaultServeMux
    }
    if req.RequestURI == "" && req.Method == "OPTIONS" {
        handler = globalOptionsHandler{}
    }
    handler.ServeHTTP(rw, req)
}

???這里DefaultServeMux的ServeHTTP方法其實(shí)也是定義在ServeMux結(jié)構(gòu)中的,相關(guān)代碼如下:

func (mux *ServeMux) (w ResponseWriter, r Request) {
    if r.RequestURI == "" {
        if r.ProtoAtLeast(1, 1) {
            w.Header().Set("Connection", "close")
        }
        w.WriteHeader(StatusBadRequest)
        return
    }
    h, _ := mux.Handler(r)
    h.ServeHTTP(w, r)
}
 
func (mux *ServeMux) Handler(r *Request) (h Handler, pattern string) {
    if r.Method != "CONNECT" {
        if p := cleanPath(r.URL.Path); p != r.URL.Path {
            _, pattern = mux.handler(r.Host, p)
            url := *r.URL
            url.Path = p
            return RedirectHandler(url.String(), StatusMovedPermanently), pattern
        }
    }
    return mux.handler(r.Host, r.URL.Path)
}
 
func (mux *ServeMux) handler(host, path string) (h Handler, pattern string) {
    mux.mu.RLock()
    defer mux.mu.RUnlock()
 
    // Host-specific pattern takes precedence over generic ones
    if mux.hosts {
        h, pattern = mux.match(host + path)
    }
    if h == nil {
        h, pattern = mux.match(path)
    }
    if h == nil {
        h, pattern = NotFoundHandler(), ""
    }
    return
}
 
func (mux *ServeMux) match(path string) (h Handler, pattern string) {
    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
}

???mux的ServeHTTP方法通過(guò)調(diào)用其Handler方法尋找注冊(cè)到路由上的handler函數(shù),并調(diào)用該函數(shù)的ServeHTTP方法。?

? ?mux的Handler方法對(duì)URL簡(jiǎn)單的處理,然后調(diào)用handler方法,后者會(huì)創(chuàng)建一個(gè)鎖,同時(shí)調(diào)用match方法返回一個(gè)handler和pattern。
? ?在match方法中,mux的m字段是map[string]muxEntry,后者存儲(chǔ)了pattern和handler處理器函數(shù),因此通過(guò)迭代m尋找出注冊(cè)路由的pattern模式與實(shí)際url匹配的handler函數(shù)并返回。
? ?返回的結(jié)構(gòu)一直傳遞到mux的ServeHTTP方法,接下來(lái)調(diào)用handler函數(shù)的ServeHTTP方法,即IndexHandler函數(shù),然后把reponse寫(xiě)到http.RequestWirter對(duì)象返回給客戶(hù)端。

? ?上述函數(shù)運(yùn)行結(jié)束即serverHandler{c.server}.ServeHTTP(w, w.req)運(yùn)行結(jié)束。接下來(lái)就是對(duì)請(qǐng)求處理完畢之后上希望和連接斷開(kāi)的相關(guān)邏輯。

? ?至此,Golang中一個(gè)完整的http服務(wù)介紹完畢,包括注冊(cè)路由,開(kāi)啟監(jiān)聽(tīng),處理連接,路由處理函數(shù)。

參考:

https://www.yuque.com/docs/share/24a1bd1c-e32d-4268-9115-bf03f53677d3

到此這篇關(guān)于golang構(gòu)建HTTP服務(wù)的實(shí)現(xiàn)步驟的文章就介紹到這了,更多相關(guān)golang構(gòu)建HTTP服務(wù)內(nèi)容請(qǐng)搜索腳本之家以前的文章或繼續(xù)瀏覽下面的相關(guān)文章希望大家以后多多支持腳本之家!

相關(guān)文章

  • Go語(yǔ)言實(shí)現(xiàn)字符串搜索算法Boyer-Moore

    Go語(yǔ)言實(shí)現(xiàn)字符串搜索算法Boyer-Moore

    Boyer-Moore?算法是一種非常高效的字符串搜索算法,被廣泛的應(yīng)用于多種字符串搜索場(chǎng)景,下面我們就來(lái)學(xué)習(xí)一下如何利用Go語(yǔ)言實(shí)現(xiàn)這一字符串搜索算法吧
    2023-11-11
  • 一文帶你使用Golang實(shí)現(xiàn)SSH客戶(hù)端

    一文帶你使用Golang實(shí)現(xiàn)SSH客戶(hù)端

    SSH?全稱(chēng)為?Secure?Shell,是一種用于安全地遠(yuǎn)程登錄到網(wǎng)絡(luò)上的其他計(jì)算機(jī)的網(wǎng)絡(luò)協(xié)議,本文主要為大家詳細(xì)介紹了如何使用?Golang?實(shí)現(xiàn)?SSH?客戶(hù)端,需要的可以參考下
    2023-11-11
  • Gin框架中異步任務(wù)的實(shí)現(xiàn)

    Gin框架中異步任務(wù)的實(shí)現(xiàn)

    Gin框架中的異步任務(wù)處理是指在Web應(yīng)用中以非阻塞的方式處理耗時(shí)操作或后臺(tái)任務(wù),文中通過(guò)示例代碼介紹的非常詳細(xì),對(duì)大家的學(xué)習(xí)或者工作具有一定的參考學(xué)習(xí)價(jià)值,需要的朋友們下面隨著小編來(lái)一起學(xué)習(xí)學(xué)習(xí)吧
    2024-11-11
  • 使用Go實(shí)現(xiàn)一個(gè)百行聊天服務(wù)器的示例代碼

    使用Go實(shí)現(xiàn)一個(gè)百行聊天服務(wù)器的示例代碼

    前段時(shí)間, redis作者整了個(gè)c語(yǔ)言版本的聊天服務(wù)器,代碼量攏共不過(guò)百行,于是, 心血來(lái)潮下, 我也整了個(gè)Go語(yǔ)言版本, 簡(jiǎn)單來(lái)說(shuō)就是實(shí)現(xiàn)了一個(gè)聊天室的功能,文中通過(guò)代碼示例給大家介紹的非常詳細(xì),需要的朋友可以參考下
    2023-12-12
  • Golang壓縮Jpeg圖片和PNG圖片的操作

    Golang壓縮Jpeg圖片和PNG圖片的操作

    這篇文章主要介紹了Golang壓縮Jpeg圖片和PNG圖片的操作,具有很好的參考價(jià)值,希望對(duì)大家有所幫助。一起跟隨小編過(guò)來(lái)看看吧
    2020-12-12
  • Go編寫(xiě)定時(shí)器與定時(shí)任務(wù)詳解(附第三方庫(kù)gocron用法)

    Go編寫(xiě)定時(shí)器與定時(shí)任務(wù)詳解(附第三方庫(kù)gocron用法)

    當(dāng)需要每天執(zhí)行定時(shí)任務(wù)的時(shí)候就需要定時(shí)器來(lái)處理了,周期任務(wù),倒計(jì)時(shí)任務(wù),定點(diǎn)任務(wù)等,下面這篇文章主要給大家介紹了關(guān)于Go編寫(xiě)定時(shí)器與定時(shí)任務(wù)的相關(guān)資料,文中通過(guò)實(shí)例代碼介紹的非常詳細(xì),需要的朋友可以參考下
    2022-07-07
  • golang網(wǎng)絡(luò)通信超時(shí)設(shè)置方式

    golang網(wǎng)絡(luò)通信超時(shí)設(shè)置方式

    這篇文章主要介紹了golang網(wǎng)絡(luò)通信超時(shí)設(shè)置方式,具有很好的參考價(jià)值,希望對(duì)大家有所幫助。一起跟隨小編過(guò)來(lái)看看吧
    2020-12-12
  • Golang中的占位符詳解

    Golang中的占位符詳解

    這篇文章主要給大家詳細(xì)總結(jié)了Golang中的占位符用法,文章通過(guò)代碼示例介紹的非常詳細(xì),對(duì)我們學(xué)習(xí)Golang占位符有一定的幫助,需要的朋友可以參考下
    2023-07-07
  • golang?db事務(wù)的統(tǒng)一封裝的實(shí)現(xiàn)

    golang?db事務(wù)的統(tǒng)一封裝的實(shí)現(xiàn)

    這篇文章主要介紹了golang db事務(wù)的統(tǒng)一封裝的實(shí)現(xiàn),文中通過(guò)示例代碼介紹的非常詳細(xì),具有一定的參考價(jià)值,感興趣的小伙伴們可以參考一下
    2021-12-12
  • 詳解Go語(yǔ)言中的結(jié)構(gòu)體的特性

    詳解Go語(yǔ)言中的結(jié)構(gòu)體的特性

    結(jié)構(gòu)體是Go語(yǔ)言中重要且靈活的概念之一,本文旨在深入介紹Go語(yǔ)言中的結(jié)構(gòu)體,揭示其重要性和靈活性,并向讀者展示結(jié)構(gòu)體支持的眾多特性,需要的可以參考一下
    2023-06-06

最新評(píng)論

江阴市| 杨浦区| 凭祥市| 临邑县| 汉源县| 全州县| 安多县| 吉木乃县| 平罗县| 长垣县| 三江| 大关县| 稷山县| 嘉义市| 荆门市| 岗巴县| 佳木斯市| 彭阳县| 丰镇市| 措美县| 龙江县| 临朐县| 荔波县| 忻州市| 馆陶县| 延寿县| 沙洋县| 万全县| 开化县| 砚山县| 边坝县| 揭东县| 清远市| 大田县| 新丰县| 西峡县| 旺苍县| 莫力| 交口县| 连南| 武城县|