利用go原生的 http 模塊,寫一個簡單的服務,然后實現以下路由中間件
一、簡單的中間件實現
package main import ( "fmt" "net/http" "time" ) func hello(wr http.ResponseWriter, r *http.Request) { wr.Write([]byte("hello")) } func timeMiddleware(next http.Handler) http.Handler { // http.HandlerFunc 將匿名函數強制轉換,為 http.Handler 的接口類型 return http.HandlerFunc(func(wr http.ResponseWriter, r *http.Request) { timeStart := time.Now() // next handler next.ServeHTTP(wr, r) timeElapsed := time.Since(timeStart) fmt.Println(timeElapsed) }) } func main() { // http.HandlerFunc(hello) 類型轉換, 給 hello 函數加上 , ServeHTTP 方法 helloHandler := http.HandlerFunc(hello); // 這里還可以加更多的中間鍵,例如 logger => http.Handle("/", logger(timeMiddleware(helloHandler))); http.Handle("/", timeMiddleware(helloHandler)); http.ListenAndServe(":8085", nil) }
以上就是一個簡易版的路由中間件,需要注意以下區別:
http.Handle 和 http.Handler
http.HandleFunc 和 http.HandlerFunc
以上寫法的缺點: 不便於維護和修改。嵌套過多,邏輯有點亂。
二、抽離一個 router 的類。
router.go 代碼如下
package router import ( "net/http" ) type middleware func (http.Handler)http.Handler type Router struct{ middlewareChain [] middleware mux map[string] http.Handler } func NewRouter() *Router { // middlewareChain 會自動初始化,map 不會自動初始化 //middlewareChain := new([]middleware); mux := map[string]http.Handler{}; return &Router{mux:mux}; } func (r *Router) Use(m middleware) { r.middlewareChain = append(r.middlewareChain,m); } func (r *Router) Add(route string, h http.Handler) { var mergedHandle = h; for i := len(r.middlewareChain)- 1; i >= 0; i--{ // 將后面的函數注入到前面的函數中 mergedHandle = r.middlewareChain[i](mergedHandle); } r.mux[route] = mergedHandle; } func (r *Router) Load () { // 遍歷將路由加入 for k,v := range r.mux{ http.Handle(k,v); } }
在 main.go 的使用如下:
package main import ( "net/http" "fmt" "time" "test_dev/play/day4/router" ) func hello(wr http.ResponseWriter, r *http.Request) { wr.Write([]byte("hello")) } func timeMiddleware(next http.Handler) http.Handler { // http.HandlerFunc 將匿名函數強制轉換,為 http.Handler 的接口類型 return http.HandlerFunc(func(wr http.ResponseWriter, r *http.Request) { // 進入時間 timeStart := time.Now() // next handler next.ServeHTTP(wr, r) // 處理結束的時間 timeElapsed := time.Since(timeStart) fmt.Println(timeElapsed) }) } func main() { helloHandler := http.HandlerFunc(hello); r := router.NewRouter(); r.Use(timeMiddleware); // r.Use(logger) r.Add("/",helloHandler); r.Load(); err := http.ListenAndServe(":8085", nil) fmt.Println(err); }
以上寫法,極大的增加中間件的靈活性。 注意:在router.go 的 Add方法里面,是倒過來遍歷的。。。這樣形成一個迭代,當路由觸發的時候,是一個 洋蔥模型 。熟悉node.js的會發現,其實這就是 koa2 的中間件核心思想。
以上寫法缺點:中間件不夠簡潔,需要自己包一層做類型轉換。
三、將類型轉換移植到 router.go 的類里面
router.go 如下
package router import ( "net/http" ) type addfunc func ( http.ResponseWriter, *http.Request ) type middleware func (http.ResponseWriter, *http.Request , http.Handler) type Router struct{ middlewareChain [] middleware mux map[string] http.Handler } func middlewareTrsfromMiddleware(m middleware,next http.Handler) http.Handler { return http.HandlerFunc(func ( res http.ResponseWriter, req *http.Request) { m(res,req,next); }); } func NewRouter() *Router { mux := map[string]http.Handler{}; return &Router{mux:mux}; } func (r *Router) Use(m middleware) { r.middlewareChain = append(r.middlewareChain,m); } func (r *Router) Add(route string, h addfunc) { // 必須要指定 mergedHandle 為 http.Handler 類型 var mergedHandle http.Handler = http.HandlerFunc(h) for i := len(r.middlewareChain)- 1; i >= 0; i--{ // 將后面的函數注入到前面的函數中 mergedHandle = middlewareTrsfromMiddleware(r.middlewareChain[i],mergedHandle); } r.mux[route] = mergedHandle; } func (r *Router) Load () { // 遍歷將路由加入 for k,v := range r.mux{ http.Handle(k,v); } }
main.go 的使用
package main import ( "net/http" "fmt" "time" "test_dev/play/day5/router" ) func hello(res http.ResponseWriter, req *http.Request ) { res.Write([]byte("hello")) } func timeMiddleware(res http.ResponseWriter, req *http.Request , next http.Handler) { // 進入時間 timeStart := time.Now() // next handler next.ServeHTTP(res, req) // 處理結束的時間 timeElapsed := time.Since(timeStart) fmt.Println(timeElapsed) } func main() { // helloHandler := http.HandlerFunc(hello); r := router.NewRouter(); r.Use(timeMiddleware); // r.Use(logger) r.Add("/",hello); r.Load(); http.ListenAndServe(":8085", nil) }
最后,臟活類活,都丟給 router.go 了,main里面已經非常簡潔和靈活。
擴展:依照現有的 洋蔥模型 可以繼續增加支持 post 、get 等方法的路由,形成一個強大的路由工具。
補充
http.Handler : 是一個 interface
type Handler interface { ServeHTTP(ResponseWriter, *Request) }
http.Handle : 是一個方法
func Handle(pattern string, handler http.Handler)
http.HandlerFunc: 是一個類型
type HandlerFunc func(ResponseWriter, *Request) // ServeHTTP calls f(w, r). func (f HandlerFunc) ServeHTTP(w ResponseWriter, r *Request) { f(w, r) }
可以看見,這個類型還有一個方法叫 ServeHTTP , 注意和 http.Handler 區分
http.HandleFunc : 是一個方法
func (mux *ServeMux) HandleFunc(pattern string, handler func(ResponseWriter, *Request))