关于golang:聊聊dubbogoproxy的loggerFilter

序

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

loggerFilter

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

// nolintfunc 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办法

Do

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

// Logger logger filter, print url and latencyfunc (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。

doc

• dubbo-go-proxy