微信公众号搜"智元新知"关注
微信扫一扫可直接关注哦!

Dubbo中CompletableFuture异步调用

使用Future实现异步调用,对于无需获取返回值的操作来说不存在问题,但消费者若需要获取到最终的异步执行结果,则会出现问题:消费者在使用Future的get()方法获取返回值时被阻塞。为了解决这个问题,dubbo又引入了CompletableFuture来实现对提供者的异步调用

一、创建提供者10-provider-async2

A、创建工程

直接复制10-provider-async工程,并命名为10-provider-async2

B、修改业务接口

需要异步调用执行的方法返回CompletableFuture<>

C、修改实现类

二、 创建消费者10-consumer-async2

A、创建工程

直接复制10-consumer-async工程,并命名为10-consumer-async2

B、修改业务接口

C、修改消费者类

直接删除同步消费者类,修改异步消费者类

D、修改配置文件

三、总结

Future与CompletableFuture的对比

  • Future:dubbo2.7.0版本之前消费者异步调用提供者的实现方式。源自于JDK5,对异步结果的获取采用了阻塞与轮询方式。
  • CompletableFuturedubbo2.7.0版本之后消费者异步调用提供者的实现方式。源自于JDK8,对异步结果的获取采用了回调的方式

版权声明:本文内容由互联网用户自发贡献,该文观点与技术仅代表作者本人。本站仅提供信息存储空间服务,不拥有所有权,不承担相关法律责任。如发现本站有涉嫌侵权/违法违规的内容, 请发送邮件至 dio@foxmail.com 举报,一经查实,本站将立刻删除。

相关推荐