关于golang:聊聊dubbogoproxy的loggerFilter

2次阅读

共计 1057 个字符，预计需要花费 3 分钟才能阅读完成。

本文次要钻研一下 dubbo-go-proxy 的 loggerFilter

dubbo-go-proxy/pkg/filter/logger/logger.go

// nolint
func Init() {extension.SetFilterFunc(constant.LoggerFilter, loggerFilterFunc())
}

func loggerFilterFunc() context.FilterFunc {return New().Do()}

// loggerFilter is a filter for simple logger.
type loggerFilter struct {
}

// New create logger filter.
func New() filter.Filter {return &loggerFilter{}
}

loggerFilter 的 Init 办法往 extension 设置了 loggerFilterFunc，该 context.FilterFunc 执行 loggerFilter 的 Do 办法

dubbo-go-proxy/pkg/filter/logger/logger.go

// Logger logger filter, print url and latency
func (f loggerFilter) Do() context.FilterFunc {return func(c context.Context) {start := time.Now()

        c.Next()

        latency := time.Now().Sub(start)

        logger.Infof("[dubboproxy go] [UPSTREAM] receive request | %d | %s | %s | %s |", c.StatusCode(), latency, c.GetMethod(), c.GetUrl())
    }
}

Do 办法先记录下 start，之后执行 c.Next()，最初计算 latency，最初打印下日志，输入 status code，latency、method、url

dubbo-go-proxy 的 loggerFilter 的 Init 办法往 extension 设置了 loggerFilterFunc，该 context.FilterFunc 执行 loggerFilter 的 Do 办法；Do 办法先记录下 start，之后执行 c.Next()，最初计算 latency，最初打印下日志，输入 status code，latency、method、url。