自己做个网站多少钱,seo系统培训班,自学ui设计需要哪些资料,优秀手机网站版式Flux 和 Mono区别
在工作中#xff0c;看到导师写项目的时候用到了Flux和Mono。知识盲区了。随后去查了相关的技术信息。很遗憾说的有点太官方了。没有看懂。中午就餐之后#xff0c;就问导师这两个是什么意思#xff0c;以及什么区别。废话不多说#xff0c;总结一下看到导师写项目的时候用到了Flux和Mono。知识盲区了。随后去查了相关的技术信息。很遗憾说的有点太官方了。没有看懂。中午就餐之后就问导师这两个是什么意思以及什么区别。废话不多说总结一下
什么是Flux呢
Flux代表一个包含零个或多个元素的异步序列。你可以将其视为一种异步的、可以包含多个元素的容器。通常用于处理多个并行的异步操作或者事件流。
什么是Mono
Mono代表一个包含零个或一个元素的异步序列。你可以将其视为一种异步的、最多包含一个元素的容器。通常用于处理只会产生一个结果的异步操作。 在响应式编程中Flux和Mono是Reactor库中的两个核心类用于处理异步数据流。Flux用于处理多个元素的情况而Mono则用于处理单个元素的情况。
为什么要使用它们呢
使用Flux和Mono有几个好处
异步编程简化Flux和Mono提供了简洁的API使异步编程更加容易。通过使用这两个类你可以轻松地处理异步操作而不必担心回调或者复杂的线程管理。响应式编程Flux和Mono是响应式编程的核心概念。它们允许你以声明性的方式处理数据流并且能够方便地应对数据流的变化和处理多个并发事件。组合操作Flux和Mono提供了丰富的操作符可以方便地对数据流进行转换、过滤、合并等操作。这些操作符使得对数据流进行复杂的处理变得简单和高效。异步和并发Flux和Mono可以很容易地与Java的异步和并发框架集成比如CompletableFuture和Java 8的CompletableFuture。这使得在异步和并发场景中使用Flux和Mono变得更加方便和灵活。
怎么使用它们呢
在Java项目中使用Flux和Mono是使用Project Reactor库的常见操作。Project Reactor是一个用于构建基于响应式编程的库它提供了Flux和Mono两个主要的数据类型分别用于多个值和单个值的响应式流。
提供一个小示例代码
演示如何使用各种操作符来处理响应式流 1.首先需要在java中引入依赖
dependencygroupIdio.projectreactor/groupIdartifactIdreactor-core/artifactIdversion3.4.11/version
/dependency2.在代码中使用Flux和Mono
import reactor.core.publisher.Flux;
import reactor.core.publisher.Mono;import java.util.Arrays;
import java.util.List;public class ECommercePlatform {// 模拟从数据库中获取产品列表public static FluxProduct getProductsFromDatabase() {ListProduct products Arrays.asList(new Product(1, Laptop, 1000),new Product(2, Smartphone, 800),new Product(3, Headphones, 200),new Product(4, Tablet, 600));return Flux.fromIterable(products);}// 模拟从外部API获取特价产品信息public static FluxProduct getSpecialOffers() {ListProduct specialOffers Arrays.asList(new Product(5, Smartwatch, 300),new Product(6, Camera, 700));return Flux.fromIterable(specialOffers);}// 模拟从消息队列获取新产品通知public static MonoProduct getNewProductNotification() {// 假设我们每次只收到一条新产品通知return Mono.just(new Product(7, Speaker, 150));}public static void main(String[] args) {// 从各个数据源获取产品信息并合并成一个FluxFluxProduct allProducts Flux.concat(getProductsFromDatabase(),getSpecialOffers(),getNewProductNotification());// 过滤出价格低于500的产品FluxProduct filteredProducts allProducts.filter(product - product.getPrice() 500);// 按价格升序排序产品FluxProduct sortedProducts filteredProducts.sort((p1, p2) - p1.getPrice() - p2.getPrice());// 订阅最终的产品流并处理每个产品sortedProducts.subscribe(product - System.out.println(Product: product));}static class Product {private int id;private String name;private int price;public Product(int id, String name, int price) {this.id id;this.name name;this.price price;}public int getId() {return id;}public String getName() {return name;}public int getPrice() {return price;}Overridepublic String toString() {return Product{ id id , name name \ , price price };}}
}我们首先从数据库、外部API和消息队列中获取产品信息然后使用concat操作符将它们合并成一个Flux。然后我们使用filter操作符过滤出价格低于500的产品再使用sort操作符按价格升序对产品进行排序。最后我们订阅最终的产品流并打印每个产品的信息。
第二问题
其中提到并发和异步那就来加一个同步和异步并发和并行的区别吧
同步:指的是任务按照顺序依次执行一个任务的执行需要等待上一个任务完成后才能开始。在同步操作中如果一个任务阻塞比如等待I/O操作完成则整个线程都会被阻塞直到任务完成。
如果看不懂举一个例子理解假设你在食堂排队打饭每个人依次进行。当你的轮到时你需要等待前面的人依次打饭完成才能轮到你。这就是同步的典型例子因为你必须等待前面的任务其他人打饭完成后才能执行你自己的任务打饭。
异步:指的是任务可以独立执行不需要等待其他任务完成。在异步操作中一个任务的执行不会阻塞其他任务的执行可以继续执行其他任务或者等待任务完成的通知。异步操作通常通过回调函数、Promise、async/await等方式来处理。
例子理解现在假设食堂引入了预约打饭的系统。你可以提前在手机上预约打饭的时间并在预约的时间点到达食堂直接取饭而无需排队等待。这种情况下你的打饭操作与其他人的打饭操作是独立的你不需要等待其他人完成打饭因此是异步的。
并发:指的是多个任务在同一个时间段内交替执行。虽然这些任务可能在同一时刻都在执行但实际上它们可能会分时执行通过时间片轮转等方式来实现。 例子理解假设食堂只有一条打饭线但有多个人排队。每个人都在等待自己的食物被准备好但是厨师可能会交替地为每个人准备食物因此在某一时刻多个人都在等待他们的食物这就是并发。尽管只有一个厨师但是他可以交替为不同人准备食物实现了并发操作。并行:指的是多个任务同时执行每个任务都在独立的处理器上执行不会相互干扰。并行可以通过多核处理器、分布式系统等方式来实现。
例子理解现在假设食堂有多条打饭线每条线路都有自己的厨师。这样多个人可以同时打饭每个人的打饭操作都在独立的线路上进行彼此互不影响。这就是并行操作因为多个任务打饭操作同时进行每个任务都在独立的线路上并行执行。 加油伙伴
