首页  

dubbo 自定义 filter 实例     所属分类 dubbo 浏览量 947
Filter
ProtocolFilterWrapper Filter链

原生的Filter

ConsumerContextFilter  Consumer上下文传递

自定义filter

@Activate(group = {Constants.PROVIDER, Constants.CONSUMER})
public class DubboHelloFilter implements Filter

META-INF/dubbo/com.alibaba.dubbo.rpc.Filter
hello=dyyx.DubboHelloFilter



import com.alibaba.dubbo.common.Constants;
import com.alibaba.dubbo.common.extension.Activate;
import com.alibaba.dubbo.rpc.Filter;
import com.alibaba.dubbo.rpc.Invocation;
import com.alibaba.dubbo.rpc.Invoker;
import com.alibaba.dubbo.rpc.Result;
import com.alibaba.dubbo.rpc.RpcException;

@Activate(group = {Constants.PROVIDER, Constants.CONSUMER})
public class DubboHelloFilter implements Filter{
    
    public DubboHelloFilter() {
        System.out.println("DubboHelloFilter() run "+LocalDateTime.now()+"\n\n\n");
    }

    public Result invoke(Invoker<?> invoker, Invocation invocation) throws RpcException {
        long start = System.currentTimeMillis();
        Result result = invoker.invoke(invocation);
        long end = System.currentTimeMillis();
        long time = end - start;
        System.out.println("DubboHelloFilter time="+time+"\n\n\n");
        return result;
    }

}


完整代码
https://gitee.com/dyyx/dubbodemo/blob/master/dubbo-hello-filter/src/main/java/dyyx/DubboHelloFilter.java


dubbo RpcContexta attachments 实例 Dubbo Filter 顺序 dubbo 分布式追踪 traceId 传递要点

上一篇     下一篇
dubbo之RpcContext

dubbo RpcContexta attachments 实例

Dubbo Filter 顺序

TBA聊考研

springboot REST api 实例

基于 HttpURLConnection 的 http 客户端