Reactor3 Map与FlatMap的区别示例详解

更新时间：2023年08月23日 17:31:59 作者：Weison Wei

这篇文章主要为大家介绍了Reactor3 Map与FlatMap的区别示例详解,有需要的朋友可以借鉴参考下,希望能够有所帮助,祝大家多多进步,早日升职加薪

Publisher Map 与 FlatMap的区别

环境信息：

JDK: Java 8
Reactor: Reactor 3.2.10.RELEASE

Gradle依赖：

compile group: 'io.projectreactor', name: 'reactor-core', version: '3.2.10.RELEASE'
compile 'ch.qos.logback:logback-classic:1.2.1'
testCompile 'io.projectreactor.addons:reactor-test'
testCompile 'junit:junit:4.12'

这几个代码的效果都一样，打印出11;

Mono.just("1").map(a -> a + "1").subscribe(System.out::println);
Mono.just("1").flatMap(a -> Mono.just(a + "1")).subscribe(System.out::println);
Flux.just("1").map(a -> a + "1").subscribe(System.out::println);
Flux.just("1").flatMap(a -> Flux.just(a + "1")).subscribe(System.out::println);

1 Mono

1.1 map()

Mono<String> monoMap = Mono.just("1").map(a -> a + "1");
monoMap.subscribe(System.out::println);

同步的转换发布的元素并返回。

1.2 flatMap()

Flux<String> monoFlatMap = Mono.just("1").flatMap(a -> Mono.just(a + "1"));
monoFlatMap.subscribe(System.out::println);

异步的转换发布的元素并返回一个新的Mono，被转换的元素和新Mono是动态绑定的。

2 Flux

2.1 map()

Mono<String> fluxMap = Flux.just("1").map(a -> a + "1");
fluxMap.subscribe(System.out::println);

同步的转换发布的元素并返回，转换完后被转换元素被丢弃。

2.2 flatMap()

Flux<String> fluxFlatMap = Flux.just("1").flatMap(a -> Flux.just(a + "1"));
fluxFlatMap.subscribe(System.out::println);

异步的转换发布的元素并他们展开合并到一个新的Flux并返回。

以上就是Reactor3 Map与FlatMap的区别示例详解的详细内容，更多关于Reactor3 Map FlatMap区别的资料请关注脚本之家其它相关文章！

您可能感兴趣的文章:

MyBatis入门程序
MyBatis是支持普通SQL查询，存储过程和高级映射的优秀持久层框架。接下来本文给大家带来了MyBatis入门程序，感兴趣的朋友一起学习吧
2016-08-08
Java中的notyfy()和notifyAll()的本质区别
很多朋友对java中的notyfy()和notifyAll()的本质区别不了解，今天小编抽空给大家整理一篇教程关于Java中的notyfy()和notifyAll()的本质区别，需要的朋友参考下吧
2017-02-02
IntelliJ IDEA 2022安装注册永久激活
java开发工具IntelliJ IDEA深受用户喜爱，很多朋友对这个idea开发工具比较忠心，一旦有新版本发出，很多小伙伴就迫不及待的想更新，今天小编给大家带来了idea2022.1最新永久激活码，亲测有效，喜欢的朋友快来下载体验吧
2022-08-08
SpringBoot整合ES解析搜索返回字段问题
这篇文章主要介绍了SpringBoot整合ES解析搜索返回字段问题,本文给大家介绍的非常详细，对大家的学习或工作具有一定的参考借鉴价值，需要的朋友可以参考下
2023-03-03
spring boot + mybatis如何实现数据库的读写分离
这篇文章主要给大家介绍了关于spring boot + mybatis如何实现数据库的读写分离的相关资料，文中通过示例代码介绍的非常详细，对大家学习或者使用spring boot具有一定的参考学习价值，需要的朋友们下面来一起学习学习吧
2019-09-09
DOM解析XML报错Content is not allowed in prolog解决方案详解
这篇文章主要介绍了DOM解析XML报错解决方案详解,文中通过示例代码介绍的非常详细，对大家的学习或者工作具有一定的参考学习价值,需要的朋友可以参考下
2020-10-10
Java Spring的两种事务你知道吗
这篇文章主要为大家详细介绍了Java Spring的两种事务，文中示例代码介绍的非常详细，具有一定的参考价值，感兴趣的小伙伴们可以参考一下，希望能够给你带来帮助
2022-03-03
java算法导论之FloydWarshall算法实现代码
这篇文章主要介绍了算法导论之FloydWarshall算法实现代码的相关资料,需要的朋友可以参考下
2017-05-05
SpringBoot如何处理@KafkaListener消息
Spring通过KafkaMessageListenerContainer、ConcurrentMessageListenerContainer等组件实现Kafka消息的监听和处理,并通过@KafkaListener注解将业务逻辑与Kafka消费者连接起来,Spring Boot自动配置Kafka相关组件,简化了Kafka的使用
2024-12-12
JAVA内存模型和Happens-Before规则知识点讲解
在本篇文章里小编给大家整理的是一篇关于JAVA内存模型和Happens-Before规则知识点内容，有需要的朋友们跟着学习下。
2020-11-11