SpringBoot巧用 @Async 提升API接口并发能力

@Async
public void executeTask(){
   //业务操作
}

@Async
public Future<Dto> task2(){
   //业务操作
   
   //返回操作结果
   return new AsyncResult<>(new Dto("danyuan",22));
}

@Data
@AllArgsConstructor
public class Dto implements Serializable{
/**
 *serialVersionUID
 */
private static final long serialVersionUID = 1L;

private String name;

private Integer age;

}

/**  
* Title StartAsyncServer.java  
* Description  
* @author danyuan
* @version 1.0.0
* site: www.danyuanblog.com
*/
package com.danyuanblog.test;

import java.io.ByteArrayOutputStream;
import java.io.PrintStream;
import java.lang.reflect.Method;
import java.util.concurrent.Executor;

import lombok.extern.slf4j.Slf4j;

import org.springframework.aop.interceptor.AsyncUncaughtExceptionHandler;
import org.springframework.boot.SpringApplication;
import org.springframework.boot.autoconfigure.SpringBootApplication;
import org.springframework.scheduling.annotation.AsyncConfigurer;
import org.springframework.scheduling.annotation.EnableAsync;
import org.springframework.scheduling.concurrent.ThreadPoolTaskExecutor;

@SpringBootApplication
@EnableAsync
public class StartAsyncServer implements AsyncConfigurer {

public static void main(String[] args) {
 SpringApplication.run(StartAsyncServer.class, args);
}

@Override
public AsyncUncaughtExceptionHandler getAsyncUncaughtExceptionHandler() {
 
 return new ExceptionHandler();
};

@Slf4j(topic="异步线程池运行时异常捕获器")
static class ExceptionHandler implements AsyncUncaughtExceptionHandler{

 /**
  * @author danyuan
  */
 @Override
 public void handleUncaughtException(Throwable e, Method method,
   Object... params) {//全局捕获异步执行异常并处理
  ByteArrayOutputStream outputStream = new ByteArrayOutputStream(1024);
        PrintStream printStream = new PrintStream(outputStream);
        e.printStackTrace(printStream);
        log.error(outputStream.toString());
 }
 
}
/**
 * @author danyuan
 */
@Override
public Executor getAsyncExecutor() {
 ThreadPoolTaskExecutor executor = new ThreadPoolTaskExecutor();
       executor.setCorePoolSize(20);
       executor.setMaxPoolSize(400);
       executor.setQueueCapacity(10000);
       executor.setThreadNamePrefix("TestAsyncExecutor-");
       executor.initialize();
       return executor;
}
}

/**  
* Title AsyncTestService.java  
* Description  
* @author danyuan
* @version 1.0.0
* site: www.danyuanblog.com
*/
package com.danyuanblog.test.asyc;

import java.util.concurrent.Future;

import org.springframework.scheduling.annotation.Async;
import org.springframework.scheduling.annotation.AsyncResult;
import org.springframework.stereotype.Service;

@Service
public class AsyncTestService {

@Async
public void task1(){
 System.out.println("task1 execute begin .....");
 try {
  Thread.sleep(1000);
 } catch (InterruptedException e) {
  e.printStackTrace();
 }
 System.out.println("task1 execute success !");
}

@Async
public Future<Dto> task2(){
 System.out.println("task2 execute begin .....");
 try {
  Thread.sleep(6000);
 } catch (InterruptedException e) {
  e.printStackTrace();
 }
 System.out.println("task2 execute success !");
 return new AsyncResult<>(new Dto("danyuan",22));
}

@Async
public void task3(Dto dto){
 System.out.println("task3 execute begin .....");
 try {
  Thread.sleep(1000);
 } catch (InterruptedException e) {
  e.printStackTrace();
 }
 if(dto.getAge() > 18){
  System.out.println(dto.getName() "已成年!");
 }else{
  System.out.println(dto.getName() "未成年!");
 }
 System.out.println("task3 execute success !");
}

}

/**  
* Title AsycTestController.java  
* Description  业务异步化测试
* @author danyuan
* @version 1.0.0
* site: www.danyuanblog.com
*/
package com.danyuanblog.test.asyc;

import java.util.concurrent.ExecutionException;
import java.util.concurrent.Future;

import org.springframework.beans.factory.annotation.Autowired;
import org.springframework.scheduling.annotation.AsyncResult;
import org.springframework.web.bind.annotation.GetMapping;
import org.springframework.web.bind.annotation.RestController;

@RestController
public class AsycTestController {

@Autowired
private AsyncTestService asyncTestService;
/**
 * 测试异步化任务
 * @author danyuan
 */
@GetMapping("/testAsync")
public void testAsync(){
 asyncTestService.task1();
 Future<Dto> result = asyncTestService.task2();
 while(true){//task3需要等待task2执行完成
  if(result.isDone() || result.isCancelled()){
   break;
  }
  try {
   Thread.sleep(1000);
  } catch (InterruptedException e) {
   e.printStackTrace();
  }
 }
 try {
  asyncTestService.task3(result.get());
 } catch (ExecutionException | InterruptedException e) {
  e.printStackTrace();
 }
}

}