SpringBoot中如何优雅地实现异步调用？

　　前言
　　SpringBoot想必大家都用过，但是大家平时使用发布的接口大都是同步的，那么你知道如何优雅的实现异步呢？
　　这篇文章就是关于如何在SpringBoot中实现异步行为的。但首先，让我们看看同步和异步之间的区别。同步编程：在同步编程中，任务一次执行一个，只有当一个任务完成时，下一个任务才会被解除阻塞。异步编程：在异步编程中，可以同时执行多个任务。您可以在上一个任务完成之前转到另一个任务。
　　在SpringBoot中，我们可以使用Async注解来实现异步行为。实现步骤定义一个异步服务接口AsyncService。javapublicinterfaceAsyncService｛voidasyncMethod（）throwsInterruptedException；FutureStringfutureMethod（）throwsInterruptedException；｝复制代码实现定义的接口AsyncServiceImpl。javaServiceSlf4jpublicclassAsyncServiceImplimplementsAsyncService｛AsyncOverridepublicvoidasyncMethod（）throwsInterruptedException｛Thread。sleep（3000）；log。info（Thread：〔｛｝〕，Callingotherservice。。，Thread。currentThread（）。getName（））；｝AsyncOverridepublicFutureStringfutureMethod（）throwsInterruptedException｛Thread。sleep（5000）；log。info（Thread：〔｛｝〕，Callingotherservice。。，Thread。currentThread（）。getName（））；returnnewAsyncResult（taskDone）；｝｝复制代码AsyncServiceImpl是一个spring管理的bean。您的异步方法必须是公共的，而且是被Async注解修饰。返回类型被限制为void或Future。定义一个控制器AsyncController。javaEnableAsyncRestControllerSlf4jpublicclassAsyncController｛AutowiredAsyncServiceasyncService；GetMapping（async）publicStringasyncCallerMethod（）throwsInterruptedException｛longstartSystem。currentTimeMillis（）；log。info（callasyncmethod，threadname：〔｛｝〕，Thread。currentThread（）。getName（））；asyncService。asyncMethod（）；Stringresponsetaskcompletesin：（System。currentTimeMillis（）start）milliseconds；returnresponse；｝GetMapping（asyncFuture）publicStringasyncFuture（）throwsInterruptedException，ExecutionException｛longstartSystem。currentTimeMillis（）；log。info（callasyncmethod，threadname：〔｛｝〕，Thread。currentThread（）。getName（））；FutureStringfutureasyncService。futureMethod（）；阻塞获取结果StringtaskResultfuture。get（）；StringresponsetaskResulttaskcompletesin：（System。currentTimeMillis（）start）milliseconds；returnresponse；｝｝复制代码关键点，需要添加启用异步的注解EnableAsync，当然这个注解加在其他地方也ok得。当外部调用该接口时，asyncMethod（）将由默认任务执行程序创建的另一个线程执行，主线程不需要等待完成异步方法执行。运行一下
　　现在我们运行一下看看，是不是异步返回的。
　　可以看到调用async接口，最终一步调用了方法。
　　调用asyncFuture，发现返回5秒多，难道不是异步的吗？其实也是异步的，看日志可以看出来，只不过我们返回的是Future，调用Futrue。get（）是阻塞的。自定义异步任务执行器和异常处理
　　我们现在看看如果异常方法中报错了会怎么样？修改异步代码如下所示，会抛运行时异常：
　　再次执行异步接口，如下所示，会使用默认的线程池和异常处理。
　　我们也可以自定义异步方法的处理异常和异步任务执行器，我们需要配置AsyncUncaughtExceptionHandler，如下代码所示：ConfigurationpublicclassAsynConfigurationextendsAsyncConfigurerSupport｛OverridepublicExecutorgetAsyncExecutor（）｛ThreadPoolTaskExecutorexecutornewThreadPoolTaskExecutor（）；executor。setCorePoolSize（3）；executor。setMaxPoolSize（4）；executor。setThreadNamePrefix（asyntaskthread）；executor。setWaitForTasksToCompleteOnShutdown（true）；executor。initialize（）；returnexecutor；｝OverridepublicAsyncUncaughtExceptionHandlergetAsyncUncaughtExceptionHandler（）｛returnnewAsyncUncaughtExceptionHandler（）｛OverridepublicvoidhandleUncaughtException（Throwableex，Methodmethod，Object。。。params）｛System。out。println（Exception：ex。getMessage（））；System。out。println（MethodName：method。getName（））；ex。printStackTrace（）；｝｝；｝｝复制代码
　　再次运行，得到的结果如下：
　　Async如何工作的？
　　必须通过使用EnableAsync注解注解主应用程序类或任何直接或间接异步方法调用程序类来启用异步支持。主要通过代理模式实现，默认模式是Proxy，另一种是AspectJ。代理模式只允许通过代理拦截调用。永远不要从定义它的同一个类调用异步方法，它不会起作用。
　　当使用Async对方法进行注解时，它会根据proxyTargetClass属性为该对象创建一个代理。当spring执行这个方法时，默认情况下它会搜索关联的线程池定义。上下文中唯一的spring框架TaskExecutorbean或名为taskExecutor的Executorbean。如果这两者都不可解析，默认会使用spring框架SimpleAsyncTaskExecutor来处理异步方法的执行。总结
　　在本文中，我们演示了在springboot中如何使用Async注解和异步方法中的异常处理实现异步行为。我们可以在一个接口中，需要访问不同的资源，比如异步调用各个其他服务的接口，可以使用Async，然后将结果通过Future的方式阻塞汇总，不失为一个提高性能的好方法。