标签：generics invoke cost 参数转换 远程服务 远程调用 基于接口 含义 image
本文借用dubbo.learn的Dubbo API方式来解释原理。
服务消费端泛化调用
前面我们讲解到，基于Spring和基于Dubbo API方式搭建简单的分布式系统时，服务消费端引入了一个SDK二方包，里面存放着服务提供端提供的所有接口类，之所以需要引入接口类是因为服务消费端一般是基于接口使用JDK代理实现远程调用的。
泛化接口调用方式主要在服务消费端没有API接口类及模型类元（比如入参和出参的POJO类）的情况下使用。其参数及返回值中没有对应的POJO类，所以所有POJO均转换为Map表示。使用泛化调用时候服务消费模块不再需要引入SDK二方包。
下面基于Dubbo API实现异步调用，在Consumer模块里面TestConsumerApiGeneric是泛化调用的方式，代码如下：
public class TestConsumerApiGeneric(){ public static void main(String[] args) throws IOException{ // 当前应用配置 ApplicationConfig application = new ApplicationConfig(); application.setName("dubboConsumer"); // 连接注册中心配置 RegistryConfig registry = new RegistryConfig(); registry.setAddress("127.0.0.1:2181"); registry.setProtocol("zookeeper"); // 泛型参数设置为GenericService ReferenceConfig<GenericService> reference = new ReferenceConfig<GenericService>(); reference.setApplication(application); reference.setRegistry(registry); reference.setVersion("1.0.0"); reference.setGroup("dubbo"); reference.setTimeout(3000); // 设置为泛化 reference.setInterface("com.test.UserServiceBo"); reference.setGeneric(true); // 用com.alibaba.dubbo.rpc.service.GenericService替代所有接口引用 GenericService userService = reference.get(); // 基于类型以及Date/List/Map等不需要转换，直接调用，如果返回值为POJO也将自动转为Map Object result = userService.$invoke("sayHello",new String[]{"java.lang.String"},new Object[]{"哈哈哈"}); System.out.println(JSON.json(result)); // POJO参数转换为map Map<String,Object> map = new HashMap<String,Object>(); map.put("class","com.test.PersonImpl"); map.put("name","jiaduo"); map.put("password","password"); result = userService.$invoke("testPojo",new String[]{"com.test.Person"},new Object[]{map}); System.out.println((result)); } }
上面代码中，由于sayHello的参数是String，没有很好的体现参数转换为Map，下面我们具体来说下POJO参数转换Map的含义。
比如服务提供者提供的一个接口的 testPojo(Person person) 方法的参数为如下所示：
package com.test; public class PersonImpl implements Person{ private String name; private String password; public String getName(){ return name; } public void setName(String name){ this.name = name; } public String getPassword(){ return password; } public void setPassword(String password){ this.password = password; } }
则POJO数据：
Person person = new PersonImpl(); person.setName("jiaduo"); person.setPassword("password");
正常情况下调用接口是使用：
servicePerson.testPojo(person);
泛化调用下需要首先转换person为Map，如下表示：
Map<String,Object> map = new HashMap<String,Object>(); // 注意：如果参数类型是接口，或者List等丢失泛型，可通过class属性指定类型。 map.put("class","com.test.PersonImpl"); map.put("name","jiaduo"); map.put("password","password");
然后使用下面方法进行泛化调用：
servicePerson.$invoke("testPojo",new String[]{"com.test.Person"},new Object[]{map});
泛化调用通常用于框架集成，比如：实现一个通用的服务测试框架，可通过GenericService调用所有服务实现，而不需要依赖服务实现方提供的接口类以及接口的入参和出参的POJO类。
服务消费端异步调用
无论前面我们讲解的正常调用还是泛化调用，都是同步调用，也就是服务消费方发起一个远程调用后，调用线程要被阻塞挂起，直到服务提供方返回。
本节讲解下服务消费端异步调用，异步调用是指服务消费方发起一个远程调用后，不等服务提供方返回结果，调用方法就返回了，也就是当前线程不会被阻塞，这就允许调用方同时调用多个远程方法。
在Consumer模块里面TestConsumerAsync是泛化调用，代码如下：
public class TestConsumerAsync{ public static void main(String[] args) throws InterruptedException,ExecutionException{ // 当前应用配置 ApplicationConfig application = new ApplicationConfig(); application.setName("dubboConsumer"); // 连接注册中心配置 RegistryConfig registry = new RegistryConfig(); registry.setAddress("127.0.0.1:2181"); registry.setProtocol("zookeeper"); // 引用远程服务 ReferenceConfig<UserServiceBo> reference = new ReferenceConfig<UserServiceBo>(); reference.setApplication(application); reference.setRegistry(registry); reference.setInterface(UserServiceBo.class); reference.setVersion("1.0.0"); reference.setGroup("dubbo"); reference.setTimeout(3000); // (1)设置为异步调用 reference.setAsync(true); // 和本地bean一样使用xxxService UserServiceBo userService = reference.get(); long startTime = System.currentTimeMillis() / 1000; // (2)因为异步调用，此处返回null System.out.println(userService.sayHello("哈哈哈")); // 拿到调用的Future引用，当结果返回后，会被通知和设置到此Futrue Future<String> userServiceFutureOne = RpcContext.getContext().getFuture(); // (3)因为异步调用，此处返回null System.out.println(userService.sayHello2("哈哈哈2")); // 拿到调用的Future引用，当结果返回后，会被通知和设置到此Future Future<String> userServiceFutureTwo = RpcContext.getContext().getFuture(); // (4)阻塞到get方法，等待结果返回 System.out.println(userServiceFutureOne.get()); System.out.println(userServiceFutureTwo.get()); long endTime = System.currentTimeMillis() / 1000; System.out.println("costs:" + (endTime - startTime)); } }
运行上面代码，输出如下图所示：
其中代码（2）（3）处输出null，说明开启异步调用后调用方直接返回null。
输出costs：2说明异步调用生效了，因为sayHello和sayHello2方法内都sleep了2s，如果是顺序调用则会耗时至少4s，这里耗时2s说明两次调用是并发进行的。
异步调用是基于nio的非阻塞实现并行调用，客户端不需要启动多线程即可完成并行调用多个远程服务，相对调用不同的服务使用不同线程来说开销较小。
标签：generics invoke cost 参数转换 远程服务 远程调用 基于接口 含义 image
原文地址：https://www.cnblogs.com/xhj123/p/9076530.html
