在现代的Web开发中，对于高性能和可伸缩性的需求越来越高。为了满足这些需求，Spring Framework引入了Spring WebFlux，这是一种基于Reactive Streams的非阻塞响应式编程模型。
在Spring WebFlux中，Mono和Flux是两个核心的类型，用于处理异步和非阻塞的操作。它们是响应式编程中的基本构建块，可以用于处理单个值（Mono）或多个值（Flux）的流。
Mono： Mono代表一个包含零个或一个元素的异步序列。它类似于Java 8中的Optional，但具有额外的异步能力。Mono的特点是只能发出一个元素，或者在没有元素的情况下表示完成状态。可以使用Mono来处理一次性的结果，例如从数据库查询或远程调用中获取单个对象。
下面是一个使用Mono的简单示例：
Mono
mono.subscribe(value -> System.out.println(value));
在上面的例子中，我们创建了一个包含字符串"Hello"的Mono对象，并通过subscribe方法订阅它。一旦Mono发出值，我们的订阅者将打印出该值。
Flux： Flux代表一个包含零个或多个元素的异步序列。它类似于Java 8中的Stream，但是具有非阻塞和异步的特性。Flux可以用于处理多个值的流，例如从消息队列中获取一系列消息或从文件中读取一行行的数据。
下面是一个使用Flux的简单示例：
Flux
flux.subscribe(value -> System.out.println(value));
在上面的例子中，我们创建了一个包含数字1到5的Flux对象，并通过subscribe方法订阅它。一旦Flux发出值，我们的订阅者将打印出每个值。
使用Mono和Flux的好处是它们通过异步和非阻塞的方式处理数据流，从而提供了更好的性能和可伸缩性。在Spring WebFlux中，您可以使用这些类型来处理HTTP请求和响应，以实现高效的Web应用程序。
在JDK9中开始引入了响应式编程模型，而spring5.0版本之后正式引入对webflux的支持，即spring webflux，spring webflux是spring在5.0版本后提供的一套响应式编程风格的web开发框架
以及个人写了一个最为简单的demo供大家学习
首先，在您的项目中添加Spring WebFlux的依赖项。您可以使用Maven或Gradle等构建工具来管理依赖关系。以下是使用Maven的示例：
创建处理器： 接下来，您需要创建一个处理器类来处理HTTP请求。处理器类应该使用@RestController或@Controller注解进行标记，并使用@RequestMapping或其他相关注解来定义处理请求的方法 ：
import org.springframework.web.bind.annotation.GetMapping;
import org.springframework.web.bind.annotation.RestController;
import reactor.core.publisher.Flux;
@RestController
public class MyController {
@GetMapping("/hello")
public Mono
return Mono.just("Hello, World!");
}
@GetMapping("/numbers")
public Flux
return Flux.just(1, 2, 3, 4, 5);
}
@GetMapping("/names")
public Flux
return Flux.fromArray(new String[]{"Alice", "Bob", "Charlie"});
}
}
在上面的示例中，我们创建了一个简单的处理器类，并使用@GetMapping注解来定义了一个处理GET请求的方法。
配置路由： 为了将请求映射到正确的处理器方法，您需要配置路由。在Spring WebFlux中，您可以使用RouterFunction或@RequestMapping注解来定义路由。
import org.springframework.context.annotation.Bean;
import org.springframework.context.annotation.Configuration;
import org.springframework.http.MediaType;
import org.springframework.web.reactive.function.server.HandlerFunction;
import org.springframework.web.reactive.function.server.RequestPredicates;
import org.springframework.web.reactive.function.server.RouterFunction;
import org.springframework.web.reactive.function.server.RouterFunctions;
import org.springframework.web.reactive.function.server.ServerResponse;
import reactor.core.publisher.Flux;
import reactor.core.publisher.Mono;
@Configuration
public class MyRouter {
@Bean
public RouterFunction
return RouterFunctions.route()
.GET("/hello", request -> myController.hello())
.GET("/numbers", request -> myController.numbers().collectList().flatMap(ServerResponse.ok()::bodyValue))
.GET("/names", request -> myController.names().collectList().flatMap(ServerResponse.ok()::bodyValue))
.build();
}
}
启动应用程序： 最后，您需要启动Spring应用程序。您可以使用SpringApplication.run方法或其他方式来启动应用程序。
@SpringBootApplication
public class MyApplication {
public static void main(String[] args) {
SpringApplication.run(MyApplication.class, args);
}
}
总结： Spring WebFlux中的Mono和Flux是响应式编程的核心概念。Mono用于表示一个包含零个或一个元素的异步序列，而Flux用于表示一个包含零个或多个元素的异步序列。它们提供了非阻塞和异步的能力，可以用于处理单个值或多个值的流。通过使用这些类型，您可以构建高性能和可伸缩的Web应用程序。
推荐文章
您阅读本篇文章共花了：
发表评论