在Dubbo3中，服务异步调用的新实践和开发模式

2023-11-18 15:30:39







**引子** 

在分布式系统中，服务之间的调用往往是耗时的，这可能会导致系统性能下降和用户体验不佳。为了解决这个问题，Dubbo3引入了异步调用特性，允许客户端在不等待服务端返回结果的情况下继续执行其他任务，从而提高了系统的吞吐量和响应速度。

**技术背景** 

从2.7.0版本开始，Dubbo的所有异步编程接口都以CompletableFuture为基础，基于NIO的非阻塞实现并行调用。这意味着客户端不需要启动多线程即可完成并行调用多个服务。

**服务异步调用的新实践** 

在Dubbo3中，服务异步调用可以通过两种方式实现：

* **使用CompletableFuture直接进行异步调用** 

这种方式是最简单的，也是最直接的。只需要在服务接口中定义一个CompletableFuture类型的返回值，然后在服务实现类中使用CompletableFuture的complete方法来完成异步调用。

例如：

```java
public interface DemoService {

    CompletableFuture<String> sayHello(String name);

}

public class DemoServiceImpl implements DemoService {

    @Override
    public CompletableFuture<String> sayHello(String name) {
        // 实际的业务逻辑
        String result = "Hello, " + name;

        // 完成异步调用
        CompletableFuture<String> future = new CompletableFuture<>();
        future.complete(result);

        return future;
    }

}

使用Dubbo的异步调用注解

这种方式更加方便，只需要在服务接口的方法上加上@Async注解即可。Dubbo会自动生成一个CompletableFuture类型的返回值，并在服务实现类中使用CompletableFuture的complete方法来完成异步调用。

例如：

public interface DemoService {

    @Async
    String sayHello(String name);

}

public class DemoServiceImpl implements DemoService {

    @Override
    public String sayHello(String name) {
        // 实际的业务逻辑
        String result = "Hello, " + name;

        return result;
    }

}

开发模式

在Dubbo3中，服务异步调用支持两种开发模式：

Callback模式

Callback模式是异步调用的传统模式，需要客户端实现一个回调接口，并在服务端完成异步调用后调用该回调接口。

例如：

public class DemoCallback implements Callback<String> {

    @Override
    public void onSuccess(String result) {
        // 处理异步调用成功的结果
    }

    @Override
    public void onError(Throwable throwable) {
        // 处理异步调用失败的异常
    }

}

public class DemoConsumer {

    public void callAsync() {
        DemoService service = DubboReferenceConfig.get(DemoService.class);

        // 异步调用服务
        service.sayHello("World", new DemoCallback());
    }

}

CompletableFuture模式

CompletableFuture模式是Java 8引入的新型异步调用模式，它提供了更加方便和灵活的异步编程方式。

例如：

public class DemoConsumer {

    public void callAsync() {
        DemoService service = DubboReferenceConfig.get(DemoService.class);

        // 异步调用服务
        CompletableFuture<String> future = service.sayHello("World");

        // 在其他线程中处理异步调用结果
        future.thenAccept(result -> {
            // 处理异步调用成功的结果
        });

        future.exceptionally(throwable -> {
            // 处理异步调用失败的异常
            return null;
        });
    }

}