服务消费端泛化调用与异步调用

Posted 徐浩进

tags:

篇首语:本文由小常识网(cha138.com)小编为大家整理,主要介绍了服务消费端泛化调用与异步调用相关的知识,希望对你有一定的参考价值。

本文借用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的非阻塞实现并行调用,客户端不需要启动多线程即可完成并行调用多个远程服务,相对调用不同的服务使用不同线程来说开销较小。  

以上是关于服务消费端泛化调用与异步调用的主要内容,如果未能解决你的问题,请参考以下文章

使用 ActiveMQ 实现JMS 异步调用

Dubbo的基本使用

Dubbo3高级特性「框架与服务」Dubbo3客户端和服务端的泛化调用机制体系

Dubbo消费端同步调用异步调用(基于Dubbo3)

Dubbo基本特性之泛化调用

dubbo用户指南