关于golang:聊聊dubbogoproxy的authorityFilter

7次阅读

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

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

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

func Init() {extension.SetFilterFunc(constant.HTTPAuthorityFilter, authorityFilterFunc())
}

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

// authorityFilter is a filter for blacklist/whitelist.
type authorityFilter struct {
}

// New create blacklist/whitelist filter.
func New() filter.Filter {return &authorityFilter{}
}

authorityFilter 往 extension 设置了名为 dgp.filters.http.authority_filter 的 authorityFilterFunc；该 func 执行的是 authorityFilter.Do 办法

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

// Do execute blacklist/whitelist filter logic.
func (f authorityFilter) Do() context.FilterFunc {return func(c context.Context) {f.doAuthorityFilter(c.(*http.HttpContext))
    }
}

Do 办法执行的是 doAuthorityFilter 办法

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

func (f authorityFilter) doAuthorityFilter(c *http.HttpContext) {
    for _, r := range c.HttpConnectionManager.AuthorityConfig.Rules {item := c.GetClientIP()
        if r.Limit == model.App {item = c.GetApplicationName()
        }

        result := passCheck(item, r)
        if !result {c.WriteWithStatus(nh.StatusForbidden, constant.Default403Body)
            c.Abort()
            return
        }
    }

    c.Next()}

doAuthorityFilter 办法遍历 AuthorityConfig 的 Rules，挨个执行 passCheck 判断

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

func passCheck(item string, rule model.AuthorityRule) bool {
    result := false
    for _, it := range rule.Items {
        if it == item {
            result = true
            break
        }
    }

    if (rule.Strategy == model.Blacklist && result == true) || (rule.Strategy == model.Whitelist && result == false) {return false}

    return true
}