深入理解 `Sinks.Empty<Void>` 和 `Mono<Void>`:如何触发完成信号并结合 WebSocket 示例

在响应式编程中,Sinks 是 Project Reactor 提供的一个强大工具,用于手动控制数据流的信号发射。Sinks.Empty<Void> 是一种特殊的 Sinks,它不发射任何数据,仅用于表示完成或错误信号。结合 Mono<Void>,它可以用来表示一个异步操作的完成状态。本文将详细分析 Sinks.Empty<Void>Mono<Void> 的行为,并通过示例代码展示其用法,同时结合 WebSocket 建立连接的伪代码,展示其在实际场景中的应用。


1. Sinks.Empty<Void> 是什么?

Sinks.Empty<Void> 是 Project Reactor 中的一个 Sinks 类型,专门用于表示一个不发射任何数据的信号源。它的主要特点是:

  • 不发射任何数据(onNext 信号)。
  • 只能发射完成信号(onComplete)或错误信号(onError)。
  • 需要通过显式调用方法(如 tryEmitEmpty())来触发完成信号。

它的典型使用场景是表示一个异步操作的完成状态,而不需要传递任何数据。


2. Mono<Void> 的作用

Mono<Void> 是 Project Reactor 中的一个响应式类型,表示一个最多发射一个元素的异步序列。对于 Mono<Void> 来说:

  • 它不会发射任何数据(onNext 信号)。
  • 它只会发射完成信号(onComplete)或错误信号(onError)。
  • 它通常用于表示一个不需要返回值的异步操作。

通过将 Sinks.Empty<Void> 转换为 Mono<Void>,我们可以将手动控制的信号源与响应式流结合起来。


3. 如何触发完成信号?

Sinks.Empty<Void> 的完成信号需要通过显式调用 tryEmitEmpty() 来触发。以下是关键点:

  • 在调用 tryEmitEmpty() 之前,Sinks.Empty<Void> 处于未完成状态,订阅者会一直等待。
  • 调用 tryEmitEmpty() 后,Sinks.Empty<Void> 会立即发出完成信号,订阅者会收到 onComplete 通知。

4. 示例代码

以下是一个完整的示例,展示了如何使用 Sinks.Empty<Void>Mono<Void> 来触发完成信号:

import reactor.core.publisher.Mono;
import reactor.core.publisher.Sinks;public class SinksEmptyExample {public static void main(String[] args) {// 1. 创建一个空的 Sinks.Empty<Void>Sinks.Empty<Void> completion = Sinks.empty();// 2. 将其转换为 Mono<Void>Mono<Void> mono = completion.asMono();// 3. 订阅 Mono<Void>mono.subscribe(null, // onNext (不会调用,因为没有数据)error -> System.err.println("Error: " + error), // onError() -> System.out.println("Completed!") // onComplete);// 4. 模拟一个异步操作System.out.println("Starting async operation...");try {Thread.sleep(2000); // 模拟耗时操作} catch (InterruptedException e) {e.printStackTrace();}// 5. 手动触发完成信号System.out.println("Triggering completion...");completion.tryEmitEmpty();// 输出:// Starting async operation...// (等待 2 秒)// Triggering completion...// Completed!}
}
代码解析:
  1. 创建 Sinks.Empty<Void>

    • 使用 Sinks.empty() 创建一个空的 Sinks.Empty<Void>
  2. 转换为 Mono<Void>

    • 通过 completion.asMono()Sinks.Empty<Void> 转换为 Mono<Void>
  3. 订阅 Mono<Void>

    • 订阅 Mono<Void>,并定义 onErroronComplete 的处理逻辑。
  4. 模拟异步操作

    • 使用 Thread.sleep(2000) 模拟一个耗时 2 秒的异步操作。
  5. 触发完成信号

    • 调用 completion.tryEmitEmpty() 手动触发完成信号,订阅者会收到 onComplete 通知。

5. 结合 WebSocket 建立连接的伪代码

在实际应用中,Sinks.Empty<Void>Mono<Void> 可以用于表示 WebSocket 连接的建立和关闭。以下是一个伪代码示例,展示如何在 WebSocket 连接建立后触发完成信号:

import reactor.core.publisher.Mono;
import reactor.core.publisher.Sinks;
import org.springframework.web.reactive.socket.WebSocketSession;public class WebSocketExample {public Mono<Void> handleWebSocketConnection(WebSocketSession session) {// 1. 创建一个空的 Sinks.Empty<Void>Sinks.Empty<Void> completion = Sinks.empty();// 2. 将其转换为 Mono<Void>Mono<Void> mono = completion.asMono();// 3. 处理 WebSocket 连接session.receive().doOnNext(message -> {// 处理收到的消息System.out.println("Received message: " + message.getPayloadAsText());}).doOnError(error -> {// 处理错误System.err.println("WebSocket error: " + error);completion.tryEmitError(error); // 触发错误信号}).doOnComplete(() -> {// 连接关闭时触发完成信号System.out.println("WebSocket connection closed.");completion.tryEmitEmpty(); // 触发完成信号}).subscribe();// 4. 返回 Mono<Void>,表示 WebSocket 连接的处理结果return mono;}public static void main(String[] args) {WebSocketExample example = new WebSocketExample();// 模拟 WebSocket 连接WebSocketSession session = // 获取 WebSocketSession 的伪代码example.handleWebSocketConnection(session).subscribe(null, // onNext (不会调用,因为没有数据)error -> System.err.println("Error: " + error), // onError() -> System.out.println("WebSocket handling completed!") // onComplete);}
}
伪代码解析:
  1. 创建 Sinks.Empty<Void>

    • 使用 Sinks.empty() 创建一个空的 Sinks.Empty<Void>,用于表示 WebSocket 连接的完成状态。
  2. 处理 WebSocket 连接

    • 使用 session.receive() 处理 WebSocket 消息。
    • doOnNext 中处理收到的消息。
    • doOnError 中处理错误,并调用 completion.tryEmitError(error) 触发错误信号。
    • doOnComplete 中处理连接关闭,并调用 completion.tryEmitEmpty() 触发完成信号。
  3. 返回 Mono<Void>

    • 返回 Mono<Void>,表示 WebSocket 连接的处理结果。
  4. 订阅 Mono<Void>

    • 订阅 Mono<Void>,并定义 onErroronComplete 的处理逻辑。

6. 关键点总结

  • Sinks.Empty<Void> 是一个手动控制的信号源,它不会自动发出完成信号,必须通过显式调用 tryEmitEmpty() 来触发。
  • Mono<Void> 表示一个不发射数据的异步序列,它只会发出完成或错误信号。
  • WebSocket 连接示例
    • 通过 Sinks.Empty<Void>Mono<Void>,可以灵活地表示 WebSocket 连接的完成状态。
    • 在连接关闭或发生错误时,手动触发完成或错误信号。

7. 总结

通过 Sinks.Empty<Void>Mono<Void>,我们可以灵活地控制异步操作的完成信号。结合 WebSocket 示例,展示了如何在实际场景中使用这些工具。关键在于理解 Sinks.Empty<Void> 的初始状态是未完成的,必须通过显式调用 tryEmitEmpty()tryEmitError() 来触发信号。

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

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

相关文章

LLM+多智能体协作:基于CrewAI与DeepSeek的邮件自动化实践

文章目录 引言理解 Flows&#xff08;工作流&#xff09;与 Crews&#xff08;协作组&#xff09;一、环境准备与工具安装1.1 Python环境搭建1.2 创建并激活虚拟环境1.3 安装核心依赖库&#xff08;crewai、litellm&#xff09; 二、本地DeepSeek R1大模型部署2.1 Ollama框架安…

Deepseek开源周,第二天:Deep EP

DeepSeek 开源的 DeepEP 项目是一个专为 MoE&#xff08;混合专家&#xff09;模型设计的开源通信库&#xff0c;旨在优化训练和推理效率。其对开发者的核心价值体现在以下方面&#xff1a; 1. 显著提升训练与推理性能 全连接通信优化 通过高效优化的 All-to-All 通信机制&…

分布式深度学习:探索无限可能

分布式深度学习:探索无限可能 大家好,我是Echo_Wish,一名专注于人工智能和Python的自媒体创作者。今天,我们将深入探讨分布式深度学习,这个技术不仅是AI发展的前沿,更是应对大规模数据和复杂模型的关键解决方案。随着数据量和模型复杂度的不断增加,传统的单机深度学习已…

window下kafka安装

kafka下载 下载好,直接解压即可 默认是带有zookeeper(注册中心) 需要先启动zookeeper zookeeper配置 先配置下zookeeper 这个data文件夹是自定建的 随意建在哪里 注意 这里斜杠用和linux一样 启动zookeeper 进入bin/windows目录 启动zookeeper zookeeper-server-start.ba…

浅谈 Redis 主从复制原理(二)

大家好&#xff0c;我是此林。 【浅谈 Redis 主从集群原理&#xff08;一&#xff09; 】 上一篇文章中&#xff0c;说到了 Redis 主从复制的全量同步和增量同步&#xff0c;repl_baklog 复制缓冲区&#xff0c;以及 slave 挂掉之后数据同步的措施。 下面介绍的上一篇遗留问…

Vue 中单向数据流原则

做一个 ElementUI 弹框组件的二次封装 效果如下: 点击取消按钮发现弹出如下报错信息 : [Vue warn]: Avoid mutating a prop directly since the value will be overwritten whenever the parent component re-renders. Instead, use a data or computed property based on the …

网页版的俄罗斯方块

1、新建一个txt文件 2、打开后将代码复制进去保存 <!DOCTYPE html> <html lang"en"><head><meta charset"UTF-8"><meta name"viewport" content"widthdevice-width, initial-scale1.0"><title>俄…

计算机毕业设计SpringBoot+Vue.js足球青训俱乐部管理系统(源码+文档+PPT+讲解)

温馨提示&#xff1a;文末有 CSDN 平台官方提供的学长联系方式的名片&#xff01; 温馨提示&#xff1a;文末有 CSDN 平台官方提供的学长联系方式的名片&#xff01; 温馨提示&#xff1a;文末有 CSDN 平台官方提供的学长联系方式的名片&#xff01; 作者简介&#xff1a;Java领…

element ui的select选择框

我们首先先试一下&#xff0c;这个东西怎么玩的 <el-select v-model"select" change"changeSelect"><el-option value"香蕉"></el-option><el-option value"菠萝"></el-option><el-option value&quo…

DeepSeek引领目标检测新趋势:如何通过知识蒸馏优化模型性能

目录 一、知识蒸馏是什么&#xff1f; 二、知识蒸馏在目标检测中的重要性 提升实时性 跨任务迁移学习 三、如何使用知识蒸馏优化目标检测&#xff1f; 训练教师模型 生成软标签 训练学生模型 调节温度参数 多教师蒸馏&#xff08;可选&#xff09; 四、案例分享 定…

C++与Python实现LiDAR点云投影对比:关键差异与易错点详解

问题背景 在多传感器融合任务中&#xff0c;常需将LiDAR点云投影到相机图像。然而&#xff0c;不同语言&#xff08;如C和Python&#xff09;的实现可能存在细微差异&#xff0c;导致投影结果不一致。本文通过对比两段功能相近的代码&#xff08;C和Python&#xff09;&#x…

数据结构☞泛型

一.基础定义与应用方向 1.定义&#xff1a; 一般的类和方法&#xff0c;只能使用具体的类型 : 要么是基本类型&#xff0c;要么是自定义的类。如果要编写可以 应用于多种类型 的代码&#xff0c;这种刻板的限制对代码的束缚就会很大。----- 来源《 Java 编程思想》对泛型的介…

算法-数据结构-图-邻接表构建

邻接表的基本概念 顶点&#xff08;Vertex&#xff09;&#xff1a; 图中的每个顶点用一个节点表示。 每个顶点存储一个链表或数组&#xff0c;用于记录与该顶点直接相连的其他顶点。 边&#xff08;Edge&#xff09;&#xff1a; 如果顶点 A 和顶点 B 之间有一条边&#xf…

再论Spring MVC中Filter和HandlerInterceptor的优先级

在Spring MVC中&#xff0c;Filter和HandlerInterceptor的执行顺序及优先级如下&#xff1a; 1. 执行顺序与优先级 Filter&#xff08;Servlet规范&#xff09;的优先级高于 HandlerInterceptor&#xff08;Spring MVC框架&#xff09;。 请求处理流程&#xff1a; Filter链&a…

LeetCode 每日一题 2025/2/17-2025/2/23

记录了初步解题思路 以及本地实现代码&#xff1b;并不一定为最优 也希望大家能一起探讨 一起进步 目录 2/17 1287. 有序数组中出现次数超过25%的元素2/18 2080. 区间内查询数字的频率2/19 624. 数组列表中的最大距离2/20 2595. 奇偶位数2/21 2209. 用地毯覆盖后的最少白色砖块…

C#中提供的多种集合类以及适用场景

在 C# 中&#xff0c;有多种集合类可供使用&#xff0c;它们分别适用于不同的场景,部分代码示例提供了LeetCode相关的代码应用。 1. 数组&#xff08;Array&#xff09; 特点 固定大小&#xff1a;在创建数组时需要指定其长度&#xff0c;之后无法动态改变。连续存储&#xf…

5秒修改文件默认打开方式-windows版

这里写自定义目录标题 今天做前端开发遇见我的ts文件默认打开方式是暴风影音&#xff0c;但是我想让他默认用vscode打开&#xff0c;在vscode 找了半天也没搞定&#xff0c;从网上搜索到了修改方式&#xff0c;只需5秒钟。下面就来看看吧。 &#x1f4c1; 想要改变文件的默认打…

2025年信息科学与工程学院科协机器学习介绍——机器学习基本模型介绍

机器学习 目录 机器学习一.安装基本环境conda/miniconda环境 二.数据操作数据预处理一维数组二维数组以及多维数组的认识访问元素的方法torch中tenson的应用张量的运算张量的广播 三.线性代数相关知识四.线性回归SoftMax回归问题&#xff08;分类问题&#xff09;什么是分类问题…

计算机毕业设计Hadoop+Spark+DeepSeek-R1大模型民宿推荐系统 hive民宿可视化 民宿爬虫 大数据毕业设计(源码+文档+PPT+讲解)

温馨提示&#xff1a;文末有 CSDN 平台官方提供的学长联系方式的名片&#xff01; 温馨提示&#xff1a;文末有 CSDN 平台官方提供的学长联系方式的名片&#xff01; 温馨提示&#xff1a;文末有 CSDN 平台官方提供的学长联系方式的名片&#xff01; 作者简介&#xff1a;Java领…

业务应用和大数据平台的数据流向

概述 业务应用与大数据平台之间的交互是实现数据驱动决策和实时业务处理的关键环节。其交互方式多样&#xff0c;协议选择取决于数据流向、实时性要求及技术架构。一句话总结&#xff0c;数据流向可以是从业务应用写入大数据平台&#xff0c;也可以是大数据平台回写至业务应用…