Spring Web MVC框架(三) 异步处理

简介: 前面介绍的处理方法都是同步的,意味着所有操作都在一个线程中完成。有时候处理流程可能很长,可能需要长时间的IO,这时候同步处理方法会白白占用处理器资源。这样就需要异步处理方法。

前面介绍的处理方法都是同步的,意味着所有操作都在一个线程中完成。有时候处理流程可能很长,可能需要长时间的IO,这时候同步处理方法会白白占用处理器资源。这样就需要异步处理方法。

启用异步请求

要启用异步处理功能,我们要打开DispatcherServlet的异步支持。在web.xml中添加<async-supported>true</async-supported>即可。web.xml最低必须是3.0的。

<servlet>
    <servlet-name>dispatcher</servlet-name>
    <servlet-class>org.springframework.web.servlet.DispatcherServlet</servlet-class>
    <load-on-startup>1</load-on-startup>
    <async-supported>true</async-supported>
</servlet>

异步方法的返回值

异步处理方法需要返回一个Callable。这种情况下最终的返回值会由一个Spring管理的线程生成。这种情况很适合IO阻塞的情况,例如读写大文件,读写数据库等等。

@PostMapping
public Callable<String> processUpload(final MultipartFile file) {

    return new Callable<String>() {
        public String call() throws Exception {
            // ...
            return "someView";
        }
    };

}

另外一种方式是返回一个DeferredResult,这时候返回结果的线程可以使任何线程,不一定是Spring MVC管理的线程,例如消息队列、计划任务等等。

@RequestMapping("/async")
@ResponseBody
public DeferredResult<String> async() {
    DeferredResult<String> result = new DeferredResult<>();
    Runnable task = () -> {
        try {
            Thread.sleep(5000);
            result.setResult("result");
        } catch (InterruptedException e) {
            e.printStackTrace();
        }
    };
    new Thread(task).start();
    return result;
}

异步处理的异常

简单地说异步代码如果发生异常,情况和控制器直接抛出异常是一样的,异常同样会经过Spring的异常处理流程。对于返回DeferredResult的方法来说,其他线程可以选择返回正常结果(setValue方法)或者返回异常(setErrorResult方法)。

异步请求的拦截

HandlerInterceptor可以同时实现AsyncHandlerInterceptorafterConcurrentHandlingStarted回调,也可以注册CallableProcessingInterceptorDeferredResultProcessingInterceptor 来进行更详细的控制。

DeferredResult提供了一些方法例如onTimeout(Runnable)onCompletion(Runnable)。如果使用Callable,也可以将其包装到WebAsyncTask中,同样提供了超时和完成回调的支持。

HTTP流

使用HTTP流可以向一个响应返回多个值。这时候让方法返回ResponseBodyEmitterResponseBodyEmitter可以由任意线程发送至,然后由HttpMessageConverter转换为合适的类型返回给响应。

@RequestMapping("/stream")
public ResponseBodyEmitter stream() {
    ResponseBodyEmitter emitter = new ResponseBodyEmitter();
    Runnable task = () -> {
        try {
            emitter.send("Hello guy");
            emitter.send("Bye");
            emitter.complete();
        } catch (IOException e) {
            e.printStackTrace();
        }
    };
    new Thread(task).start();
    return emitter;
}

有时候可能需要直接操作二进制流。这时候可以让方法返回StreamingResponseBody,Spring会将二进制流直接返回给客户端。这种方法可以用来向客户端发送图片等数据。

@RequestMapping("/streamBody")
public StreamingResponseBody streamBody() {
    return (output) -> {
        output.write("123456".getBytes());
    };
}

配置异步请求

配置Servlet容器

要启用异步请求,我们需要在web.xml中设置DispatcherServlet和所有参与异步请求的过滤器的异步支持。如果使用Java配置的话,需要在WebApplicationInitializer设置asyncSupported为真,或者更好的办法是继承AbstractAnnotationConfigDispatcherServletInitializer,它已经设置了这些属性,并且让你注册过滤器更加容易。

配置Spring MVC

Spring的代码配置和XML配置提供了配置异步请求的地方,分别是WebMvcConfigurerconfigureAsyncSupport方法和<mvc:annotation-driven><async-support>子元素。我们可以配置的属性有:异步请求的超时时间;异步请求的执行器(我们最好设置这个,因为Spring只是用了最简单的执行器,不一定满足我们的需求);以及注册CallableProcessingInterceptorDeferredResultProcessingInterceptor拦截器。

相关文章
|
5月前
|
缓存 安全 Java
《深入理解Spring》过滤器(Filter)——Web请求的第一道防线
Servlet过滤器是Java Web核心组件,可在请求进入容器时进行预处理与响应后处理,适用于日志、认证、安全、跨域等全局性功能,具有比Spring拦截器更早的执行时机和更广的覆盖范围。
|
5月前
|
前端开发 Java 微服务
《深入理解Spring》:Spring、Spring MVC与Spring Boot的深度解析
Spring Framework是Java生态的基石,提供IoC、AOP等核心功能;Spring MVC基于其构建,实现Web层MVC架构;Spring Boot则通过自动配置和内嵌服务器,极大简化了开发与部署。三者层层演进,Spring Boot并非替代,而是对前者的高效封装与增强,适用于微服务与快速开发,而深入理解Spring Framework有助于更好驾驭整体技术栈。
|
12月前
|
前端开发 Java 测试技术
微服务——SpringBoot使用归纳——Spring Boot中的MVC支持——@RequestParam
本文介绍了 `@RequestParam` 注解的使用方法及其与 `@PathVariable` 的区别。`@RequestParam` 用于从请求中获取参数值(如 GET 请求的 URL 参数或 POST 请求的表单数据),而 `@PathVariable` 用于从 URL 模板中提取参数。文章通过示例代码详细说明了 `@RequestParam` 的常用属性,如 `required` 和 `defaultValue`,并展示了如何用实体类封装大量表单参数以简化处理流程。最后,结合 Postman 测试工具验证了接口的功能。
670 0
微服务——SpringBoot使用归纳——Spring Boot中的MVC支持——@RequestParam
|
6月前
|
存储 安全 Java
如何在 Spring Web 应用程序中使用 @SessionScope 和 @RequestScope
Spring框架中的`@SessionScope`和`@RequestScope`注解用于管理Web应用中的状态。`@SessionScope`绑定HTTP会话生命周期,适用于用户特定数据,如购物车;`@RequestScope`限定于单个请求,适合无状态、线程安全的操作,如日志记录。合理选择作用域能提升应用性能与可维护性。
274 1
|
12月前
|
JSON 前端开发 Java
微服务——SpringBoot使用归纳——Spring Boot中的MVC支持——@RequestBody
`@RequestBody` 是 Spring 框架中的注解,用于将 HTTP 请求体中的 JSON 数据自动映射为 Java 对象。例如,前端通过 POST 请求发送包含 `username` 和 `password` 的 JSON 数据,后端可通过带有 `@RequestBody` 注解的方法参数接收并处理。此注解适用于传递复杂对象的场景,简化了数据解析过程。与表单提交不同,它主要用于接收 JSON 格式的实体数据。
1265 0
|
12月前
|
前端开发 Java 微服务
微服务——SpringBoot使用归纳——Spring Boot中的MVC支持——@PathVariable
`@PathVariable` 是 Spring Boot 中用于从 URL 中提取参数的注解,支持 RESTful 风格接口开发。例如,通过 `@GetMapping(&quot;/user/{id}&quot;)` 可以将 URL 中的 `{id}` 参数自动映射到方法参数中。若参数名不一致,可通过 `@PathVariable(&quot;自定义名&quot;)` 指定绑定关系。此外,还支持多参数占位符,如 `/user/{id}/{name}`,分别映射到方法中的多个参数。运行项目后,访问指定 URL 即可验证参数是否正确接收。
750 0
|
12月前
|
JSON 前端开发 Java
微服务——SpringBoot使用归纳——Spring Boot中的MVC支持——@RequestMapping
@RequestMapping 是 Spring MVC 中用于请求地址映射的注解,可作用于类或方法上。类级别定义控制器父路径,方法级别进一步指定处理逻辑。常用属性包括 value(请求地址)、method(请求类型,如 GET/POST 等,默认 GET)和 produces(返回内容类型)。例如:`@RequestMapping(value = &quot;/test&quot;, produces = &quot;application/json; charset=UTF-8&quot;)`。此外,针对不同请求方式还有简化注解,如 @GetMapping、@PostMapping 等。
673 0
|
12月前
|
JSON 前端开发 Java
微服务——SpringBoot使用归纳——Spring Boot中的MVC支持——@RestController
本文主要介绍 Spring Boot 中 MVC 开发常用的几个注解及其使用方式,包括 `@RestController`、`@RequestMapping`、`@PathVariable`、`@RequestParam` 和 `@RequestBody`。其中重点讲解了 `@RestController` 注解的构成与特点:它是 `@Controller` 和 `@ResponseBody` 的结合体,适用于返回 JSON 数据的场景。文章还指出,在需要模板渲染(如 Thymeleaf)而非前后端分离的情况下,应使用 `@Controller` 而非 `@RestController`
470 0
|
7月前
|
存储 NoSQL Java
探索Spring Boot的函数式Web应用开发
通过这种方式,开发者能以声明式和函数式的编程习惯,构建高效、易测试、并发友好的Web应用,同时也能以较小的学习曲线迅速上手,因为这些概念与Spring Framework其他部分保持一致性。在设计和编码过程中,保持代码的简洁性和高内聚性,有助于维持项目的可管理性,也便于其他开发者阅读和理解。
224 0
|
8月前
|
前端开发 Java API
Spring Cloud Gateway Server Web MVC报错“Unsupported transfer encoding: chunked”解决
本文解析了Spring Cloud Gateway中出现“Unsupported transfer encoding: chunked”错误的原因,指出该问题源于Feign依赖的HTTP客户端与服务端的`chunked`传输编码不兼容,并提供了具体的解决方案。通过规范Feign客户端接口的返回类型,可有效避免该异常,提升系统兼容性与稳定性。
559 0