Spring及Springboot 异步请求

1.java 异步请求

Spring在3.2的版本上就已经为我们提供的相应的机制，以应对Http Nio的场景。

官方文档中说DeferredResult和Callable都是为了异步生成返回值提供基本的支持。

 *简单来说就是一个请求进来，如果你使用了DeferredResult或者Callable，在没有得到返回数据之前， DispatcherServlet和所有Filter就会退出Servlet容器线程，但响应保持打开状态， 一旦返回数据有了，这个DispatcherServlet就会被再次调用并且处理，以异步产生的方式，向请求端返回值。

2.异步请求实现方式

 1. Callable加SpringMvc 自带线程池，可以对SpringBoot 默认创建的ThreadPoolTaskExecutor 进行覆写，按照业务需求定义线程池

 /*** 1.使用 springboot 自动生成的ThreadPoolTaskExecutor 线程池* @param request* @param name* @return*/@GetMapping("/test1")@ResponseBodypublic  Callable<String> test1(HttpServletRequest request,@RequestParam (required = true) String name){log.info("--------start-----");Callable<String> callable = new Callable<String>() {@Overridepublic String call() throws Exception {Thread.sleep(2000);log.info("当前线程名" + Thread.currentThread().getName());return "hello" + name + "访问 test1";}};log.info("--------end-----");return callable;}## 覆写 mvc 线程池```java
@Configuration
@ConfigurationProperties(prefix = "web-mvc-async")
public class WebMvcConfig extends WebMvcConfigurationSupport {@Overridepublic void configureAsyncSupport(final AsyncSupportConfigurer configurer) {configurer.setDefaultTimeout(60 * 1000L);configurer.registerCallableInterceptors(timeoutInterceptor());configurer.setTaskExecutor(threadPoolTaskExecutor());}@Beanpublic TimeoutCallableProcessingInterceptor timeoutInterceptor() {return new TimeoutCallableProcessingInterceptor();}@Beanpublic ThreadPoolTaskExecutor threadPoolTaskExecutor() {ThreadPoolTaskExecutor t = new ThreadPoolTaskExecutor();t.setCorePoolSize(2);t.setMaxPoolSize(3);t.setQueueCapacity(1024);t.setThreadNamePrefix("My-Mvc-Thread-");t.setRejectedExecutionHandler(new ThreadPoolExecutor.CallerRunsPolicy()); //在调用线程，即主线程执行return t;}
}

使用自定义线程池和Future 方式


private static final ThreadPoolExecutor threadPoolExecutor = new ThreadPoolExecutor(cpuNum, cpuNum * 2, 0L,TimeUnit.MILLISECONDS, new LinkedBlockingQueue<Runnable>(1024));/*** 使用配置bean 自定义线程池，返回submit.get() 要放到最后一行，不阻塞主线程* @param request* * */
@GetMapping("/test2")@ResponseBodypublic  String test2(HttpServletRequest request,@RequestParam (required = true) String name)throws ExecutionException, InterruptedException {log.info("--------start2-----");Future<String> submit = threadPoolExecutor.submit(new Callable<String>() {@Overridepublic String call() throws Exception {Thread.sleep(2000);log.info("当前线程名" + Thread.currentThread().getName());return "hello" + name + "访问 test2";}});log.info("--------end2-----");return submit.get();}

对于没有返回值得任务来说可以使用自定义线程池，也可以使用@Async 异步注解

Spring及Springboot 异步请求相关推荐

SpringBoot异步请求
何为异步请求在Servlet 3.0之前,Servlet采用Thread-Per-Request的方式处理请求,即每一次Http请求都由某一个线程从头到尾负责处理.如果一个请求需要进行IO操作,比如 ...
详解Spring框架的异步请求
文章目录详解Spring框架的异步请求 1.导入响应的jar包(gson) 2.前端请求 3.后端逻辑处理并返回结果详解Spring框架的异步请求在开发过程中有异步请求和同步请求之分. 同步请求 ...
spring mvc对异步请求的处理
在spring mvc3.2及以上版本增加了对请求的异步处理,是在servlet3的基础上进行封装的. 1.修改web.xml <?xml version="1.0" enc ...
Spring Boot 异步请求和异步调用
点击上方"方志朋",选择"设为星标" 回复"666"获取新整理的面试文章一.Spring Boot中异步请求的使用 1.异步请求与同步请求 ...
Spring Boot 异步请求和异步调用，一文搞定！
一.Spring Boot中异步请求的使用 1.异步请求与同步请求特点: 可以先释放容器分配给请求的线程与相关资源,减轻系统负担,释放了容器所分配线程的请求,其响应将被延后,可以在耗时处理完成(例如 ...
springboot服务调用超时_Spring Boot 异步请求和异步调用，一文搞定
一.Spring Boot中异步请求的使用 1.异步请求与同步请求特点: 可以先释放容器分配给请求的线程与相关资源,减轻系统负担,释放了容器所分配线程的请求,其响应将被延后,可以在耗时处理完成(例如 ...
SpringBoot异步调用方法
SpringBoot异步调用方法一.spring boot--使用异步请求,提高系统的吞吐量 https://blog.csdn.net/liuchuanhong1/article/details/ ...
java异步处理_SpringBoot异步开发之异步请求，在高并发的情况下，提高性能
何为异步请求在Servlet 3.0之前,Servlet采用Thread-Per-Request的方式处理请求,即每一次Http请求都由某一个线程从头到尾负责处理.如果一个请求需要进行IO操作,比如 ...
面试官 | SpringBoot 中如何实现异步请求和异步调用？
作者 | 会炼钢的小白龙来源 | cnblogs.com/baixianlong/p/10661591.html 一.SpringBoot中异步请求的使用 1.异步请求与同步请求特点: 可以先释放 ...

Spring及Springboot 异步请求

1.java 异步请求

2.异步请求实现方式

Spring及Springboot 异步请求相关推荐

最新文章

热门文章