自定义服务调用中间件
1. 准备工作
- 已安装 dubbo-go cli 工具和依赖工具
- 阅读 [组件加载和扩展性]
- 创建一个新的演示应用
2. 配置指定的过滤器
指定过滤器时，可以使用“,”分隔
消费者端
dubbo: consumer: filter: echo,token,tps,myCustomFilter # Custom filter can be specified提供者端
dubbo: provider: services: GreeterProvider: filter: myCustomFilter, echo, tps
3. 自定义过滤器
用户可以在代码中自定义过滤器，将其注册到框架上，并在配置中选择使用。
func init() {
extension. SetFilter("myCustomFilter", NewMyClientFilter)
}
func NewMyClientFilter() filter. Filter {
return &MyClientFilter{}
}
type MyClientFilter struct {
}
func (f *MyClientFilter) Invoke(ctx context.Context, invoker protocol.Invoker, invocation protocol.Invocation) protocol.Result {
fmt.Println("MyClientFilter Invoke is called, method Name = ", invocation.MethodName())
return invoker. Invoke(ctx, invocation)
}
func (f *MyClientFilter) OnResponse(ctx context.Context, result protocol.Result, invoker protocol.Invoker, protocol protocol.Invocation) protocol.Result {
fmt.Println("MyClientFilter OnResponse is called")
return result
}
上次修改时间：2024 年 1 月 17 日: 修复损坏的链接 (6651e217e73)
