springboot 学习之路 18(webflux详细介绍(2))

webflux的详细介绍

　　引言:上一节已经简单介绍webflux的一些基本概念，本章继续学习webflux的原理和实战方面的东西：

　　Spring WebFlux架构：

　　　　

　　　　note:注意理解上面这张图。下面解释引用百度

1）服务端技术栈

    Spring提供了完整的支持响应式的服务端技术栈。

            如上图所示，左侧为基于spring-webmvc的技术栈，右侧为基于spring-webflux的技术栈，

            Spring WebFlux是基于响应式流的，因此可以用来建立异步的、非阻塞的、事件驱动的服务。它采用Reactor作为首选的响应式流的实现库，不过也提供了对RxJava的支持。
            由于响应式编程的特性，Spring WebFlux和Reactor底层需要支持异步的运行环境，比如Netty和Undertow；也可以运行在支持异步I/O的Servlet 3.1的容器之上，比如Tomcat（8.0.23及以上）和Jetty（9.0.4及以上）。
            从图的纵向上看，spring-webflux上层支持两种开发模式： 
            类似于Spring WebMVC的基于注解（@Controller、@RequestMapping）的开发模式；
            Java 8 lambda 风格的函数式开发模式。
            Spring WebFlux也支持响应式的Websocket服务端开发。
            由此看来，Spring WebFlux与Vert.x有一些相通之处，都是建立在非阻塞的异步I/O和事件驱动的基础之上的。
2）响应式Http客户端

    此外，Spring WebFlux也提供了一个响应式的Http客户端API WebClient。它可以用函数式的方式异步非阻塞地发起Http请求并处理响应。其底层也是由Netty提供的异步支持。

            我们可以把WebClient看做是响应式的RestTemplate，与后者相比，前者：

            是非阻塞的，可以基于少量的线程处理更高的并发；
            可以使用Java 8 lambda表达式；
            支持异步的同时也可以支持同步的使用方式；
            可以通过数据流的方式与服务端进行双向通信。
            当然，与服务端对应的，Spring WebFlux也提供了响应式的Websocket客户端API。

springboot_webflux   demo案例：

　　根据上面原理图  webflux的实现有两版，一是基于springmvc，一种基于响应式流的，,下面我来逐一介绍一下：（需要学习的尽量跟着我的步骤走，我会把出错的地方标出）

　　基础部分搭建（不管哪种实现，都需要项目准备工作）：

　　　　第一步：引入项目依赖，我后期会演示mongodb的操作，这次一下把依赖都引入：

　　　　　　

　　　　第二步：把allpication.yml 的mongodb配置上，

　　　　　　

　　

从webflux开始，我的demo采用yaml语法的配置文件来讲解，前面采用的都是properties文件，是为了大家方便入门，后期我采用application.yml文件，
　　补充：配置文件的优先顺序： 项目路径下/conf/  > 项目路径下/ > /resources/conf/  >  resources/   (  properties后缀优先 yml文件的加载顺序)

　　1>注解式：

　　　　1>> 只是为了测试，直接写测试控制器了，实战中应该从Handler中获取

　　　　

　　　　2>>  启动springboot项目：

　　　　　　是netty启动，上节介绍过，webflux是响应式框架，默认是netty启动（可以改tomcat toncat8以后已经支持响应式了）

　　　　　　请求测试如下：

　　　　　　

　　　　

Netty是一套异步的、事件驱动的网络应用程序框架和工具，能够开发高性能、高可靠性的网络服务器和客户端程序，因此与同样是异步的、事件驱动的响应式编程范式吻合。
　　在Java 7推出异步I/O库，以及Servlet3.1增加了对异步I/O的支持之后，Tomcat等Servlet容器也随后开始支持异步I/O，然后Spring WebMVC也增加了对Reactor库的支持，
　　所以上边如果不是将spring-boot-starter-web替换为spring-boot-starter-WebFlux，而是增加reactor-core的依赖的话，仍然可以用注解的方式开发基于Tomcat的响应式应用。

　　注解式就简单介绍一下，重点在响应式开发，webflux是响应式框架，我会着重介绍一下响应式开发的步骤。注解式只是spring团队为了更好的迁移而提供给大家的，因为我们都是用上面那种开发方式开发代码　　

　　2>webflux的响应式开发：

　　　　响应式开发主要在handler和route上，handler相当于我们原来使用的 server | controller   官方定义是处理，就是写逻辑代码的地方，而route相当于RequestMapping() 相当于配置映射的地方，官方定义是路由

　　　　2.1>测试handler如下：　（方法应该从数据获取数据进行返回，我只是做测试，就用打印时间代替了）

　　　　　

　　　　2.2> 编辑route　

　　　　　　　

　　　　2.3>启动，测试：

　　　　　　

在WebFlux中，请求和响应不再是WebMVC中的ServletRequest和ServletResponse，而是ServerRequest和ServerResponse。后者是在响应式编程中使用的接口，它们提供了对非阻塞和回压特性的支持，以及Http消息体与响应式类型Mono和Flux的转换方法。

　　　　注意：到这，webflux的响应式开发配置基本搭建完毕，后面会继续介绍mongodb的操作

---

webflux操作mongodb:

　　webflux不支持mysql,　　使用mongodb来进行演示　(mongodb配置已经在准备时配置进去了)　　　

　　第一步：创建实体User

　　　

　　在这个mongodb的启动后，会自动在对应的mongodb中创建一个user集合，名字就是实体类名称小写。

　　第二步：dao实现：　　

　　　　note：与非响应式Spring Data的CrudReposity对应的，响应式的Spring Data也提供了相应的Repository库：ReactiveCrudReposity，当然，我们也可以使用它的子接口ReactiveMongoRepository。

　　　　　　　ReactiveCrudRepository的泛型分别是User和ID的类型；

　　　　

　　第三步：UserHandler(逻辑处理代码)

　　　　

　　第四步：webFlux的注解实现controller: 方便大家上手 （ 响应式后期再说：）

　　　　

　　最后启动测试即可：

　　　　截图不放了。下面我介绍几个问题点：　

---

问题：　

　　1>  怎么验证响应式流：

　　　　

　　　　启动测试就可以发现查询所用是一个一个出来的，而不是一下返回。

　

---

　异步 阻塞的概念还需要大家理解，这是服务端大效果演示，还有一种客户端的演示，待下节介绍