在Spring Boot中（Spring MVC）下请求默认都是同步的，一个请求过去到结束都是由一个线程负责的，很多时候为了能够提高吞吐量，需要将一些操作异步化，比如一些耗时的业务逻辑可以异步化。
一个请求到服务上，是用的web容器的线程接收的，比如线程http-nio-8084-exec-1。
我们可以使用WebAsyncTask将这个请求分发给一个新的线程去执行，http-nio-8084-exec-1可以去接收其他请求的处理。一旦WebAsyncTask返回数据有了，就会被再次调用并且处理，以异步产生的方式，向请求端返回值。
示例代码如下：
/**
* 查询
*/
@RequestMapping(method = RequestMethod.GET, value = "/aysncTask/{testId}")
@ResponseStatus(HttpStatus.OK)
public WebAsyncTask<Response> aysncTask(@PathVariable("testId") String testId) {
System.out.println(String.format("/aysncTask/%s 被调用 thread id is: %s", testId,Thread.currentThread().getName()));
Callable<Response> callable = () -> {
Thread.sleep(1000L);
Response response = new Response(true,"异步执行成功");
System.out.println(String.format("/aysncTask/%s 被调用 thread id is: %s", testId,Thread.currentThread().getName()));
return response;
};
return new WebAsyncTask<Response>(callable);
}
控制台打印如下：
在执行业务逻辑之前的线程和具体处理业务逻辑的线程不是同一个，达到了我们的目的。async-customize-1这个前缀是我们自定义的下边会说
/aysncTask/12348567676 被调用 thread id is: http-nio-8084-exec-1
/aysncTask/12348567676 被调用 thread id is: async-customize-1
至此我们达到了异步执行的目的，但是通常我们都会自定义线程池来装载异步执行的线程，下边是自定义线程池的操作：
第一步：重写spring mvc的配置
因为我们只需要改变mvc异步执行的配置，所以选择继承WebMvcConfigurationSupport这个Mvc的主配置类
/**
* @Description: 自定义mvc配置
* @Author: LiuBing
* @Date: 17:49 2018/11/13
*/
@Configuration
public class WebMvcConfig extends WebMvcConfigurationSupport {
@Autowired
private AsyncTaskExecutePool asyncTaskExecutePool;
@Override
public void configureAsyncSupport(final AsyncSupportConfigurer configurer) {
configurer.setDefaultTimeout(60 * 1000L);
configurer.registerCallableInterceptors(timeoutCallableProcessingInterceptor());
configurer.setTaskExecutor((AsyncTaskExecutor)asyncTaskExecutePool.getAsyncExecutor());
}
@Bean
public TimeoutCallableProcessingInterceptor timeoutCallableProcessingInterceptor(){
return new TimeoutCallableProcessingInterceptor();
}
}
第二步：创建属性配置类
/**
* @Description: 线程池属性配置
* @Author: LiuBing
* @Date: 18:20 2018/11/13
*/
@Data
@Configuration
@ConfigurationProperties(prefix = "spring.task.pool")
public class TaskThreadPoolConfig {
/** 池中允许的最小线程数 */
Integer corePoolSize;
/** 池中允许的最大线程数 */
Integer maximumPoolSize;
/** 空闲线程在终止之前等待新任务的最长时间 */
Integer keepAliveTime;
/** 队列长度 */
Integer queueCapacity;
/** 线程前缀 */
String threadNamePrefix;
}
第三步：自定义线程池主类
这个类两个方法：1.获取Execute 2.获取异步执行异常处理器handler
/**
* @Description: 自定义线程池
* @Author: LiuBing
* @Date: 18:11 2018/11/13
*/
@Slf4j
@Configuration
public class AsyncTaskExecutePool implements AsyncConfigurer {
@Autowired
private TaskThreadPoolConfig threadPoolConfig;
/**
* The {@link Executor} instance to be used when processing async
* method invocations.
*/
@Override
public Executor getAsyncExecutor() {
ThreadPoolTaskExecutor taskExecutor = new ThreadPoolTaskExecutor();
taskExecutor.setCorePoolSize(threadPoolConfig.getCorePoolSize());
taskExecutor.setKeepAliveSeconds(threadPoolConfig.getKeepAliveTime());
taskExecutor.setMaxPoolSize(threadPoolConfig.getMaximumPoolSize());
taskExecutor.setQueueCapacity(threadPoolConfig.getQueueCapacity());
taskExecutor.setThreadNamePrefix(threadPoolConfig.getThreadNamePrefix());
// 拒绝策略
taskExecutor.setRejectedExecutionHandler(new ThreadPoolExecutor.CallerRunsPolicy());
taskExecutor.initialize();
return taskExecutor;
}
/**
* The {@link AsyncUncaughtExceptionHandler} instance to be used
* when an exception is thrown during an asynchronous method execution
* with {@code void} return type.
*/
@Override
public AsyncUncaughtExceptionHandler getAsyncUncaughtExceptionHandler() {
return (ex, method, params) -> {
log.info("异步执行异常信息:{}", ex.getMessage());
log.info("异步执行的方法名:{}", method.getName());
};
}
}
properties文件线程池属性配置（具体值根据各方面因素考量），当然也可以使用yml
spring.task.pool.corePoolSize=30
spring.task.pool.maximumPoolSize=30
spring.task.pool.keepAliveTime=30
spring.task.pool.queueCapacity=1000
spring.task.pool.threadNamePrefix=async-customize-
这样我们便在一开进行web请求的时候用的就是我们自定义的线程池。
主要适用场景：接口并发请求高，内部处理逻辑耗时。
网友评论