当某个请求执行非常耗时当有大量访问该请求的时候再访问请求其他服务时会出现没有连接使用的情况。造成这种现象的主要原因是容器中线程的数量是一定的如果当所有线程都正在用来处理请求服务的时候再有请求进来就没有多余的连接可用只能拒绝连接。SpringBoot异步机制可以使请求到了controller的时候容器中的线程直接返回同时使用系统内部的线程来执行耗时的服务处理结束后果再将请求返回给客户端。Servlet 3.0 新增了请求的异步处理Spring 3.2 也在此基础上做了封装处理。Spring通过任务执行器TaskExecutor来实现多线程和并发编程。使用ThreadPoolTaskExecutor可实现一个基于线程池的TaskExecutor。在 Spring Boot 框架中可以在配置类中添加EnableAsync开始对异步任务的支持并将相应的方法使用Async注解来声明为一个异步任务。对于Transactional、Async等注解Spring扫描到具有这些注解方法的类时生成一个代理类由代理类去执行所以异步方法必须在类外部调用并且Async所修饰的不能是static方法。获取得到执行结果则可设置异步函数返回类型为FutureComponent public class MyAsyncTask { Async public FutureString task1() throws InterruptedException{ return new AsyncResultString(task1执行完毕); }Controller的方法可以很快返回一个java.util.concurrent.Callable或DeferredResult同时Servlet容器的主线程退出和释放这并不意味着客户端收到了一个响应。//Callable Controller public class DefaultController { RequestMapping(/async/test) ResponseBody public CallableString callable() { //调用后生成一个非web线程来执行部分代码。 return new CallableString() { Override public String call() throws Exception { Thread.sleep(3 * 1000L); return finish System.currentTimeMillis(); } }; } } //DeferredResult RestController public class AsyncDeferredController { private final TaskService taskService; Autowired public AsyncDeferredController(TaskService taskService) { this.taskService taskService; } RequestMapping(value /deferred, method RequestMethod.GET, produces text/html) public DeferredResultString executeSlowTask() { DeferredResultString deferredResult new DeferredResult(); CompletableFuture.supplyAsync(taskService::execute).whenCompleteAsync((result, throwable) - deferredResult.setResult(result)); return deferredResult; } }Callable的其它示例public static void main(String[] args) throws ExecutionException, InterruptedException { CallableString callable new CallableImpl(my callable test!); FutureTaskString task new FutureTask(callable); new Thread(task).start(); //调用get()会阻塞主线程。 String result task.get(); }Callable和DeferredResult的区别Callable和DeferredResult效果都是释放容器线程在另一个线程中运行长时间的任务。不同的是谁管理执行任务的线程Callable在执行线程完毕时返回。Deferredresult是通过设置返回对象值返回可以在任何地方控制返回。定时任务1.在程序入口类上添加类注解 EnableScheduling 来启用计划任务2.在定时任务的类上加上类注解 Component在具体的定时任务方法上加上注解 Scheduled 启动该定时任务。Scheduled(initialDelay10000, fixedDelay10000) //10 seconds, or use cron express默认所有的Scheduled都是串行执行的并行需要继承SchedulingConfigurer类并重写其方法实现并行任务。Configuration EnableScheduling public class ScheduleConfig implements SchedulingConfigurer { Override public void configureTasks(ScheduledTaskRegistrar taskRegistrar) { taskRegistrar.setScheduler(taskExecutor()); } Bean(destroyMethodshutdown) public Executor taskExecutor() { return Executors.newScheduledThreadPool(100); } }当某个请求执行非常耗时当有大量访问该请求的时候再访问请求其他服务时会出现没有连接使用的情况。造成这种现象的主要原因是容器中线程的数量是一定的例如500个当这500个线程都正在用来处理请求服务的时候再有请求进来没有多余的连接可用了只能拒绝连接。SpringBoot异步机制可以使请求到controller中时容器线程直接返回同时使用系统内部的线程来执行耗时的服务处理结束后果再将请求返回给客户端。Servlet 3.0 新增了请求的异步处理Spring 3.2 也在此基础上做了封装处理。Spring通过任务执行器TaskExecutor来实现多线程和并发编程。使用ThreadPoolTaskExecutor可实现一个基于线程池的TaskExecutor。在 Spring Boot 框架中可以在配置类中添加EnableAsync开始对异步任务的支持并将相应的方法使用Async注解来声明为一个异步任务。对于Transactional、Async等注解spring扫描时具有这些注解方法的类时生成一个代理类由代理类去执行所以异步方法必须在类外部调用并且Async所修饰的不能是static方法。获取得到执行结果则可设置异步函数返回类型为Future。preComponentpublic class MyAsyncTask {Asyncpublic FutureString task1() throws InterruptedException{return new AsyncResultString(task1执行完毕);}/preController的方法可以很快返回一个java.util.concurrent.Callable或Deferredresult同时Servlet容器的主线程退出和释放这并不意味着客户端收到了一个响应。pre//CallableControllerpublic class DefaultController {RequestMapping(/async/test)ResponseBodypublic CallableString callable() {//调用后生成一个非web线程来执行部分代码。return new CallableString() {Overridepublic String call() throws Exception {Thread.sleep(3 * 1000L);return finish System.currentTimeMillis();}};}}//DeferredResultRestControllerpublic class AsyncDeferredController {private final TaskService taskService;Autowiredpublic AsyncDeferredController(TaskService taskService) {this.taskService taskService;}RequestMapping(value /deferred, method RequestMethod.GET, produces text/html)public DeferredResultString executeSlowTask() {DeferredResultString deferredResult new DeferredResult();CompletableFuture.supplyAsync(taskService::execute).whenCompleteAsync((result, throwable) - deferredResult.setResult(result));return deferredResult;}}/preCallable的其它示例prepublic static void main(String[] args) throws ExecutionException, InterruptedException {CallableString callable new CallableImpl(my callable test!);FutureTaskString task new FutureTask(callable);new Thread(task).start();//调用get()会阻塞主线程。String result task.get();}/preCallable和Deferredresult的区别Callable和Deferredresult效果都是释放容器线程在另一个线程中运行长时间的任务。不同的是谁管理执行任务的线程Callable在执行线程完毕时返回Deferredresult是通过设置返回对象值返回可以在任何地方控制返回。https://blog.csdn.net/he90227/article/details/52262163Spring MVC 异步处理请求提高程序性能h1定时任务/h11.在程序入口类上添加类注解 EnableScheduling 来启用计划任务2.在定时任务的类上加上类注解 Component在具体的定时任务方法上加上注解 Scheduled 启动该定时任务。Scheduled(initialDelay10000, fixedDelay10000) //10 seconds, or use cron express默认所有的Scheduled都是串行执行的并行需要继承SchedulingConfigurer类并重写其方法实现并行任务。preConfigurationEnableSchedulingpublic class ScheduleConfig implements SchedulingConfigurer {Overridepublic void configureTasks(ScheduledTaskRegistrar taskRegistrar) {taskRegistrar.setScheduler(taskExecutor());}Bean(destroyMethodshutdown)public Executor taskExecutor() {return Executors.newScheduledThreadPool(100);}}/pre详解SpringBoot Schedule配置http://www.cfei.net/archives/88832