前言
都說(shuō)go標(biāo)準(zhǔn)庫(kù)實(shí)用,Api設(shè)計(jì)簡(jiǎn)潔。這次就用go 標(biāo)準(zhǔn)庫(kù)中的net/http包實(shí)現(xiàn)一個(gè)簡(jiǎn)潔的http web服務(wù)器,包括三種版本。
v1最簡(jiǎn)單版
直接使用http.HandleFunc(partern,function(http.ResponseWriter,*http.Request){})
HandleFunc接受兩個(gè)參數(shù),第一個(gè)為路由地址,第二個(gè)為處理方法。
//v1 func main() { http.HandleFunc("/", func(w http.ResponseWriter, r *http.Request) { w.Write([]byte("httpserver v1")) }) http.HandleFunc("/bye", sayBye) log.Println("Starting v1 server ...") log.Fatal(http.ListenAndServe(":1210", nil)) } func sayBye(w http.ResponseWriter, r *http.Request) { w.Write([]byte("bye bye ,this is v1 httpServer")) }
v2自定義Handler
查看標(biāo)準(zhǔn)庫(kù)源碼,v1版本實(shí)際上是調(diào)用了handle方法,傳入的HandlerFunc實(shí)現(xiàn)了Handler的ServeHTTP方法,實(shí)際上是ServeHTTP在做http請(qǐng)求處理。
HandleFunc調(diào)用.png
HandleFunc實(shí)現(xiàn)Handler.png
Handler接口定義.png
由此我們可以自定義自己的Handler,v2版本代碼如下:
// v2 func main() { mux := http.NewServeMux() mux.Handle("/", myHandler{}) mux.HandleFunc("/bye", sayBye) log.Println("Starting v2 httpserver") log.Fatal(http.ListenAndServe(":1210", mux)) } type myHandler struct{} func (*myHandler) ServeHTTP(w http.ResponseWriter, r *http.Request) { w.Write([]byte("this is version 2")) } func sayBye(w http.ResponseWriter, r *http.Request) { w.Write([]byte("bye bye ,this is v2 httpServer")) }
v3自定義server配置
前面對(duì)Handler開了一次刀,下面我們看看http.ListenAndServe()中有些什么秘密。
ListenAndServe.png
原來(lái)這里可以自定義http服務(wù)器配置,都在Server這個(gè)結(jié)構(gòu)體中,這個(gè)對(duì)象能配置監(jiān)聽地址端口,配置讀寫超時(shí)時(shí)間,配置handler,配置請(qǐng)求頭最大字節(jié)數(shù)...,所有稍微改造一下v2的程序得到v3版:
// v3 func main() { mux := http.NewServeMux() mux.Handle("/", myHandler{}) mux.HandleFunc("/bye", sayBye) server := http.Server{ Addr: ":1210", WriteTimeout: time.Second * 3, //設(shè)置3秒的寫超時(shí) Handler: mux, } log.Println("Starting v3 httpserver") log.Fatal(server.ListenAndServe()) } type myHandler struct{} func (*myHandler) ServeHTTP(w http.ResponseWriter, r *http.Request) { w.Write([]byte("this is version 3")) } func sayBye(w http.ResponseWriter, r *http.Request) { // 睡眠4秒 上面配置了3秒寫超時(shí),所以訪問 “/bye“路由會(huì)出現(xiàn)沒有響應(yīng)的現(xiàn)象 time.Sleep(4 * time.Second) w.Write([]byte("bye bye ,this is v3 httpServer")) }
拓展一下(如何平滑關(guān)閉http服務(wù))
在go1.8中新增了一個(gè)新特性,利用Shutdown(ctx context.Context) 優(yōu)雅地關(guān)閉http服務(wù)。
文檔中描述:
Shutdown 將無(wú)中斷的關(guān)閉正在活躍的連接,然后平滑的停止服務(wù)。處理流程如下:
利用這個(gè)特性改造一下v3版本的程序,實(shí)現(xiàn)一個(gè)關(guān)閉http的提示
// 主動(dòng)關(guān)閉服務(wù)器 var server *http.Server func main() { // 一個(gè)通知退出的chan quit := make(chan os.Signal) signal.Notify(quit, os.Interrupt) mux := http.NewServeMux() mux.Handle("/", myHandler{}) mux.HandleFunc("/bye", sayBye) server = http.Server{ Addr: ":1210", WriteTimeout: time.Second * 4, Handler: mux, } go func() { // 接收退出信號(hào) -quit if err := server.Close(); err != nil { log.Fatal("Close server:", err) } }() log.Println("Starting v3 httpserver") err := server.ListenAndServe() if err != nil { // 正常退出 if err == http.ErrServerClosed { log.Fatal("Server closed under request") } else { log.Fatal("Server closed unexpected", err) } } log.Fatal("Server exited") } type myHandler struct{} func (*myHandler) ServeHTTP(w http.ResponseWriter, r *http.Request) { w.Write([]byte("this is version 3")) } // 關(guān)閉http func sayBye(w http.ResponseWriter, r *http.Request) { w.Write([]byte("bye bye ,shutdown the server")) // 沒有輸出 err := server.Shutdown(nil) if err != nil { log.([]byte("shutdown the server err")) } }
嘗試訪問 http://localhost:1210/bye 在控制臺(tái)會(huì)得到以下提示結(jié)果,平滑關(guān)閉http服務(wù)成功:
成功平滑關(guān)閉.png
到此這篇關(guān)于詳解Golang開啟http服務(wù)的三種方式的文章就介紹到這了,更多相關(guān)Golang開啟http服務(wù)內(nèi)容請(qǐng)搜索腳本之家以前的文章或繼續(xù)瀏覽下面的相關(guān)文章希望大家以后多多支持腳本之家!
標(biāo)簽:太原 阿克蘇 貴陽(yáng) 慶陽(yáng) 西雙版納 廣西 調(diào)研邀請(qǐng) 德州
巨人網(wǎng)絡(luò)通訊聲明:本文標(biāo)題《詳解Golang開啟http服務(wù)的三種方式》,本文關(guān)鍵詞 詳解,Golang,開啟,http,服務(wù),;如發(fā)現(xiàn)本文內(nèi)容存在版權(quán)問題,煩請(qǐng)?zhí)峁┫嚓P(guān)信息告之我們,我們將及時(shí)溝通與處理。本站內(nèi)容系統(tǒng)采集于網(wǎng)絡(luò),涉及言論、版權(quán)與本站無(wú)關(guān)。