Dubbo常用功能10异步调用

从dubbo的2.7.0版本，所有异步编程接口以CompletableFuture为基础。

基于NIO的非阻塞实现并行调用，服务消费方不需要启动多线程即可完成并行调用多个远程服务，相对多线程开销教小。

简而言之，消费者通过异步调用，不用等待服务提供者返回结果就立即完成任务，待有结果之后再执行之前设定好的监听逻辑。

1、接口层修改：

package com.yas.api;

import java.util.concurrent.CompletableFuture;

public interface SiteService {
    String getName(String name);

    //回调方法
    default String getName(String name,String key,SiteServiceListener siteServiceListener){
        return null;
    }

    //异步调用方法
    default CompletableFuture<String> getNameAsync(String name){
        return null;
    }
}

2、提供方代码：

package com.yas.serviceprovider.impl;

import com.yas.api.SiteService;
import org.apache.dubbo.config.annotation.Service;

import java.util.concurrent.CompletableFuture;

@Service(version = "async")
public class AsyncSiteServiceImpl implements SiteService {
    @Override
    public String getName(String name) {
        return "async:" + name;
    }

    @Override
    public CompletableFuture<String> getNameAsync(String name) {
        System.out.println("异步调用");
        return CompletableFuture.supplyAsync(() -> {
            return getName(name);
        });
    }
}

3、消费方代码

package com.yas.serviceconsumer.controller;

import com.yas.api.SiteService;
import org.apache.dubbo.config.annotation.Reference;
import org.springframework.web.bind.annotation.RequestMapping;
import org.springframework.web.bind.annotation.RequestParam;
import org.springframework.web.bind.annotation.RestController;

import java.util.concurrent.CompletableFuture;

@RestController
public class SiteController {

    @Reference(version = "async")
    SiteService asyncSiteService;

    @RequestMapping("/async")
    public String getNameByAsync(@RequestParam("name") String name){
        //调用异步方法
        CompletableFuture<String> future = asyncSiteService.getNameAsync(name);

        //设置监听，非阻塞
        future.whenComplete((v,e)->{
            if(e!=null){
                e.printStackTrace();
            }else{
                System.out.println("async result:"+v);
            }
        });
        return "异步调用完成";
    }
}

4、测试：

使用postman请求地址：http://localhost:8000/async?name=zhangsan

得到响应如下：

调用完毕后，消费者的控制台会打印：

这个调用是异步的，底层使用的是NIO。