前言
这篇文章就是关于如何在Spring Boot中实现异步行为的。但首先，让我们看看同步和异步之间的区别。
-
同步编程：在同步编程中，任务一次执行一个，只有当一个任务完成时，下一个任务才会被解除阻塞。
- 异步编程：在异步编程中，可以同时执行多个任务。您可以在上一个任务完成之前转到另一个任务。
Spring Boot中，我们可以使用@Async注解来实现异步行为。
实现步骤
- 定义一个异步服务接口
AsyncService.java
public interface AsyncService {
void asyncMethod( throws InterruptedException;
Future<String> futureMethod( throws InterruptedException;
}
- 实现定义的接口
AsyncServiceImpl.java
@Service
@Slf4j
public class AsyncServiceImpl implements AsyncService {
@Async
@Override
public void asyncMethod( throws InterruptedException {
Thread.sleep(3000;
log.info("Thread: [{}], Calling other service..", Thread.currentThread(.getName(;
}
@Async
@Override
public Future<String> futureMethod( throws InterruptedException {
Thread.sleep(5000;
log.info("Thread: [{}], Calling other service..", Thread.currentThread(.getName(;
return new AsyncResult<>("task Done";
}
}
- 您的异步方法必须是公共的，而且是被
@Async注解修饰。 - 返回类型被限制为
void或Future。
AsyncServiceImpl 是一个 spring 管理的 bean。
- 定义一个控制器
AsyncController.java
@EnableAsync
@RestController
@Slf4j
public class AsyncController {
@Autowired
AsyncService asyncService;
@GetMapping("/async"
public String asyncCallerMethod( throws InterruptedException {
long start = System.currentTimeMillis(;
log.info("call async method, thread name: [{}]", Thread.currentThread(.getName(;
asyncService.asyncMethod(;
String response = "task completes in :" +
(System.currentTimeMillis( - start + "milliseconds";
return response;
}
@GetMapping("/asyncFuture"
public String asyncFuture( throws InterruptedException, ExecutionException {
long start = System.currentTimeMillis(;
log.info("call async method, thread name: [{}]", Thread.currentThread(.getName(;
Future<String> future = asyncService.futureMethod(;
// 阻塞获取结果
String taskResult = future.get(;
String response = taskResult + "task completes in :" +
(System.currentTimeMillis( - start + "milliseconds";
return response;
}
}
- 关键点，需要添加启用异步的注解
- 当外部调用该接口时，
asyncMethod(将由默认任务执行程序创建的另一个线程执行，主线程不需要等待完成异步方法执行。
@EnableAsync，当然这个注解加在其他地方也ok得。
- 运行一下
现在我们运行一下看看，是不是异步返回的。
- 可以看到调用
/async接口，最终一步调用了方法。
- 调用
/asyncFuture，发现返回5秒多，难道不是异步的吗？其实也是异步的，看日志可以看出来，只不过我们返回的是Future,调用Futrue.get(是阻塞的。
自定义异步任务执行器和异常处理
AsyncUncaughtExceptionHandler，如下代码所示：
@Configuration
public class AsynConfiguration extends AsyncConfigurerSupport {
@Override
public Executor getAsyncExecutor( {
ThreadPoolTaskExecutor executor = new
ThreadPoolTaskExecutor(;
executor.setCorePoolSize(3;
executor.setMaxPoolSize(4;
executor.setThreadNamePrefix("asyn-task-thread-";
executor.setWaitForTasksToCompleteOnShutdown(true;
executor.initialize(;
return executor;
}
@Override
public AsyncUncaughtExceptionHandler
getAsyncUncaughtExceptionHandler( {
return new AsyncUncaughtExceptionHandler( {
@Override
public void handleUncaughtException(Throwable ex,
Method method, Object... params {
System.out.println("Exception: " + ex.getMessage(;
System.out.println("Method Name: " + method.getName(;
ex.printStackTrace(;
}
};
}
}
再次运行，得到的结果如下：
@Async如何工作的？
@EnableAsync注解注解主应用程序类或任何直接或间接异步方法调用程序类来启用异步支持。主要通过代理模式实现，默认模式是 Proxy，另一种是 AspectJ。代理模式只允许通过代理拦截调用。永远不要从定义它的同一个类调用异步方法，它不会起作用。
@Async对方法进行注解时，它会根据“proxyTargetClass”属性为该对象创建一个代理。当 spring 执行这个方法时，默认情况下它会搜索关联的线程池定义。上下文中唯一的 spring 框架 TaskExecutor bean 或名为“taskExecutor”的 Executor bean。如果这两者都不可解析，默认会使用spring框架SimpleAsyncTaskExecutor来处理异步方法的执行。
总结
@Async 注解和异步方法中的异常处理实现异步行为。我们可以在一个接口中，需要访问不同的资源，比如异步调用各个其他服务的接口，可以使用@Async，然后将结果通过Future的方式阻塞汇总，不失为一个提高性能的好方法。
欢迎关注个人公众号【JAVA旭阳】交流沟通