聊聊dubbo-go-proxy的loggerFilter

時間 2021-06-21

標籤 git github url 日誌 code get dubbo request 欄目 Dubbo 简体版

原文原文鏈接

序

本文主要研究一下dubbo-go-proxy的loggerFiltergit

loggerFilter

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

// 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方法

Do

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

// 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。日誌