异步操作优化接口性能，可提升数倍

古城微笑少年丶 2023-01-06 11:56 134阅读 0赞

# 背景： #

在我们日常的开发中，很多时候我们的接口会有比较复杂的逻辑，比如说在一个接口中我们可能要去查询N次数据库来获得我们想要的数据，然后做一些逻辑运算，参数拼装等，还可能调用第三方的api，这会让我们的接口不堪重负。

# 实战 #

其实在很多操作其实是没必要串行的，会浪费掉我们计算机的性能，还增加了接口的开销时间，这时我们可以通过并行也就是异步来优化我们接口的。  
比如有这样的场景，我们需要去调用三个第三方的api获取结果后并且相加，每个api大概需要花2s  
代码:

public int getA(){
            try {
                Thread.sleep(2000);
            } catch (InterruptedException e) {
                e.printStackTrace();
            }
            return 1;
        }
        public int getB(){
            try {
                Thread.sleep(2000);
            } catch (InterruptedException e) {
                e.printStackTrace();
            }
            return 2;
        }
        public int getC(){
            try {
                Thread.sleep(2000);
            } catch (InterruptedException e) {
                e.printStackTrace();
            }
            return 3;
        }
    
    @org.junit.Test
        public void api() throws ExecutionException, InterruptedException {
            long startTime = System.currentTimeMillis();
            int a = getA();
            int b = getB();
            int c = getC();
            System.out.println(a+b+c);
            long endTime = System.currentTimeMillis();
            System.out.println("total expense = {},"+(endTime-startTime));
        }

运行结果：  
![在这里插入图片描述][watermark_type_ZmFuZ3poZW5naGVpdGk_shadow_10_text_aHR0cHM6Ly9ibG9nLmNzZG4ubmV0L3FxXzE3MDExNDIz_size_16_color_FFFFFF_t_70]  
总共需要6S多的时间，这样的串行计算，其实没法发挥出多核计算机的优势，我们使用异步来优化我们的接口：

@org.junit.Test
        public void apiOp() throws ExecutionException, InterruptedException {
            long startTime = System.currentTimeMillis();
            CompletableFuture a = CompletableFuture.supplyAsync(() -> {
                return getA();
            });
            CompletableFuture b = CompletableFuture.supplyAsync(() -> {
                return getB();
            });
            CompletableFuture c = CompletableFuture.supplyAsync(() -> {
                return getC();
            });
            System.out.println((int)a.get() + (int)b.get()+ (int)c.get());
            long endTime = System.currentTimeMillis();
            System.out.println("total expense = {},"+(endTime-startTime));
        }

![在这里插入图片描述][watermark_type_ZmFuZ3poZW5naGVpdGk_shadow_10_text_aHR0cHM6Ly9ibG9nLmNzZG4ubmV0L3FxXzE3MDExNDIz_size_16_color_FFFFFF_t_70 1]  
可以看到我们的接口性能提升近3倍。

CompletableFuture是jdk8中的类， 提供了四个静态方法来创建一个异步操作

public static CompletableFuture<Void> runAsync(Runnable runnable)
 public static CompletableFuture<Void> runAsync(Runnable runnable, Executor executor)
 public static CompletableFuture supplyAsync(Supplier supplier)
 public static CompletableFuture supplyAsync(Supplier supplier, Executor executor)

runAsyn方法不支持返回值，supplyAsync可以支持返回值，有兴趣的可以自己学一下，网上资料一大把的。

[watermark_type_ZmFuZ3poZW5naGVpdGk_shadow_10_text_aHR0cHM6Ly9ibG9nLmNzZG4ubmV0L3FxXzE3MDExNDIz_size_16_color_FFFFFF_t_70]: /images/20221119/4c06e235e1134f0dbb01c16e273996d9.png
[watermark_type_ZmFuZ3poZW5naGVpdGk_shadow_10_text_aHR0cHM6Ly9ibG9nLmNzZG4ubmV0L3FxXzE3MDExNDIz_size_16_color_FFFFFF_t_70 1]: https://img-blog.csdnimg.cn/20210114164518462.png?x-oss-process=image/watermark,type_ZmFuZ3poZW5naGVpdGk,shadow_10,text_aHR0cHM6Ly9ibG9nLmNzZG4ubmV0L3FxXzE3MDExNDIz,size_16,color_FFFFFF,t_70