多应用+插件架构,代码干净,二开方便,首家独创一键云编译技术,文档视频完善,免费商用码云13.8K 广告
## 中间件 ### 怎样自己写一个中间件? 比如有以下需求 - 通过该中间件去统计请求数目、状态和时间。 - 中间件把写过写回响应。 #### Server `server.go` ```go package main import ( "net/http" "strconv" "sync" "time" "github.com/labstack/echo" ) type ( Stats struct { Uptime time.Time `json:"uptime"` RequestCount uint64 `json:"requestCount"` Statuses map[string]int `json:"statuses"` mutex sync.RWMutex } ) func NewStats() *Stats { return &Stats{ Uptime: time.Now(), Statuses: make(map[string]int), } } // Process is the middleware function. func (s *Stats) Process(next echo.HandlerFunc) echo.HandlerFunc { return func(c echo.Context) error { if err := next(c); err != nil { c.Error(err) } s.mutex.Lock() defer s.mutex.Unlock() s.RequestCount++ status := strconv.Itoa(c.Response().Status) s.Statuses[status]++ return nil } } // Handle is the endpoint to get stats. func (s *Stats) Handle(c echo.Context) error { s.mutex.RLock() defer s.mutex.RUnlock() return c.JSON(http.StatusOK, s) } // ServerHeader middleware adds a `Server` header to the response. func ServerHeader(next echo.HandlerFunc) echo.HandlerFunc { return func(c echo.Context) error { c.Response().Header().Set(echo.HeaderServer, "Echo/3.0") return next(c) } } func main() { e := echo.New() // Debug mode e.Debug = true //------------------- // Custom middleware //------------------- // Stats s := NewStats() e.Use(s.Process) e.GET("/stats", s.Handle) // Endpoint to get stats // Server header e.Use(ServerHeader) // Handler e.GET("/", func(c echo.Context) error { return c.String(http.StatusOK, "Hello, World!") }) // Start server e.Logger.Fatal(e.Start(":1323")) } ``` #### 响应 *响应头* ```sh Content-Length:122 Content-Type:application/json; charset=utf-8 Date:Thu, 14 Apr 2016 20:31:46 GMT Server:Echo/2.0 ``` *响应体* ```js { "uptime": "2016-04-14T13:28:48.486548936-07:00", "requestCount": 5, "statuses": { "200": 4, "404": 1 } } ```