dubbo系列6、SPI擴展Filter隱式傳參

1、實現Filter接口

一、消費者過濾器:ConsumerTraceFilter.java

package com.dubbo.demo.Filter; import com.alibaba.dubbo.rpc.*; import java.util.Map; import java.util.UUID; public class ConsumerTraceFilter implements Filter { @Override public Result invoke(Invoker<?> invoker, Invocation invocation) throws RpcException { Map<String, String> stringStringMap = invocation.getAttachments(); // 設置參數
        stringStringMap.put("patentId","0"); stringStringMap.put("traceId",UUID.randomUUID().toString()); System.out.println("生成tradeId:"+stringStringMap.get("traceId")); return invoker.invoke(invocation); } }

二、生產者過濾器:ProviderTraceFilter.java

package com.dubbo.demo.Filter; import com.alibaba.dubbo.rpc.*; import java.util.Map; public class ProviderTraceFilter implements Filter { public Result invoke(Invoker<?> invoker, Invocation invocation) throws RpcException { Map<String, String> stringStringMap = invocation.getAttachments(); // 接收參數
        System.out.println("收到：patentId:"+stringStringMap.get("patentId")); System.out.println("收到：tradeId:"+stringStringMap.get("traceId")); return invoker.invoke(invocation); } }

2、配置SPI Filter擴展文件

一、生產者配置

在目錄：resources/META-INF/dubbo/ 建立com.alibaba.dubbo.rpc.Filter（純文本文件.txt）

內容：

traceFilter=com.dubbo.demo.Filter.ProviderTraceFilter

二、消費者配置

在目錄：resources/META-INF/dubbo/ 建立com.alibaba.dubbo.rpc.Filter（純文本文件.txt）

內容：

traceFilter=com.dubbo.demo.Filter.ConsumerTraceFilter

3、配置dubbo文件

一、生產者

<?xml version="1.0" encoding="UTF-8"?>
<beans xmlns="http://www.springframework.org/schema/beans" xmlns:xsi="http://www.w3.org/2001/XMLSchema-instance" xmlns:dubbo="http://code.alibabatech.com/schema/dubbo" xsi:schemaLocation="http://www.springframework.org/schema/beans http://www.springframework.org/schema/beans/spring-beans.xsd http://code.alibabatech.com/schema/dubbo http://code.alibabatech.com/schema/dubbo/dubbo.xsd">

    <!--過濾器配置-->
    <dubbo:provider filter="traceFilter" />
     <!--dubbo應用程序命名-->
    <dubbo:application name="dubbo-demo-provider"/>
    <!--dubbo註冊地址-->
    <dubbo:registry address="zookeeper://192.168.1.100:2181"/>
    <!--dubbo協議地址-->
    <dubbo:protocol name="dubbo" port="20880"/>
    <!--接口聲明-->
    <dubbo:service interface="com.dubbo.demo.api.DemoRpcService" ref="demoRpcService"/>
        <bean id="demoRpcService" class="com.dubbo.demo.DemoRpcServiceImpl"/>
    </beans>

二、消費者

<?xml version="1.0" encoding="UTF-8"?>
<beans xmlns="http://www.springframework.org/schema/beans" xmlns:xsi="http://www.w3.org/2001/XMLSchema-instance" xmlns:dubbo="http://code.alibabatech.com/schema/dubbo" xsi:schemaLocation="http://www.springframework.org/schema/beans http://www.springframework.org/schema/beans/spring-beans.xsd http://code.alibabatech.com/schema/dubbo http://code.alibabatech.com/schema/dubbo/dubbo.xsd">

    <!--過濾器配置-->
    <dubbo:consumer filter="traceFilter" />

    <!--dubbo應用程序命名-->
    <dubbo:application name="dubbo-demo-provider"/>
    <!--dubbo註冊地址-->
    <dubbo:registry address="zookeeper://192.168.1.100:2181"/>
    <!--接口引用-->
    <dubbo:reference interface="com.dubbo.demo.api.DemoRpcService" id="demoRpcService"/>
</beans>

 

4、驗證

依次啓動生產者、消費者發起遠程調用

 

 

 示例代碼：

https://github.com/Star-Lordxing/dubbo-demo