springwebflux原理（spring webflux原理）

大家好，我是讯享网，很高兴认识大家。

 <svg xmlns="http://www.w3.org/2000/svg" style="display: none;"> <path stroke-linecap="round" d="M5,0 0,2.5 5,5z" id="raphael-marker-block" style="-webkit-tap-highlight-color: rgba(0, 0, 0, 0);"></path> </svg> <p></p>

讯享网

官方文档：https://docs.spring.io/spring-framework/docs/current/reference/html/web-reactive.html

是Spring5添加新的模块，用于web开发的，功能和SpringMVC类似的，WebFlux使用当前一种比较流行的出现的框架。使用场景，SpringCloud中的网关。

使用传统web框架，比如SpringMVC，这些基于Servlet容器，WebFlux是一种异步非阻塞的框架，异步非阻塞的框架在Servlet3.1以后才支持，是基于的相关API实现的。

异步同步
非阻塞和阻塞
上面都是针对对象不一样
异步和同步针对，发送请求，如果等着对方回应之后才去做其他事情就是同步，如果发送请求之后不等着对方回应就去做其他事情就是异步。。
阻塞和非阻塞针对，被调用者收到请求之后，做完请求任务之后才给出反馈就是阻塞，收到请求之后，马上给出反馈，然后去做事情就是非阻塞。。

讯享网

在这里插入图片描述

两个框架都可以使用注解方式，都运行在Tomcat等容器中
SpringMVC采用，WebFlux采用

简称RP（Reactive Programming）
是一种面向和变化传播的。这意味着可以在编程语言中很方便地表达静态或动态的数据流，而相关的计算模型会自动将的值通过进行。
电子表格程序就是响应式编程的一个例子。单元格可以包含字面值或类似"=B1+C1"的公式，而包含公式的单元格的值会依据其他单元格的值的变化而变化。
在这里插入图片描述

提供的两个类，和

讯享网

(1)响应式编程操作中，Reactor式满足Reactive规范
（2）Reactor有两个核心类，Mono和Flux，这两个类实现接口Publisher，提供丰富操作符。Flux对象实现发布者，返回N个元素；Mono实现发布者，返回0或者一个元素
(3)Flux和Mono都是数据流的发布者，使用Flux和Mono都可以发出三种数据信号：元素值、错误信号、完成信号，错误信号和完成信号都代表终止信号，终止信号用于告诉订阅者数据流结束了，错误信号终止数据流同时把错误信息传递给订阅者。
（4）代码演示Flux和Mono
第一步引入依赖

第二步编写代码

讯享网

（5）三种信号特点

错误信号和完成信号都是终止信号，不能共存
如果没有发送任何元素值，而是直接发送错误或者完成信号，表示是空数据流
如果没有错误信号，没有完成信号，表示是无限数据流

SpringWebFlux基于Reactor，默认使用容器是Netty，Netty是高性能的框架，异步非阻塞的框架
（1）Netty
BIO 阻塞
在这里插入图片描述
NIO非阻塞

（2）SpringWebflux执行过程和SpringMVC相似的

SpringWebflux核心控制器DispatchHandler，实现接口WebHandler
接口WebHandler有一个方法

（3）SpringWebflux里面DispatcherHandler，负责请求的处理

HandlerMapping：请求查询到处理的方法
HandlerAdapter：真正负责请求处理
HandlerResultHandler：响应结果处理
(4)SpringWebflux实现函数式编程，两个接口：RouterFunction(路由处理)和HandlerFunction（处理函数）

SpringWebflux实现方式有两种：注解编程模型和函数式编程模型
使用注解编程模型方式，和之前SpringMVC使用相似的，只需要把相关依赖配置到项目中，SpringBoot自动配置相关运行容器，默认情况下使用Netty服务器。
第一步创建SpringBoot工程，引入webFlux依赖

讯享网

第二步配置启动端口号

第三步创建包和相关类

实例类

讯享网

创建接口定义操作的方法

接口实现类

讯享网

创建controller

方式实现，同步阻塞的方式，基于
方式实现，异步非阻塞方式，基于

springwebflux原理（spring webflux原理）

相关推荐