Reactor Mono应用

使用案例

创建Mono

使用静态工厂方法创建Mono
import reactor.core.publisher.Mono;public class MonoExample {public static void main(String[] args) {// 创建一个包含值的MonoMono<String> monoWithValue = Mono.just("Hello, Reactor!");// 创建一个空的MonoMono<String> emptyMono = Mono.empty();// 创建一个包含错误的MonoMono<String> errorMono = Mono.error(new RuntimeException("Something went wrong"));}
}
从Callable、Supplier、CompletableFuture等创建Mono
import reactor.core.publisher.Mono;import java.util.concurrent.CompletableFuture;public class MonoExample {public static void main(String[] args) {// 从Callable创建MonoMono<String> callableMono = Mono.fromCallable(() -> "Hello from Callable");// 从Supplier创建MonoMono<String> supplierMono = Mono.fromSupplier(() -> "Hello from Supplier");// 从CompletableFuture创建MonoCompletableFuture<String> future = CompletableFuture.supplyAsync(() -> "Hello from CompletableFuture");Mono<String> futureMono = Mono.fromFuture(future);}
}

订阅Mono

订阅是开始数据流处理的关键步骤

import reactor.core.publisher.Mono;public class MonoExample {public static void main(String[] args) {Mono<String> mono = Mono.just("Hello, Reactor!");// 订阅并消费数据mono.subscribe(value -> System.out.println("Received: " + value), // onNexterror -> System.err.println("Error: " + error),   // onError() -> System.out.println("Completed")             // onComplete);}
}

操作Mono

转换和操作数据
import reactor.core.publisher.Mono;public class MonoExample {public static void main(String[] args) {Mono<String> mono = Mono.just("hello");// 转换数据Mono<String> transformedMono = mono.map(String::toUpperCase);// 链式操作transformedMono.flatMap(value -> Mono.just(value + " World")).subscribe(System.out::println);  // 输出: HELLO World}
}

异常处理

import reactor.core.publisher.Mono;public class MonoExample {public static void main(String[] args) {Mono<String> monoWithError = Mono.error(new RuntimeException("Original Error"));// 捕获并处理错误monoWithError.onErrorReturn("Fallback value").subscribe(System.out::println);  // 输出: Fallback value// 使用 onErrorResume 提供备用的 MonomonoWithError.onErrorResume(error -> {System.err.println("Error: " + error);return Mono.just("Recovered value");}).subscribe(System.out::println);  // 输出: Recovered value}
}

组合Mono

import reactor.core.publisher.Mono;public class MonoExample {public static void main(String[] args) {Mono<String> mono1 = Mono.just("Hello");Mono<String> mono2 = Mono.just("World");// 组合两个MonoMono<String> combinedMono = Mono.zip(mono1, mono2, (s1, s2) -> s1 + " " + s2);combinedMono.subscribe(System.out::println);  // 输出: Hello World}
}

调试和日志

使用日志功能可以帮助调试和监控数据流。

import reactor.core.publisher.Mono;
import reactor.util.Logger;
import reactor.util.Loggers;public class MonoExample {public static void main(String[] args) {Logger logger = Loggers.getLogger(MonoExample.class);Mono<String> mono = Mono.just("Hello, Reactor!").log();  // 默认日志mono.subscribe(System.out::println);}
}

调度器(Schedulers)

使用调度器来控制Mono的执行线程。

import reactor.core.publisher.Mono;
import reactor.core.scheduler.Schedulers;public class MonoExample {public static void main(String[] args) {Mono<String> mono = Mono.fromCallable(() -> {// 在独立的线程池中执行Thread.sleep(1000);return "Hello from another thread";});mono.subscribeOn(Schedulers.boundedElastic())  // 指定订阅时的调度器.publishOn(Schedulers.parallel())         // 指定发布时的调度器.subscribe(System.out::println);}
}

应用场景

异步计算

Mono可以用来表示和处理异步计算的结果。例如,当你需要从一个异步操作中获取一个值时,可以使用Mono。

Mono<String> asyncResult = Mono.fromCallable(() -> {// 模拟异步计算Thread.sleep(1000);return "Result";
});asyncResult.subscribe(result -> System.out.println("Received: " + result));

调用远程服务

在微服务架构中,调用远程服务(如REST API或gRPC)时,通常会返回一个单一的结果。这是Mono的一个典型应用场景。

WebClient webClient = WebClient.create("http://example.com");Mono<String> response = webClient.get().uri("/resource").retrieve().bodyToMono(String.class);response.subscribe(body -> System.out.println("Response: " + body));

数据库查询

Mono非常适合表示数据库查询返回的单个结果。例如,查询一个用户的信息

Mono<User> userMono = reactiveUserRepository.findById(userId);userMono.subscribe(user -> System.out.println("User: " + user));

事件驱动的处理

在事件驱动架构中,某些事件处理结果可能是单一的值。例如,处理某个事件并返回一个处理结果

Mono<EventResult> eventResultMono = processEvent(event);eventResultMono.subscribe(result -> System.out.println("Event processed: " + result));

错误处理

使用Mono可以优雅地处理异步操作中的错误。例如,如果某个操作可能会失败,可以返回一个错误的Mono并在订阅时处理错误

Mono<String> result = performOperation().onErrorReturn("Fallback value");result.subscribe(value -> System.out.println("Received: " + value),error -> System.err.println("Error: " + error)
);

延迟操作

Mono可以用于表示一个延迟操作,执行某些延迟逻辑

Mono<Long> delayMono = Mono.delay(Duration.ofSeconds(3));delayMono.subscribe(time -> System.out.println("Delayed for 3 seconds"));

条件逻辑

使用Mono可以在异步流中进行条件判断和逻辑处理。例如,根据某个条件返回不同的结果

Mono<String> conditionalMono = Mono.just("data").flatMap(data -> {if (data.equals("condition")) {return Mono.just("Condition met");} else {return Mono.just("Condition not met");}});conditionalMono.subscribe(System.out::println);

转换与映射

Mono可以用于对单个值进行转换或映射。例如,将一个值转换为另一个类型的值

Mono<String> originalMono = Mono.just("original");Mono<Integer> transformedMono = originalMono.map(String::length);transformedMono.subscribe(length -> System.out.println("Length: " + length));

资源管理

Mono可以用于在异步操作中管理资源,如文件或连接的打开和关闭

Mono.using(() -> new BufferedReader(new FileReader("data.txt")), reader -> Mono.fromCallable(() -> reader.readLine()), BufferedReader::close
).subscribe(line -> System.out.println("Read line: " + line));

组合多个异步操作

Mono可以用于组合多个异步操作,构建复杂的异步数据流

Mono<String> combinedMono = Mono.zip(Mono.just("Hello"),Mono.just("World"),(s1, s2) -> s1 + " " + s2
);combinedMono.subscribe(System.out::println);  // 输出: Hello World

本文来自互联网用户投稿,该文观点仅代表作者本人,不代表本站立场。本站仅提供信息存储空间服务,不拥有所有权,不承担相关法律责任。如若转载,请注明出处:http://www.mzph.cn/pingmian/31850.shtml

如若内容造成侵权/违法违规/事实不符,请联系多彩编程网进行投诉反馈email:809451989@qq.com,一经查实,立即删除!

相关文章

昇思25天学习打卡营第3天|数据集Dataset

一、简介&#xff1a; 数据是深度学习的基础&#xff0c;高质量的数据输入将在整个深度神经网络中起到积极作用。有一种说法是模型最终训练的结果&#xff0c;10%受到算法影响&#xff0c;剩下的90%都是由训练的数据质量决定。&#xff08;doge&#xff09; MindSpore提供基于…

odoo17 小变更3 Warning、 “attrs “和 “states “不再用

odoo17 小变更 1、Warning from odoo.exceptions import ValidationError,Warning ImportError: cannot import name Warning from odoo.exceptions (D:\od172406\odoo\exceptions.py) 2、自 17.0 版起&#xff0c;不再使用 "attrs "和 "states "属性。 …

Docker常用操作和命令

文章目录 1、卸载旧版本 2、yum安装Docker CE&#xff08;社区版&#xff09; 3、添加镜像加速器 4、docker --version 查看docker版本 5、docker info 或 docker system info 显示 Docker 系统的详细信息&#xff0c;包括容器、镜像、网络等 6、docker search 搜索镜像 …

仙讯畅通无阻:探索MQ阵法的强大功能

MQ起源 IBM MQ&#xff1a;IBM MQ是IBM推出的一系列消息导向中间件产品&#xff0c;最初在1993年12月发布。它最初被称为MQSeries&#xff0c;2002年更名为WebSphere MQ&#xff0c;以加入WebSphere产品系列。2014年4月&#xff0c;它被重新命名为IBM MQ。Apache ActiveMQ&…

永辉超市:胖东来爆改,成色几何?

单日业绩暴涨14倍。来&#xff0c;看看&#xff0c;这是被胖东来爆改后重新开业后的门店&#xff0c; 不出意外的流量爆炸。胖东来爆改&#xff0c;真是解决实体商超困境的灵丹妙药吗&#xff1f; 今天我们聊聊——永辉超市 最近两年实体商超日子都不好过&#xff0c;去年13家…

构建高效的电商返利系统:架构设计与实现

构建高效的电商返利系统&#xff1a;架构设计与实现 大家好&#xff0c;我是免费搭建查券返利机器人省钱赚佣金就用微赚淘客系统3.0的小编&#xff0c;也是冬天不穿秋裤&#xff0c;天冷也要风度的程序猿&#xff01; 电商返利系统作为连接消费者和商家的桥梁&#xff0c;能够…

On_Java 安装

Ubuntu环境下打开.chm文件 broadview_java 于 2023-02-20 12:48:37 发布 342 收藏 分类专栏&#xff1a; Android 开发工具 文章标签&#xff1a; ubuntu chm文件 版权 Android 开发工具 专栏收录该内容 19 篇文章 1 订阅 订阅专栏 前言 在ubuntu下,下载了一个JDK1.8 api中文文…

cron.timezone

系统 date 数据库 show timezone插件 show cron.timezonealter system set cron.timezonePRC;show cron.timezone

node 升级之后 npm run build 错误

错误信息 Error Error: error:0308010C:digital envelope routines::unsupportedat new Hash (node:internal/crypto/hash:67:19)at Object.createHash (node:crypto:130:10)该错误源于您对过时的 SSL 版本的依赖&#xff0c;因此您有两个好的选择和两个最好但值得怀疑的选择&…

【odoo】常用的基本视图类型

概要 在Odoo中&#xff0c;有几种基本视图类型&#xff0c;每种视图类型用于不同的目的和场景。这些视图类型包括表单视图&#xff08;form view&#xff09;、树视图&#xff08;tree view&#xff09;、看板视图&#xff08;kanban view&#xff09;、图表视图&#xff08;gr…

tessy 编译报错:单元测试时,普通桩函数内容相关异常场景

目录 1&#xff0c;失败现象 2&#xff0c;原因分析 1&#xff0c;失败现象 1&#xff0c;在 step 桩函数正常的情况下报错。 2&#xff0c;测试代码执行的数据流 和 step 桩函数内容不一致。 2&#xff0c;原因分析 桩函数分为 test object, test case, test step 三种类别。…

研究人员描述了如何判断ChatGPT是否在虚构

研究人员描述了如何判断ChatGPT是否在虚构 这是世界上最不为人知的秘密之一&#xff0c;大型语言模型对查询给出了明显错误的答案&#xff0c;并自信地这样做&#xff0c;与它们正确的时候没有区别。这有很多原因。人工智能可能已经接受了错误信息的训练;答案可能需要从LLM无法…

Flutter【组件】富文本组件

简介 flutter 富文本组件。 github地址&#xff1a; https://github.com/ThinkerJack/jac_uikit pub地址&#xff1a;https://pub.dev/packages/jac_uikit 使用方式 运行 flutter pub add jac_uikit组件文档 使用方式&#xff1a; HighlightedTextWidget.builder(text: &…

Linux解压缩命令

文章目录 前言1. tar - 打包和压缩文件2. gzip - 压缩文件3. gunzip - 解压缩gzip文件4. bzip2 - 压缩文件5. unzip - 解压缩zip文件6. zip - 压缩文件为zip格式7. 7z - 7-Zip压缩工具8. unrar - 解压缩RAR文件 前言 解压缩文件在Linux中是常见的任务&#xff0c;以下是一些常…

内积知识点小记

import numpy as np a np.array([1,2]) b np.array([3,4]) c a b # 11e np.array([[1,2],[3,4]]) f np.array([[5,6],[7,8]])g e f #array([[19, 22],[43, 50]])内积&#xff0c;也称为点积或数量积&#xff0c;是数学中接受在实数R上的两个向量并返回一个实数值标量的…

视频数据标注

视频采集 视频采集通常指的是将视频信号从视频源&#xff08;如摄像头、视频播放器等&#xff09;捕获并转换为数字格式&#xff0c;以便于计算机处理和存储。 视频采集步骤&#xff1a; 视频信号捕获&#xff1a;通过摄像头、网络摄像头、视频采集卡等设备将视频信号捕获。 …

SpringMVC的使用

SpringMVC详情 RequestMapping("/hello") 负责用户的请求路径与后台服务器之间的映射关系 如果请求路径不匹配,则用户报错404 ResponseBody 作用: 将服务器的返回值转化为JSON. 如果服务器返回的是String类型,则按照自身返回. 新增: post请求类型 PostMapping("…

Java 从零开始写一个简单的图书管理系统

了解一下 先来了解要实现一个怎样的图书管理系统 从中可以看到有操作的 使用者 和 不同 的 功能 而不同的使用者有不同的 菜单 那要如何实现呢&#xff1f; 请继续看下去 如何实现 首先了解我们 需要什么 图书系统需要 书&#xff0c;放书的 书架 &#xff0c;用户 中有 管…

理解Python中的类型不兼容性:为什么 `dict[int, int]` 不兼容 `dict[int, int | str]`

在使用Python的类型提示时&#xff0c;开发者可能会遇到一些看似不合理的类型不兼容错误。一个典型的问题是&#xff0c;为什么 dict[int, int] 不能赋值给 dict[int, int | str]。本文将详细探讨这个问题&#xff0c;并提供一些解决方法。 例子分析 考虑以下代码片段&#x…

大数据与java哪个好找工作?这篇文章帮你做选择!

大数据与java哪个好找工作&#xff1f;这篇文章帮你做选择&#xff01; 还在为选择Java开发还是Java大数据而头疼吗&#xff1f;别担心&#xff0c;本文将从就业前景、学习方向、学习内容以及薪资待遇四个方面&#xff0c;为你揭开Java和Java大数据的神秘面纱&#xff0c;帮你做…