聊聊dubbo-go-proxy的recoveryFilter


本文摘自网络,作者,侵删。

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

recoveryFilter

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

func Init() {
    extension.SetFilterFunc(constant.RecoveryFilter, recoveryFilterFunc())
}

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

// recoveryFilter is a filter for recover.
type recoveryFilter struct {
}

// New create timeout filter.
func New() filter.Filter {
    return &recoveryFilter{}
}
recoveryFilter往extension注册名为dgp.filters.recovery的recoveryFilterFunc;该func执行的是recoveryFilter的Do方法

Do

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

// Recovery execute recoveryFilter filter logic, if recover happen, print log or do other things.
func (f recoveryFilter) Do() context.FilterFunc {
    return func(c context.Context) {
        defer func() {
            if err := recover(); err != nil {
                logger.Warnf("[dubboproxy go] error:%+v", err)

                c.WriteErr(err)
            }
        }()
        c.Next()
    }
}
Do方法先注册一个defer func进行recover,然后再执行c.Next()

小结

dubbo-go-proxy的recoveryFilter注册一个defer func进行recover,然后再执行c.Next()。

doc

  • dubbo-go-proxy

本文来自:51CTO博客

感谢作者:mb6018ead621887

查看原文:聊聊dubbo-go-proxy的recoveryFilter

相关阅读 >>

17 Golang结构体详解(三)

Golang反向代理无法访问

Goroutine轻量的秘密

Golang令牌桶实现 [Go-rate] 速率限制器

Golang 是什么写的

Golang中的错误处理方法

Go get命令详解

Golang学习笔记--unsafe.pointer和uintptr

Golang判断js文件是否存在

Golang环境怎么安装

更多相关阅读请进入《Go》频道 >>




打赏

取消

感谢您的支持,我会继续努力的!

扫码支持
扫码打赏,您说多少就多少

打开支付宝扫一扫,即可进行扫码打赏哦

分享从这里开始,精彩与您同在

评论

管理员已关闭评论功能...