Spring-webflux简介

spring-webflux 是spring在5.0版本后提供的一套响应式编程格调的web开发框架。

这个框架蕴含了 spring-framework 和spring mvc，它能够运行在Netty、Undertow以及3.1版本以上的Serlvet容器上。

你能够在我的项目中同时应用 spring-webmvc 和 spring-webflux ，或者只用其中一个来开发web利用。

什么是“响应式”

所谓响应式，举个例子，当调用一个api获取数据时，无需阻塞期待数据返回，而是当有数据返回时会进行告知。可见响应式是非阻塞的，意味着调用办法后，CPU能够去做别的事件，当接管到数据响应时CPU再回来解决，这种形式进步了零碎的吞吐量。

而响应式编程，其实是为这种异步非阻塞的流式编程制订的一套规范。流式编程已不生疏了，Java8提供的stream api就是这种格调。这套规范包含对运行环境（JVM、JavaScript）以及网络协议相干的标准。

Spring-webflux的响应式API

Spring-webflux 框架是基于Reactor这个开源我的项目开发的。Reactor框架是跟Spring紧密配合的。

它提供了两种API类型，别离是Mono和Flux；

// Mono个别作用于单个对象Mono<Person> person = personDao.getPerson(personId);// Flux个别作用于多个对象Flux<Person> people = personDao.listAllPeople();

只管webflux框架基于Reactor，它也能与其余的响应式框架同时应用，比方RxJava。

抉择Spring-webmvc还是Spring-webflux呢

这两个web框架别离代表着两种不同类型的编程流派，官网给出了一个图作为比照如下

依据官网的倡议有以下几点能够作为参考：

  • 如果你曾经应用了 Spring-webmvc 进行开发，并且我的项目运行良好，就无需更改了；何况当初大多数的三方库都是阻塞的，并不能施展出非阻塞的劣势。
  • webflux 提供了相当多的抉择；在服务层，能够应用(Netty, Tomcat, Jetty, Undertow, 和3.1版本以上的Servlet容器)作为web服务；在应用层，能够抉择用 @Controller 定义还是应用函数编程定义；在编程格调上，能够抉择用Reactor、RxJava或其余。
  • 如果你钟爱Java8提供的lambda表达式这种轻量级、函数式的编程格调，那么倡议抉择用webflux；同时对于一些轻量级利用，或者复杂度比拟低的微服务，倡议应用webflux以便更好的进行管制。
  • 在微服务架构中，能够将webmvc和webflux我的项目混合应用。两个框架都能够应用 @Controller 这种注解的形式，使得我的项目的重用更加容易。
  • 评估一个我的项目是否应该抉择webflux的最简略的形式是，根据我的项目中是否会应用很多的阻塞API，比方JDBC或者一些阻塞式的API就不实用与webflux我的项目。
  • 如果一个webmvc我的项目中有很多的内部零碎调用，能够试试响应式的 WebClient ，它能间接从 Controller 的办法中返回响应式后果。
  • 响应式编程的学习路线是比拟平缓的，所以如果你身在一个大型的团队中，要思考投入的老本；不过能够用用 WebClient 来体验下响应式编程。

Spring-webflux 不仅能够反对在Tomcat、Jetty以及3.1版本以上的Servlet容器上，还可能运行在非Servlet的服务器之上，比方Netty、Undertow等。

应用Springboot构建一个webflux利用，默认就是应用Netty，因为Netty自身就是非阻塞式的实现。

并发模型

只管webmvc和webflux都反对应用注解来定义一个Controller，然而其实现形式齐全不同。

webmvc是一个Servlet利用，实现是阻塞式IO，其保护一个线程池来解决每一个用户申请，也就是当Servlet容器启动时，就会创立比方10个线程进去，因而零碎吞吐量的瓶颈在于无限的连接数和阻塞的申请处理过程。

webflux能够基于netty这样的NIO网络框架，它只须要很少的几个工作线程（Event loop worker）就可能解决并响应申请。因为无需阻塞期待办法返回，CPU资源就失去了更好的利用。

webflux并不能让程序运行地更快；而是进步了并发解决申请的能力，即进步了零碎吞吐量。

webflux代码示例

Talk is cheap, show me the code

上面让咱们来看一下webflux的示例，总的来说应用上是十分便捷的。

咱们用Springboot构建一个webflux利用非常简单，仅仅须要退出这么一个依赖

<dependency> <groupId>org.springframework.boot</groupId> <artifactId>spring-boot-starter-webflux</artifactId></dependency>

首先定义一个对象

public class Person {    private Integer id;    private Integer age;    private String name;}

而后定义“ PersonController ”，响应式格调中不再应用 @RequestMapping 申明地址映射了，而是通过 RouterFunctions.route().GET() 办法

@Configurationpublic class PersonRouter {    @Resource    private PersonHandler personHandler;    @Bean    public RouterFunction<ServerResponse> personRoutes() {        return RouterFunctions.route()                .GET("/person/{id}", RequestPredicates.accept(MediaType.APPLICATION_JSON), personHandler::getPerson)                .GET("/person", RequestPredicates.accept(MediaType.APPLICATION_JSON), personHandler::listPeople)                .POST("/person", personHandler::createPerson)                .build();    }}

在 PersonHandler 中解决对应的HTTP申请，等同于MVC架构中的Service层

@Componentpublic class  PersonHandler {    @Resource    private PersonRepository personDao;    public Mono<ServerResponse> listPeople(ServerRequest request) {        Flux<Person> people = personDao.listAllPeople();        return ServerResponse.ok()                .contentType(MediaType.APPLICATION_JSON)                .body(people, Person.class);    }    public Mono<ServerResponse> createPerson(ServerRequest request) {        Mono<Person> person = request.bodyToMono(Person.class);        return ServerResponse.ok()                .build(personDao.savePerson(person));    }    public Mono<ServerResponse> getPerson(ServerRequest request) {        int personId = Integer.parseInt(request.pathVariable("id"));        return personDao.getPerson(personId)                .flatMap(person -> ServerResponse.ok().contentType(MediaType.APPLICATION_JSON).bodyValue(person))                .switchIfEmpty(ServerResponse.notFound().build());    }}

通过启动日志能够证实 Spring-webflux 是默认应用Netty提供HTTP服务

我的项目启动之后浏览器拜访 http://localhost:8080/person/1 就能发现，你的Spring-webflux我的项目曾经失常工作了。