dubbo泛化调用 小demo

Posted 2020-10-04

　　前两天刚好有个同事来问是否用过 dubbo泛化 调用，不需要通过指定配置。第一次听到的时候，还是有点懵，但觉得有意思，可以学点东西。

立马百度了，找了demo，这篇比较容易上手（http://www.cnblogs.com/lobo/p/7129119.html）。并结合 dubbo的官方文档（http://dubbo.io/user-guide/demos/%E6%B3%9B%E5%8C%96%E5%BC%95%E7%94%A8.html）写了个demo。

    provider 直接引用了 dubbo官方文档中的例子。

接口：

public interface DemoService {
    String sayHello(String name);
}

实现类：

public class DemoServiceImpl implements DemoService {
    @Override
    public String sayHello(String name) {
        return "Hello " + name;
    }
}

配置文件 provider.xml

<?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:application name="hello-world-app"  />

    <!-- 使用multicast广播注册中心暴露服务地址 -->
    <dubbo:registry address="zookeeper://127.0.0.1:2181" />
    <!--<dubbo:registry address="multicast://224.5.6.7:1234" />-->

    <!-- 用dubbo协议在20880端口暴露服务 -->
    <dubbo:protocol name="dubbo" port="20880" />

    <!-- 声明需要暴露的服务接口 -->
    <dubbo:service interface="persistence.dubbo.DemoService" ref="demoService" />

    <!-- 和本地bean一样实现服务 -->
    <bean id="demoService" class="persistence.dubbo.impl.DemoServiceImpl" />

</beans>

 

启动类：

public class Provider {

    public static void main(String[] args) throws IOException {

        ClassPathXmlApplicationContext context =
                new ClassPathXmlApplicationContext(new String[] {"classpath:provider.xml"});
//                new ClassPathXmlApplicationContext(new String[] {"thread/src/main/resources/provider.xml"});
        context.start();

        System.in.read(); // 按任意键退出
    }
}

 

结合 dubbo文档中的consumer 进行了测试，亲测可以调用成功。

然后进行 dubbo泛化调用测试。主要是通过 GenericService 来实现泛化调用。

 

 1 public class DubboServiceFactory {
 2 
 3     private ApplicationConfig application;
 4     private RegistryConfig registry;
 5 
 6     private static class SingletonHolder {
 7         private static DubboServiceFactory INSTANCE = new DubboServiceFactory();
 8     }
 9 
10     private DubboServiceFactoryDemo(){
11         Properties prop = new Properties();
12         ClassLoader loader = DubboServiceFactory.class.getClassLoader();
13 
14         try {
15             InputStream resourceAsStream = loader.getResourceAsStream("dubboconf.properties");
16             prop.load(loader.getResourceAsStream("dubboconf.properties"));
17         } catch (IOException e) {
18             e.printStackTrace();
19         }
20 
21         ApplicationConfig applicationConfig = new ApplicationConfig();
22         //这个应该对应  <dubbo:registry id="${dubbo.registry.id}"／> 的id
23         //我这里测试随意些没关系
24         applicationConfig.setName("dubbo-test");
25         //这里配置了dubbo的application信息*(demo只配置了name)*，因此demo没有额外的dubbo.xml配置文件
26         RegistryConfig registryConfig = new RegistryConfig();
27         registryConfig.setAddress("zookeeper://127.0.0.1:2181");
28 
29         this.application = applicationConfig;
30         this.registry = registryConfig;
31 
32     }
33 
34     public static DubboServiceFactoryDemo getInstance() {
35         return SingletonHolder.INSTANCE;
36     }
37 
38     public Object genericInvoke(String interfaceClass, String methodName, List<Map<String, Object>> parameters){
39 
40         ReferenceConfig<GenericService> reference = new ReferenceConfig<GenericService>();
41         reference.setApplication(application);
42         reference.setRegistry(registry);
43         reference.setInterface(interfaceClass); // 接口名
44         reference.setGeneric(true); // 声明为泛化接口
45 //        reference.setId("reportReadService");
46         //这里有version的必须注明
47 //        reference.setVersion("1.0.0.test");
48 
49         //ReferenceConfig实例很重，封装了与注册中心的连接以及与提供者的连接，
50         //需要缓存，否则重复生成ReferenceConfig可能造成性能问题并且会有内存和连接泄漏。
51         //API方式编程时，容易忽略此问题。
52         //这里使用dubbo内置的简单缓存工具类进行缓存
53 
54         ReferenceConfigCache cache = ReferenceConfigCache.getCache();
55         GenericService genericService = cache.get(reference);
56         // 用com.alibaba.dubbo.rpc.service.GenericService可以替代所有接口引用
57 
58         int len = parameters.size();
59         String[] invokeParamTyeps = new String[len];
60         Object[] invokeParams = new Object[len];
61         for(int i = 0; i < len; i++){
62             invokeParamTyeps[i] = parameters.get(i).get("ParamType") + "";
63             invokeParams[i] = parameters.get(i).get("Object");
64         }
65         return genericService.$invoke(methodName, invokeParamTyeps, invokeParams);
66     }
67 
68 }

 

注：这里我把参数都直接写死了，Properties部分这里是没其作用。

这里笔者也有点没弄清楚classLoader.getResourceAsStream("dubboconf.properties"); 路径问题！！！！！！（需要课后补补课，查了一些也没太搞明白，有通俗易通的解释，麻烦和我说下，先谢过啦，??）

 

 测试类：（别忘启动zookeeper）

 1 @org.junit.Test
 2     public void test1() {
 3         Map map = new HashMap<>();
 4         map.put("ParamType", "java.lang.String");  //后端接口参数类型
 5         map.put("Object", "world");  //用以调用后端接口的实参
 6 
 7         List<Map<String, Object>> paramInfos= new ArrayList<>();
 8         paramInfos.add(map);
 9 
10         DubboServiceFactory dubbo = DubboServiceFactory.getInstance();
11 
12         Object getReportResult = dubbo.genericInvoke("persistence.dubbo.DemoService", "sayHello", paramInfos);
13 
14         System.out.println(getReportResult);
15 
16         Map result = (Map) getReportResult;
17     }

 

     dubbo泛化的小demo就这样完成了，应用到实际项目中，只要把参数提出来，写到配置文件就好了。

     这里只是为了做个小demo，只是为了实现dubbo泛化调用功能，先动起来而已。其中有一些类、方法、参数的含义，需要自己再去深入了解。我本人也只是用了dubbo而已，很多东西也还没去深入学习。

　想养成写技术博客的习惯，从这里开始。目前格式排布还有很大改进，在后续中慢慢学习改变。欢迎大家指正！！