使用配置来提供服务，filter不生效

[az2az]

Environment

• Server:
• Client:
• Protocol:
• Registry:

Issue description

使用dubbo-go-samples 的config_yaml测试用例，发现使用配置文件加载filter时，不生效，而使用代码的方式加载能生效（以下代码，使用Load()可以正常使用filter，而LoadByConfig()则filter不生效）。

package main

import (
	"context"
	"errors"
	"fmt"
	"os"
	"path"
	//
	"dubbo.apache.org/dubbo-go/v3"
	"dubbo.apache.org/dubbo-go/v3/common/extension"
	"dubbo.apache.org/dubbo-go/v3/filter"
	_ "dubbo.apache.org/dubbo-go/v3/imports"
	"dubbo.apache.org/dubbo-go/v3/protocol"
	"dubbo.apache.org/dubbo-go/v3/server"
	"github.com/apache/dubbo-go-samples/go-server/proto"
)

type GreetTripleServer struct {
}

func (srv *GreetTripleServer) Greet(ctx context.Context, req *greet.GreetRequest) (*greet.GreetResponse, error) {
	name := req.Name
	if name != "ConfigTest" {
		errInfo := fmt.Sprintf("name is not right: %s", name)
		return nil, errors.New(errInfo)
	}

	resp := &greet.GreetResponse{Greeting: req.Name + "-Success"}
	return resp, nil
}

const VALIDATE_FILTER_NAME = "ValidateFilter"

type validateFilter struct{}

func (p *validateFilter) Invoke(ctx context.Context, invoker protocol.Invoker, invocation protocol.Invocation) protocol.Result {
	result := &protocol.RPCResult{}
	result.SetError(errors.New("已被过滤器拦截"))
	return result
}

func (p *validateFilter) OnResponse(ctx context.Context, result protocol.Result, invoker protocol.Invoker, invocation protocol.Invocation) protocol.Result {
	return result
}

func main() {
	LoadByConfig()
}

func Load() {
	srv, err := server.NewServer(
		server.WithServerProtocol(
			protocol.WithPort(20000),
			protocol.WithTriple(),
		),
	)
	if err != nil {
		panic(err)
	}
	//
	extension.SetFilter(VALIDATE_FILTER_NAME, func() filter.Filter {
		return &validateFilter{}
	})
	if err = greet.RegisterGreetServiceHandler(srv, &GreetTripleServer{},
		server.WithFilter(VALIDATE_FILTER_NAME),
	); err != nil {
		panic(err)
	}
	//
	if err := srv.Serve(); err != nil {
		panic(err)
	}
}

func LoadByConfig() {
	extension.SetFilter(VALIDATE_FILTER_NAME, func() filter.Filter {
		return &validateFilter{}
	})
	//
	greet.SetProviderService(&GreetTripleServer{})
	//
	s, getwdError := os.Getwd()
	if getwdError != nil {
		panic(getwdError)
	}
	configPath := path.Join(s, "/go-server/conf/dubbogo.yaml")
	//
	if err := dubbo.Load(dubbo.WithPath(configPath)); err != nil {
		panic(err)
	}
	//
	select {}
}

###############配置如下所示######################

dubbo:
  registries:
    demoZK:
      protocol: nacos
      timeout: 10s
      address: 127.0.0.1:8848
  protocols:
    tripleProtocol:
      name: tri
      port: 20000
  provider:
    services:
      GreetTripleServer:
        filter: ValidateFilter
        interface: com.apache.dubbo.sample.Greeter

Logs

Click me to check logs

Copy logs to here.

[az2az]

使用的dubbo-go版本是3.2.0-rc1。3.1.1的版本不存在此问题

[YarBor]

我查看了现有的实现，
一种可能的解决办法是，更改yaml的声明方式：

dubbo:
  registries:
    demoZK:
      protocol: nacos
      timeout: 10s
      address: 127.0.0.1:8848
  protocols:
    tripleProtocol:
      name: tri
      port: 20000
  provider:
    filter: ValidateFilter    
    services:
      GreetTripleServer:
        interface: com.apache.dubbo.sample.Greeter

[az2az]

感谢指导，确实是，调一下位置就可以了。

[AlexStocks]

这个 issue 不要 close，我已经打标 ”good first issue“

[adi-kmt]

@AlexStocks can I pick this up?

[AlexStocks]

can I pick this up?

Welcome.