webmvc和webflux作为spring framework的两个重要模块,代表了两个IO模型,阻塞式和非阻塞式。
1、webmvc
webmvc是基于servlet的阻塞式模型,一个请求到达服务器后会单独分配一个线程去处理请求,如果请求包含IO操作,线程在IO操作结束之前一直处于阻塞等待状态,这样线程在等待IO操作结束的时间就浪费了。
2、webflux
webflux是一个异步非阻塞式的 Web 框架,它能够充分利用多核 CPU 的硬件资源去处理大量的并发请求。
webflux内部使用的是响应式编程(Reactive Programming),以 Reactor 库为基础,基于异步和事件驱动,可以让我们在不扩充硬件资源的前提下,提升系统的吞吐量和伸缩性。
Reactor 是一个反应式库,用于根据反应式流规范在 JVM 上构建非阻塞应用。它是完全非阻塞的,支持在 Netty,Undertow 和 Servlet 3.1+容器等服务器上运行。
Reactor 项目提供两种类型的发布者:
- Flux 是产生 0 到 N 个值的发布者,返回多个元素的操作使用此类型;
- Mono 是产生 0 到 1 值的发布者,它用于返回单个元素的操作;
3、webflux实例
添加依赖
<dependency>
<groupId>org.springframework.boot</groupId>
<artifactId>spring-boot-starter-webflux</artifactId>
</dependency>
添加controller
@Slf4j
@RestController
@RequestMapping("/api/user")
public class UserReactiveController {
@RequestMapping(value = "/hello")
public Mono<Object> hello(@RequestParam(name = "name") String name) {
log.info("方法 hello 被调用了");
return Mono.just("hello webflux " + name);
}
}
测试
4、小结
- WebFlux 并不能使接口的响应时间缩短,它仅仅能够提升吞吐量和伸缩性;
- WebFlux内部使用的是响应式编程,以Reactor库为基础,基于异步和事件驱动,特别适合应用在IO密集型的服务中,如网关;
- WebFlux并不是Spring MVC的替代方案;
- WebFlux默认情况下使用Netty作为服务器,不支持MySQL;
- WebFlux的前端控制器是DispatcherHandler,而Spring MVC是DispatcherServlet;
- WebFlux支持两种编程风格,一种是Spring MVC的注解形式,另一种就是Java 8 Lambda函数式编程;
- Reactor类型:Mono返回0或者1个元素,即单个对象;Flux返回N个元素,即List列表对象;
- Webflux中没有拦截器这个概念,要做类似的工作需要在过滤器中完成,项目中我们用到Token验证,使用方法是注册过滤器;
- Webflux中可以使用@ControllerAdvice注册全局异常处理器,但它仅Controller中抛出的异常生效,无法顾及到过滤器。对异常,推荐的方式是注册WebExceptionHandler;