给软件行业带来了春天——揭秘Spring究竟是何方神圣（五）

系列文章目录

给软件行业带来了春天——揭秘Spring究竟是何方神圣（一）
给软件行业带来了春天——揭秘Spring究竟是何方神圣（二）
给软件行业带来了春天——揭秘Spring究竟是何方神圣（三）
给软件行业带来了春天——揭秘Spring究竟是何方神圣（四）
给软件行业带来了春天——揭秘Spring究竟是何方神圣（五）

文章目录

在这里插入图片描述

Webflux

简介

webflux是spring推出的响应式web框架，它的对标产品为spring-mvc, 与传统的spring-mvc相比较，webflux是完全非阻塞式的。
image.png

Webflux 特点：
第一 非阻塞式：在有限资源下，提高系统吞吐量和伸缩性，以 Reactor 为基础实现响应式编程。
第二 函数式编程：Spring5 框架基于 java8，Webflux 使用 Java8 函数式编程方式实现路由请求。

同步与异步，阻塞与非阻塞
同步：调用者发送请求，一直等待回应再去做其他的事情。
异步，调用者发送请求，不等对方回应就去做其他事情。

阻塞，被调用者受到请求之后，做完请求任务之后才给出反馈
非阻塞，被调用者受到请求之后，马上给出反馈再去做事情。

响应式编程

响应式编程是一种编程示例，可促进异步，非阻塞，事件驱动的数据处理方法。 响应式编程涉及将数据和事件建模为可观察的数据流，并实现数据处理例程以对这些流中的更改做出反应。

响应式编程可以理解为，当某一主题发生改变时，观察此主题的观察者就会立刻收到通知并做出一系列相应。
举个例子，在一个数据系统中，如果数据发生了变化，就会触发相应一系列的变化，数据改变，数据访问层发生变化，业务逻辑层发生变化 ，控制器发生变化，UI也做出相应的变化。

观察者模式

public class Observe extends Observable {
    public static void main(String[] args){

        Observe observe=new Observe();

        /*
        * 响应式编程
        * */
        //添加观察者
        observe.addObserver((o,arg)->{
            System.out.println("实施改变");
        });

        observe.addObserver((o,arg)->{
            System.out.println("接受通知，准备改变");
        });

        observe.setChanged();//数据变化
        observe.notifyObservers();//通知
    }
}

SpringWebflux 基于 Reactor，默认使用容器是 Netty，Netty 是高性能的 NIO 框架，异步非阻塞的框架。

NIO是一种同步非阻塞的I/O模型，也是I/O多路复用的基础，已经被越来越多地应用到大型应用服务器，成为解决高并发与大量连接、I/O处理问题的有效方式。

NIO
image.png

在响应式编程操作中，Reactor 是满足 Reactive 规范框架。Reactor 有两个核心类，Mono 和 和 Flux ，这两个类实现接口 Publisher，提供丰富操作 ，提供丰富操作符。

  • Flux 对象实现发布者，返回 N 个元素；
  • Mono 实现发布者，返回 0 或者 1 个元素

Flux示意图：
image.png
Mono示意图：
image.png
引入依赖

<!--flux响应式编程-->
    <dependency>
      <groupId>io.projectreactor</groupId>
      <artifactId>reactor-core</artifactId>
      <version>3.1.15.RELEASE</version>
    </dependency>

public class flux {
    public static void main(String[] args){

        //flux 返回多个元素
        //mono 返回0或1个元素
        Flux.just(1,2,3,4).subscribe(System.out::println);
        Mono.just(1).subscribe(System.out::println);

        Integer[] arr={1,2,3};
        Flux.fromArray(arr);

        List<Integer> list= Arrays.asList(arr);
        Flux.fromIterable(list);

        Stream<Integer> stream=list.stream();
        Flux.fromStream(stream);
    }
}

使用

导入依赖

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

基于注解的webflux

@GetMapping("/mono")
public Mono<String> mono(){
	return Mono.just("mono");
}

@GetMapping("/flux")
public Flux<String> flux(){
 return Flux.just("flux");
}

基于函数式编程的webflux
创建RouterFunction，将其注入到Spring中即可。

@Bean
pubulic RouterFuntion<ServerResponse> test01(){
 return RouterFuntions.route().Get("/flux/function",new HandlerFunction<ServerResponse>(){
	@Override
  public Mono<ServerResponse> handle(ServerRequest requrest){
      	return ServerResponse.ok().bodyValue("hello");
  }
 }).build();
}

flux与Mono的相应式编程延迟案例

@GetMapping("/test")
public Mono<String> stringMono(){
	Mono<String> from=Mono.fromSupplier(() -> {
  	try{
    	TimeUnit.SECONDS.sleep(5);
    }catch(InterruptedException e){
        	throw new RuntimeException(e);
    }
  	return "hello"+LocalDateTime.now();
  });
  	return from;
}

在这个关于 Spring揭秘系列文章中，我们深入探讨了Spring 框架中的各种核心特性以及在实际中的运用。作为这个系列的最后一篇文章，Spring WebFlux 的出现为我们开发者提供了一种全新的方式去构建高性能、响应迅速的应用程序。其灵活性和强大的响应式特性为我们打开了通往未来的大门。

在这里插入图片描述