Golang echo web框架中路由拦截、操作结果进行日志记录

路由拦截:用于登录者身份、访问资源权限校验
日志记录:记录登陆者所操作资源的请求路径、参数、操作结果等日志,如:新增、删除、审核等操作

• main.go

package main
import (
 "context"
 "github.com/labstack/echo"
 "github.com/labstack/echo/middleware"
 "net/http"
 "os"
 "os/signal"
 "strings"
 "time"
)
func main() {
 e := echo.New()
 e.Use(middleware.Recover())
 e.Use(middleware.RequestID())
 e.Use(middleware.Secure())
 e.Use(middleware.GzipWithConfig(middleware.GzipConfig{
 Skipper: GzipDefaultSkipper,
 Level: 5,
 }))
 e.Use(middleware.BodyDumpWithConfig(DefaultBodyDumpConfig))
 api := e.Group("/api", Filter)
 {
 api.GET("/test", Test)
 api.POST("/files/upload/multi", UploadFile)
 api.POST("/img/code", ImageCode)
 }
 port := ":8080"
 go func() {
 if err := e.Start(port); err != nil {
 e.Logger.Info("shutting down the server")
 }
 }()
 // Wait for interrupt signal to gracefully shutdown the server with
 // a timeout of 10 seconds.
 quit := make(chan os.Signal)
 signal.Notify(quit, os.Interrupt)
 <-quit
 ctx, cancel := context.WithTimeout(context.Background(), 10*time.Second)
 defer cancel()
 if err := e.Shutdown(ctx); err != nil {
 e.Logger.Fatal(err)
 }
}
func Filter(next echo.HandlerFunc) echo.HandlerFunc {
 return func(c echo.Context) error {
 // 路由拦截 - 登录身份、资源权限判断等
 println("Api路由拦截:", c.Path())
 return next(c)
 }
}
func Test(c echo.Context) error {
 return c.JSON(http.StatusOK, map[string]interface{}{
 "code": "200",
 "msg": "请求成功",
 "data": "test",
 })
}
func ImageCode(c echo.Context) error {
 return c.JSON(http.StatusOK, map[string]interface{}{
 "code": "200",
 "msg": "加载成功",
 "data": "123456",
 })
}
func UploadFile(c echo.Context) error {
 return c.JSON(http.StatusOK, map[string]interface{}{
 "code": "200",
 "msg": "上传成功",
 "data": nil,
 })
}
// gzip 排除动态资源,如:图形验证码
func GzipDefaultSkipper(c echo.Context) bool {
 if c.Path() == "/api/img/code" {
 return true
 }
 return false
}
var DefaultBodyDumpConfig = middleware.BodyDumpConfig{
 Skipper: BodyDumpDefaultSkipper,
 Handler: func(c echo.Context, reqBody []byte, resBody []byte) {
 println("API请求结果拦截:", string(resBody))
 // 1、解析返回的json数据,判断接口执行成功或失败。如: {"code":"200","data":"test","msg":"请求成功"}
 // 2、保存操作日志
 },
}
// 排除文件,如果您的请求/响应有效负载非常大,例如文件上载/下载,需要进行排查。否则将影响响应时间
func BodyDumpDefaultSkipper(c echo.Context) bool {
 if strings.Contains(c.Path(), "/api/files/") {
 return true
 }
 return false
}

• 运行

go run main.go

• 浏览器访问

http://127.0.0.1:8080/api/test

• 结果打印:

 ____ __
 / __/___/ / ___
 / _// __/ _ \/ _ \
/___/\__/_//_/\___/ v4.1.10
High performance, minimalist Go web framework
https://echo.labstack.com
____________________________________O/_______
 O\
⇨ http server started on [::]:8080
Api路由拦截: /api/test
API请求结果拦截: {"code":"200","data":"test","msg":"请求成功"}

有疑问加站长微信联系(非本文作者)

• 请尽量让自己的回复能够对别人有帮助
• 支持 Markdown 格式, **粗体**、~~删除线~~、`单行代码`
• 支持 @ 本站用户;支持表情(输入 : 提示),见 Emoji cheat sheet
• 图片支持拖拽、截图粘贴等方式上传