dubbo泛化调用 小demo

时间:2022-05-30 12:28:17

  前两天刚好有个同事来问是否用过 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而已,很多东西也还没去深入学习。

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