RPC调用方如何实现异步调用：CompletableFuture

目录

情景：

CompletableFuture

---

情景：

每次需要在此阻塞等待结果返回 可能还会触发超时重试 使得后续业务执行受到影响。下面的代码执行是串行执行，并发度低。

        long startTime = System.currentTimeMillis();
        int threadNum = 10;
        for (int i = 0; i < threadNum; i++) {
            try {
                // 每次需要在此阻塞等待结果返回 可能还会触发超时重试 使得后续业务执行受到影响
                String result = dataService.sendData("test" + i);
                System.out.println(result);
            } catch (Exception e) {
                e.printStackTrace();
            }
        }
        long endTime = System.currentTimeMillis();
        System.out.println(" time cost : " + (double)((endTime - startTime)/1000) + " s");

可以使用 CompletableFuture 进行异步调用和任务编排，改写完变为异步调用，耗时短，任务调用完后会自动执行后续的业务。

        int threadNum = 10;
        long startTime = System.currentTimeMillis();
        for (int i = 0; i < threadNum; i++) {
            try {
                int finalI = i;
                CompletableFuture<String> cf = CompletableFuture.supplyAsync(()->{
                     String result = dataService.sendData("test" + finalI);
                     return  result;
                }).thenCompose(result -> CompletableFuture.supplyAsync(()->{
                    // 拿到rpc调用的结果后进行相关的操作
                    System.out.println(result);
                    return "";
                }));
            } catch (Exception e) {
                e.printStackTrace();
            }
        }
        long endTime = System.currentTimeMillis();
        System.out.println(" time cost : " + (double)((endTime - startTime)/1000) + " s");

服务端也可以进行类似的改进，通过对 CompletableFuture 的支持，RPC 框架可以真正地做到在调用端与服务端之间完全异步，同时提升了调用端与服务端的两端的单机吞吐量，并且 CompletableFuture 是Java8 原生支持，业务逻辑中没有任何代码入侵性。

CompletableFuture

上文中的任务编排本质上是把任务交给了CompletableFuture 中的线程池处理，线程池的核心线程数默认是核心数-1。所以大于这个值也会进行 排队等待。解决办法就是自定义线程池，不仅可以起到隔离的效果，也可以根据任务的数量动态的创建特定大小的线程池。