1、SpringWebflux的介绍
(1)、SpringWebflux是Spring5中添加的新模块,用于web开发,功能和SpringMVC相似,Webflux使用的是响应式编程方式
(2)、Webflux是一种异步非阻塞的框架
(3)、非阻塞和阻塞、异步和同步
异步和同步是针对调用者的,调用者发送请求。如果调用者等待对方回应之后才去做其他事情,就是同步;如果发送请求之后不等待对方的回应,而是接着做其他的事情,就是异步。
阻塞和非阻塞是针对被调用者的,被调用者在接收到请求之后,在完成请求任务之后才给出反馈的,就是阻塞;如果收到请求之后先给出反馈,然后再去完成请求任务的,就是非阻塞
(4)、Webflux的特点:
第一,非阻塞式:在有限资源下,提高系统吞吐量和伸缩性,以Reactor为基础实现响应式编程
第二,函数式编程:webflux使用函数式编程方式实现路由请求
(5)、SpringWebflux和SpringMVC的比较
SpringMVC方式实现:
同步阻塞,基于SpringMVC+Servlet+Tomcat
SpringWebflux方式实现:
异步非阻塞,基于SpringWebflux+Reactor+Netty
2、响应式编程(Reactor实现)
(1)、Reactor有两个核心类,Mono和Flux,者两个类实现接口Publisher。Flux对象实现发布者,返回N个元素;Mono实现反发布者,返回0或者1个元素。
(2)、Flux和Mono都是数据流的发布者,可以发出三种信号:元素值、错误信号和完成信号。错误信号和完成信号代表终止信号,终止信号用于告诉订阅者数据流结束了,错误信号终止数据流,同时,把错误信息传递给订阅者。
(3)、三种信号的特点:
错误信号和完成信号都是终止信号,不能共存
如果没有发送任何元素值,而是直接发送错误信号或者完成信号,表示是空数据
如果没有错误信号,没有完成信号,表示是无限数据流
(4)、操作符
第一,map元素映射为项元素
第二,flatMap元素映射为流(把每个元素转换为流,把转换之后的流合并为大的流)
(3)、编程实现
第一步,引入依赖
io.projectreactor reactor-core 3.1.5.RELEASE第二步,编写相关的代码(这里直接在main方法进行实现),同时,需要使用subscript方法 进行订阅之后才能打印输出
import reactor.core.publisher.Flux;
import reactor.core.publisher.Mono;
import java.util.Arrays;
import java.util.List;
import java.util.stream.Stream;
public class TestReactor {
public static void main(String[] args) {
//just方法直接声明
Flux.just(1,2,3,4).subscribe(System.out::print);
System.out.println();
Mono.just(1).subscribe(System.out::print);
//其他方法
//1、数组
Integer [] array={1,2,3,4};
Flux.fromArray(array);
//2、集合
List<Integer> list= Arrays.asList(array);
Flux.fromIterable(list);
//3、Stream流
Stream<Integer> stream=list.stream();
Flux.fromStream(stream);
}
}
3、SpringWebflux执行流程和核心API
SpringWebflux基于Reactor,默认使用Netty,Netty是高性能的NIO框架,异步非阻塞的框架
(1)、NIO和BIO
BIO:
NIO:
(2)、SpringWebflux执行过程和SpringMVC是相似的,SpringWebflux核心控制器DispatchHandler,实现接口WebHandler
(3)、SpringWebflux中的DispatcherHandler,负责请求的处理
HandlerMapping:请求查询到处理方法
HandlerAdapter:真正的负责请求处理
HandlerResultHandler:响应结果处理
(4)、SpringWebflux实现函数式编程,提供了两个接口:RouteFunction(路由处理)和HandlerFunction(处理函数)
Spring 5.0 WebFlux 应用场景分享:
http://www.javashuo.com/article/p-ryevkraz-dw.html
JAVA QQ技术群(984253785)