关于golang:聊聊dubbogoproxy的hostFilter

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

hostFilter

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

// hostFilter is a filter for host.
type hostFilter struct {
    host string
}

// New create host filter.
func New(host string) filter.Filter {
    return &hostFilter{host: host}
}

hostFilter的New依据host创立hostFilter

Do

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

func (f hostFilter) Do() fc.FilterFunc {
    return func(c fc.Context) {
        f.doHostFilter(c.(*contexthttp.HttpContext))
    }
}

func (f hostFilter) doHostFilter(c *contexthttp.HttpContext) {
    c.Request.Host = f.host
    c.Next()
}

Do办法执行doHostFilter办法,该办法将f.host设置给c.Request.Host,而后执行c.Next()

httpFilter

dubbo-go-proxy/pkg/proxy/listener.go

func httpFilter(ctx *h.HttpContext, request fc.IntegrationRequest) {
    if len(request.Host) != 0 {
        ctx.AppendFilterFunc(host.New(request.Host).Do())
    }
    if len(request.Path) != 0 {
        ctx.AppendFilterFunc(replacepath.New(request.Path).Do())
    }
}

httpFilter办法通过AppendFilterFunc将host.New(request.Host)追加到Filters中

小结

dubbo-go-proxy的hostFilter将f.host设置给c.Request.Host,而后执行c.Next()。

doc

  • dubbo-go-proxy

评论

发表回复

您的邮箱地址不会被公开。 必填项已用 * 标注

这个站点使用 Akismet 来减少垃圾评论。了解你的评论数据如何被处理