当前位置： 首页 > news >正文

【响应式编程】Reactor 常用操作符与使用指南

news 来源：原创 2025/9/8 16:45:53

文章目录

    • 一、创建操作符
      • 1. `just` —— 创建包含指定元素的流
      • 2. `fromIterable` —— 从集合创建 Flux
      • 3. `empty` —— 创建空的 Flux 或 Mono
      • 4. `fromArray` —— 从数组创建 Flux
      • 5. `fromStream` —— 从 Java 8 Stream 创建 Flux
      • 6. `create` —— 使用 FluxSink 手动发射元素
      • 7. `generate` —— 使用状态生成元素，适用于同步场景
      • 8. `fromFuture` —— 从 CompletableFuture 创建 Mono
      • 9. `interval` —— 创建周期性发射元素的 Flux
      • 10. `timer` —— 创建延迟发射的 Mono
    • 二、转换操作符
      • 1. `map` —— 映射每个元素为新值
      • 2. `flatMap` —— 扁平化异步流，将每个元素映射为异步 Publisher
      • 3. `concatMap` —— 顺序执行映射为 Publisher 的异步流
    • 三、过滤操作符
      • 1. `filter` —— 按条件过滤元素
      • 2. `take` —— 获取前 N 个元素
      • 3. `skip` —— 跳过前 N 个元素
    • 四、组合操作符
      • 1. `concat` —— 按顺序合并多个 Flux
      • 2. `merge` —— 并发合并多个 Flux（无序）
      • 3. `zip` —— 按索引组合多个 Flux 的元素
    • 五、错误处理操作符
      • 1. `onErrorReturn` —— 出错时返回默认值
      • 2. `onErrorResume` —— 出错时切换备用流
      • 3. `retry` —— 出错时重试指定次数
    • 六、延迟执行与懒加载：`Mono.defer` 和 `Flux.defer`：被订阅时才执行
      • `Mono.defer` —— 懒加载 Mono，直到subscribe时才创建执行
      • `Flux.defer` —— 懒加载 Flux，每次订阅时重新执行逻辑

Reactor 是一个用于构建反应式应用程序的 Java 库，提供了丰富的操作符（算子）来处理反应式流（Flux 和 Mono）。本文详细介绍了 Reactor 中常用的创建、转换、过滤、组合和错误处理操作符，以及一些高级用法示例。

一、创建操作符

1. just —— 创建包含指定元素的流

Flux<Integer> flux = Flux.just(1, 2, 3, 4, 5);
Mono<String> mono = Mono.just("Hello");

2. fromIterable —— 从集合创建 Flux

List<Integer> list = Arrays.asList(1, 2, 3, 4, 5);
Flux<Integer> flux = Flux.fromIterable(list);

3. empty —— 创建空的 Flux 或 Mono

Flux<Integer> emptyFlux = Flux.empty();
Mono<String> emptyMono = Mono.empty();

4. fromArray —— 从数组创建 Flux

Integer[] numbers = {1, 2, 3, 4, 5};
Flux<Integer> flux = Flux.fromArray(numbers);

5. fromStream —— 从 Java 8 Stream 创建 Flux

Stream<Integer> stream = Arrays.asList(1, 2, 3, 4, 5).stream();
Flux<Integer> flux = Flux.fromStream(stream);

6. create —— 使用 FluxSink 手动发射元素

Flux<Integer> flux = Flux.create(sink -> {for (int i = 0; i < 5; i++) {sink.next(i);}sink.complete();
});

7. generate —— 使用状态生成元素，适用于同步场景

Flux<Integer> flux = Flux.generate(() -> 0, (state, sink) -> {sink.next(state);if (state == 4) sink.complete();return state + 1;
});

8. fromFuture —— 从 CompletableFuture 创建 Mono

CompletableFuture<String> future = CompletableFuture.completedFuture("Hello");
Mono<String> mono = Mono.fromFuture(future);

9. interval —— 创建周期性发射元素的 Flux

Flux<Long> intervalFlux = Flux.interval(Duration.ofSeconds(1));

10. timer —— 创建延迟发射的 Mono

Mono<Long> timerMono = Mono.timer(Duration.ofSeconds(2));

 

二、转换操作符

1. map —— 映射每个元素为新值

Flux<Integer> squared = Flux.just(1, 2, 3).map(n -> n * n);

2. flatMap —— 扁平化异步流，将每个元素映射为异步 Publisher

Flux<Integer> result = Flux.just(1, 2, 3).flatMap(n -> Mono.just(n * 2));

3. concatMap —— 顺序执行映射为 Publisher 的异步流

Flux<Integer> result = Flux.just(1, 2, 3).concatMap(n -> Mono.just(n * 2));

 

三、过滤操作符

1. filter —— 按条件过滤元素

Flux<Integer> evens = Flux.just(1, 2, 3, 4).filter(n -> n % 2 == 0);

2. take —— 获取前 N 个元素

Flux<Integer> firstThree = Flux.just(1, 2, 3, 4, 5).take(3);

3. skip —— 跳过前 N 个元素

Flux<Integer> skipped = Flux.just(1, 2, 3, 4, 5).skip(2);

 

四、组合操作符

1. concat —— 按顺序合并多个 Flux

Flux<Integer> combined = Flux.concat(Flux.just(1, 2), Flux.just(3, 4));

2. merge —— 并发合并多个 Flux（无序）

Flux<Integer> merged = Flux.merge(Flux.just(1, 2), Flux.just(3, 4));

3. zip —— 按索引组合多个 Flux 的元素

Flux<String> zipped = Flux.zip(Flux.just(1, 2), Flux.just(3, 4), (a, b) -> a + ":" + b);

 

五、错误处理操作符

1. onErrorReturn —— 出错时返回默认值

Flux<Integer> result = Flux.just(1, 2, 3).map(n -> {if (n == 2) throw new RuntimeException("error");return n;}).onErrorReturn(-1);

2. onErrorResume —— 出错时切换备用流

Flux<Integer> result = Flux.just(1, 2, 3).map(n -> {if (n == 2) throw new RuntimeException("error");return n;}).onErrorResume(e -> Mono.just(-1));

3. retry —— 出错时重试指定次数

Flux<Integer> result = Flux.just(1, 2, 3).map(n -> {if (n == 2) throw new RuntimeException("error");return n;}).retry(2);

 

六、延迟执行与懒加载：Mono.defer 和 Flux.defer：被订阅时才执行

Mono.defer —— 懒加载 Mono，直到subscribe时才创建执行

Mono<String> deferredMono = Mono.defer(() -> {System.out.println("Generating value...");return Mono.just("Deferred Result");
});

只有当 subscribe() 被调用时，Mono.defer 中的逻辑才会真正执行。这对于需要确保执行时机晚于前一步完成场景特别重要，比如：

Mono.defer(() -> readQaResultType()).subscribe(result -> System.out.println("QA Result: " + result));

在这段代码中，读取 qaResultType 的操作只会在前面的步骤（例如数据预处理）完全完成后才被触发。

Flux.defer —— 懒加载 Flux，每次订阅时重新执行逻辑

Flux<Integer> deferredFlux = Flux.defer(() -> {System.out.println("Evaluating source...");return Flux.just(1, 2, 3);
});

每次订阅都会重新生成数据，适用于带有状态的源或依赖最新上下文的处理逻辑。

相关文章：

【响应式编程】Reactor 常用操作符与使用指南

文章目录 一、创建操作符1. just —— 创建包含指定元素的流2. fromIterable —— 从集合创建 Flux3. empty —— 创建空的 Flux 或 Mono4. fromArray —— 从数组创建 Flux5. fromStream —— 从 Java 8 Stream 创建 Flux6. create —— 使用 FluxSink 手动发射元素7. generat…...

编程日记 2025/9/8 16:45:53

为什么我们需要if __name__ == __main__:

[目录] 0.前言 1.什么是 __name__&#xff1f; 2.if __name__ __main__: 的作用 3.为何Windows更需if __name__ &#xff1f;前言 if __name__ __main__: 是 Python 中一个非常重要的惯用法&#xff0c;尤其在使用 multiprocessing 模块或编写可导入的模块时。它的作用是区分…...

编程日记 2025/8/29 2:57:49

Week 1: Time Complexity, Rectangle Geometry

问题集 Square PastureBucket BrigadeBlocked BillboardBlocked Billboard IIWord ProcessorDo You Know Your ABCs?The Cow-SignalD3C - White Sheet 视频解析 Square Pasture Bucket Brigade Blocked Billboard Blocked Billboard II Word Processor Do You Know Your AB…...

编程日记 2025/9/3 8:58:09

论文学习：《通过基于元学习的图变换探索冷启动场景下的药物-靶标相互作用预测》

原文标题&#xff1a;Exploring drug-target interaction prediction on cold-start scenarios via meta-learning-based graph transformer 原文链接&#xff1a;https://www.sciencedirect.com/science/article/pii/S1046202324002470 药物-靶点相互作用&#xff08;DTI&…...

编程日记 2025/9/7 14:49:31

STM32 HAL库 OLED驱动实现

一、概述 1.1 OLED 显示屏简介 OLED&#xff08;Organic Light - Emitting Diode&#xff09;即有机发光二极管&#xff0c;与传统的 LCD 显示屏相比&#xff0c;OLED 具有自发光、视角广、响应速度快、对比度高、功耗低等优点。在嵌入式系统中&#xff0c;OLED 显示屏常被用…...

编程日记 2025/9/4 21:37:20

UE5蓝图之间的通信------接口

一、创建蓝图接口 二、双击创建的蓝图接口&#xff0c;添加函数&#xff0c;并重命名新函数。 三、在一个蓝图&#xff08;如玩家角色蓝图&#xff09;中实现接口&#xff0c;如下图&#xff1a; 步骤一&#xff1a;点击类设置 步骤二&#xff1a;在细节面板已经实现的接口中…...

编程日记 2025/9/3 7:58:14

封装Tcp Socket

封装Tcp Socket 0. 前言1. Socket.hpp2. 简单的使用介绍 0. 前言 本文中用到的Log.hpp在笔者的历史文章中都有涉及&#xff0c;这里就不再粘贴源码了&#xff0c;学习地址如下&#xff1a;https://blog.csdn.net/weixin_73870552/article/details/145434855?spm1001.2014.3001…...

编程日记 2025/9/2 16:13:43

深入解析 Android 图形系统：Canvas、Skia、OpenGL 与 SurfaceFlinger 的协作

在 Android 应用开发中&#xff0c;流畅的 UI 渲染是用户体验的核心。但你是否好奇&#xff0c;一个简单的 View 是如何从代码中的 onDraw() 方法一步步变成屏幕上的像素的&#xff1f;本文将从底层图形系统的视角&#xff0c;解析 Android 中 Canvas、Skia、OpenGL ES 和 Surf…...

编程日记 2025/9/5 13:14:47

LeetCode每日一题4.13

1922. 统计好数字的数目 问题 问题分析 题目要求我们找到长度为 n 且满足特定条件&#xff08;偶数下标处为偶数&#xff0c;奇数下标处为质数&#xff09;的数字字符串的总数&#xff0c;并对 (10^9 7) 取余。 思路 1.枚举 生成所有可能的数字字符串&#xff1a;对于长度…...

编程日记 2025/9/7 4:34:24

Java学习——day29（并发控制高级工具与设计模式）

文章目录 1. 并发控制高级工具简介1.1 CountDownLatch1.2 CyclicBarrier1.3 Semaphore1.4 并发设计模式 2. 扩展生产者—消费者示例2.1 示例代码 3. 代码详解3.1 主类 ExtendedProducerConsumerDemo3.2 Buffer 类3.3 Producer 类3.4 Consumer 类 4. 编译与运行结果4.1 编译4.2 …...

编程日记 2025/9/5 8:56:07

使用FormData格式上传图片

为什么要使用FormData格式上传图片 1. 为什么使用 FormData&#xff1f; FormData 是一种专门用于构建表单数据的对象&#xff0c;它能够以 multipart/form-data 格式发送数据&#xff0c;这是文件上传的标准格式。以下是使用 FormData 的主要原因&#xff1a; 简单易用 直…...

编程日记 2025/9/2 11:00:51

Tkinter表格与列表框应用

在图形用户界面（GUI）开发中，表格和列表框是常用的控件，用于显示和管理大量的数据。Tkinter提供了Listbox控件来显示简单的列表数据，而对于更复杂的表格数据，可以使用Treeview控件（属于ttk模块）来实现。这一章将介绍如何使用Listbox和Treeview来显示和操作数据，帮助您处…...

编程日记 2025/9/5 22:21:47

【Excel】数据透视表月度数据排序不正确

【问题】 插入数据透视表后&#xff0c;月度列显示的日期&#xff0c;是按照文本格式排序的&#xff0c;显然与实际月份排序并不相符。 【目的】 按照从1月份到12月份进行自然月度排序。 【方法】 步骤一&#xff1a; 在任意一处&#xff0c;输入“1月”-“12月”&#…...

编程日记 2025/9/7 1:23:44

HCIP第十天

OSPF的数据包 OSPF是跨层封装协议，直接封装在网络层之上 --- 需要IP协议使用一个协议号来标定 OSPF --- 89 OSPF的头部 版本 --- OSPF的版本 --- 2 类型 --- OSPF数据包的类型 --- hello -- 1 DBD -- 2 LSR -- 3 LSU -- 4 LSACK -- 5 路由器ID --- RID --- 携带的是发出O…...

编程日记 2025/9/3 11:20:33

Vue2，Vue3知识大全

Vue 1.了解vue,快速上手 vue是一个用于构建用户的界面的渐进式框架. vue的两种使用方法: vue核心包开发 场景:局部模块改造 vue核心包&vue插件 工程化开发 场景:整站开发 1.创建一个vue实例: 2.插值表达式 1.插值表达式是一种Vue的模版语法 作用:利用表达式进行插值…...

编程日记 2025/9/2 23:01:51

java面向对象02：回顾方法

回顾方法及加深 定义方法 修饰符 返回类型 break&#xff1a;跳出switch和return的区别 方法名 参数列表 package com.oop.demo01;//Demo01类 public class Demo01 {//main方法public static void main(String[] args) {}/*修饰符 返回值类型 方法名(...){//方法体return…...

编程日记 2025/9/8 5:40:10

【Ubuntu】【树莓派】Linux系统的远程终端登录、远程图形桌面访问、 X图形窗口访问和文件传输操作

目录 一、Ubuntu远程终端并实现文件上传下载 1.1Ubuntu桥接模式设置和新用户的创建 1.2Ubuntu的远程登录并上传和下载文件 1.3在Xming中进行Ubuntu的图形访问 二、树莓派远程登录并实现文件上传下载 2.1树莓派在putty上的远程登录 2.2使用ftp远程登录并实现文件上传下载…...

编程日记 2025/9/6 11:49:22

Linux Kernel 2

地址空间&#xff08;Address Space&#xff09; 一、物理地址空间&#xff08;Physical Address Space&#xff09; 物理地址空间 是指 RAM 和设备内存 在系统内存总线上所呈现的地址布局。 举例&#xff1a;在典型的 32 32 32 位 Intel 架构中&#xff0c; RAM&#xff08…...

编程日记 2025/9/4 4:24:24

二.springBoot项目集成ElasticSearch及使用

二.springBoot项目集成ElasticSearch及使用 1.依赖引入2.ElasticSearch常见用法 1.依赖引入 <!--elasticsearch搜索引擎--> <!--高版本7.0后TransportClient已被淘汰&#xff0c;用rest-high-level-client代替--> <dependency><groupId>org.elasticse…...

编程日记 2025/9/3 15:21:51

从三次方程到复平面：复数概念的奇妙演进（一）

注&#xff1a;本文为 “复数 | 历史 / 演进” 相关文章合辑。 因 csdn 篇幅限制分篇连载&#xff0c;此为第一篇。 生料&#xff0c;不同的文章不同的点。 机翻&#xff0c;未校。 Reflections on the History of Complex Numbers 复数的历史回顾 The first occurrence o…...

编程日记 2025/9/6 5:52:41

Day52 | 6. Z 字形变换、8. 字符串转换整数 (atoi)、22. 括号生成、38. 外观数列

6. Z 字形变换 题目链接&#xff1a;6. Z 字形变换 - 力扣&#xff08;LeetCode&#xff09; 题目难度&#xff1a;中等 代码&#xff1a; class Solution {public String convert(String s, int numRows) {if(numRows<2) return s;List<StringBuilder> rowsnew A…...

编程日记 2025/9/7 4:15:43

每日OJ_牛客_ruby和薯条_排序+二分/滑动窗口_C++_Java

目录 ruby和薯条_排序二分/滑动窗口 题目解析 C代码 Java代码 ruby和薯条_排序二分/滑动窗口 ruby和薯条 描述&#xff1a; ruby很喜欢吃薯条。 有一天&#xff0c;她拿出了n根薯条。第i根薯条的长度为ai。 ruby认为&#xff0c;若两根薯条的长度之差在l和r之间&#xff…...

编程日记 2025/9/1 14:25:54

快速幂运算

快速幂运算 一、快速幂运算快速幂运算&#xff08;Exponentiation by Squaring&#xff09;基本思想算法实现&#xff08;②③为非递归&#xff09;① 递归运算② 普通 除模运算&#xff08;不带 **模数** 与 带 **模数**&#xff09;③ 按位与运算 使用示例示例代码 复杂度分析…...

编程日记 2025/9/8 10:16:41

vue @import引入CSS scoped无效 造成全局样式污染

引入css文件导致全局样式污染 1.写在单组件的style里面css样式&#xff0c;如果标签内不加scoped可能会影响其他组件的样式 <style lang"scss" scoped> </style> 2.通过import引入的外部css文件&#xff0c;这种引入方式是全局的&#xff0c;也会影响其…...

编程日记 2025/9/8 8:50:45

基于Flask-Login简单登录和权限控制实践

1. 关于Flask-Login Flask-Login 是一个为python Flask Web框架设计的扩展，用于管理用户会话（用户登录状态）。它提供了简单的接口来处理用户登录、注销、记住用户等功能，同时确保用户会话的安全性。以下是 Flask-Login 的一些关键特性和功能： 1.1. 主要功能 用户会话管理…...

编程日记 2025/9/3 19:09:14

文件流---------获取文件的内容到控制台

总流程&#xff1a;先创建一个文本文件------->里面写入一些内容&#xff08;纯字母和字母加文字&#xff09;-----------> 然后通过输入流获取文件里面的内容&#xff0c;两种方式。 1.第一种&#xff0c;获取单个的字符 &#xff0c;先创建文件 &#xff0c;java.txt…...

编程日记 2025/9/6 15:18:51

idea 2024 build菜单不见了

Q如题 idea 2024 新版UI添加build和recompile菜单 A如图&#xff0c;右键顶部栏之后&#xff0c;点击Add to Main Toolbar菜单&#xff0c;在里面就能找到Build菜单&#xff0c;添加接口。 Recompile菜单的话在Customize Toolbar中搜索添加才行。...

编程日记 2025/8/17 19:16:15

深入理解计算机操作系统（持续更新中...）

文章目录 一、计算机系统漫游1.1信息就是位上下文 一、计算机系统漫游 1.1信息就是位上下文 源程序实际上就是一个由值0和1组成的位&#xff08;又称为比特&#xff09;&#xff0c;八个位被组织成一组&#xff0c;称为字节。每个字节表示程序中的某些文本字符 大部分现代计…...

编程日记 2025/9/3 4:28:15

[dp8_子数组] 乘积为正数的最长子数组长度 | 等差数列划分 | 最长湍流子数组

目录 1.乘积为正数的最长子数组长度 2.等差数列划分 3.最长湍流子数组 写代码做到&#xff0c;只用维护好自己的一小步 1.乘积为正数的最长子数组长度 链接&#xff1a;1567. 乘积为正数的最长子数组长度 给你一个整数数组 nums &#xff0c;请你求出乘积为正数的最长子数…...

编程日记 2025/9/8 12:01:19

量子机器学习（Quantum Machine Learning, QML）在优化测试组合

量子机器学习（Quantum Machine Learning, QML）在优化测试组合选择中展现出显著潜力，通过量子计算的并行性和量子态叠加特性，可高效解决传统方法难以处理的组合爆炸问题。以下是其技术实现路径、优势及落地案例： 一、QML优化测试组合的核心原理 1. 量子并行性加速搜索 经典…...

编程日记 2025/9/1 3:44:08

Go语言Slice切片底层

Go语言&#xff08;Golang&#xff09;中切片&#xff08;slice&#xff09;的相关知识、包括切片与数组的关系、底层结构、扩容机制、以及切片在函数传递、截取、增删元素、拷贝等操作中的特性。并给出了相关代码示例和一道面试题。关键要点包括&#xff1a; 数组特性&#xf…...

编程日记 2025/9/7 13:25:30

导入 Excel 批量替换文件夹名称

文件夹重命名的需求是多种多样的&#xff0c;前面我们介绍过按照规则修改文件夹名称的方法。但是在某些场景下&#xff0c;这个方法可能是不适用的&#xff0c;比如我们修改文件夹的规则是多种多样的&#xff0c;是无规律的。那我们应该怎么做呢&#xff1f;今天我们就给大家介…...

编程日记 2025/9/8 10:55:52

数据库或表数据迁移（使用Navicat迁移MySQL数据库表数据）

&#x1f91f;致敬读者 &#x1f7e9;感谢阅读&#x1f7e6;笑口常开&#x1f7ea;生日快乐⬛早点睡觉 &#x1f4d8;博主相关 &#x1f7e7;博主信息&#x1f7e8;博客首页&#x1f7eb;专栏推荐&#x1f7e5;活动信息 文章目录 数据库或表数据迁移&#xff08;使用Navicat…...

编程日记 2025/8/31 17:35:55

Matlab Add Legend To Graph-图例添加到图

Add Legeng To Graph: Matlab的legend&#xff08;&#xff09;函数-图例添加到图 将图例添加到图 ,图例是标记绘制在图上的数据序列的有用方法。 下列示例说明如何创建图例并进行一些常见修改&#xff0c;例如更改位置、设置字体大小以及添加标题。您还可以创建具有多列的图…...

编程日记 2025/8/27 11:30:48

【Linux】what is pam？PAM模块学习笔记

文章目录 1. pam模块简介2. pam验证的工作流程3. pam模块配置文件3.1 配置文件的格式3.1.1 验证类别type3.1.2 验证的控制标识 control flag3.1.3 pam模块 4. login的PAM验证机制流程5. 补充&#xff1a;其他pam相关文件6. 参考内容 1. pam模块简介 PAM: Pluggable Authentica…...

编程日记 2025/9/3 20:25:10

5.1 GitHub订阅监控系统实战：FastAPI+SQLAlchemy高效架构设计与核心源码揭秘

GitHub Sentinel Agent 分析报告功能设计与实现 关键词：订阅管理 API 设计、GitHub API 集成、SQLAlchemy ORM、JWT 认证、单元测试框架 1. 订阅管理功能架构设计 订阅管理模块采用分层架构设计，通过 FastAPI 构建 RESTful 接口，结合 SQLAlchemy ORM 实现数据持久化： #me…...

编程日记 2025/9/7 8:14:14

【BEPU V1物理】BEPUphysics v1 入门指南 汉化笔记#1

BEPUphysics v1 入门指南 前言下载获取库工程1.创建物理模拟环境2.添加物理实体3.与物理系统交互4.发射物体5.构建环境6.事件处理7. 进阶学习 前言 本文档记录完成 BEPUphysics 物理引擎的基础设置。 文档链接:https://github.com/bepu/bepuphysics1/blob/master/Documentatio…...

编程日记 2025/9/3 12:29:22

方法加事务在多线程中注意事项

方法加事务在多线程中注意事项 redission分布式锁释放异常问题 https://www.jianshu.com/p/055ae798547a https://blog.csdn.net/cheng__yu/article/details/122625649 虽然文章 https://blog.csdn.net/cheng__yu/article/details/122625649 和 redission锁是没关系的&#…...

编程日记 2025/9/3 0:08:14

开源 2D 横版跳跃游戏 SuperTux

官网 https://www.supertux.org/ 正文 在游戏的世界里&#xff0c;开源游戏以其独特的魅力吸引着众多玩家和开发者。今天要介绍的 SuperTux&#xff0c;便是一款备受瞩目的开源 2D 横版跳跃游戏&#xff0c;风格类似经典的超级马里奥系列。 2024 年&#xff0c;SuperTux 开发团…...

编程日记 2025/9/5 14:50:03

基于HASM模型的高精度建模matlab仿真

目录 1.程序功能描述 2.测试软件版本以及运行结果展示 3.核心程序 4.本算法原理 5.完整程序 1.程序功能描述 本课题主要使用HASM进行高精度建模&#xff0c;主要对HASM模型进行介绍以及在实际中如何进行简化实现的。 2.测试软件版本以及运行结果展示 MATLAB2022A版本运行…...

编程日记 2025/9/8 1:27:44

C++多线程编程时的伪共享问题及其定位和解决

一、引言 在多线程编程和共享内存系统中&#xff0c;为了提高程序性能&#xff0c;常常需要对共享数据进行处理。然而&#xff0c;在并发环境下&#xff0c;一种名为“伪共享&#xff08;False Sharing&#xff09;”的问题可能会悄然出现&#xff0c;它虽然不像传统的多线程同…...

编程日记 2025/9/5 4:19:42

高并发短信系统设计：基于SharingJDBC的分库分表、大数据同步与实时计算方案

高并发短信系统设计&#xff1a;基于SharingJDBC的分库分表、大数据同步与实时计算方案 一、概述 在当今互联网应用中&#xff0c;短信服务是极为重要的一环。面对每天发送2000万条短信的需求&#xff0c;我们需要一个能够处理海量数据&#xff08;一年下来达到数千万亿级别&…...

编程日记 2025/8/31 20:44:08

【HTML】html文件

HTML文件全解析&#xff1a;搭建网页的基石 在互联网的广袤世界里&#xff0c;每一个绚丽多彩、功能各异的网页背后&#xff0c;都离不开HTML文件的默默支撑。HTML&#xff0c;即超文本标记语言&#xff08;HyperText Markup Language&#xff09;&#xff0c;作为网页创建的基…...

编程日记 2025/9/8 9:18:45

5.11 GitHub API调试五大高频坑：从JSON异常到异步阻塞的实战避坑指南

GitHub API调试五大高频坑：从JSON异常到异步阻塞的实战避坑指南 关键词：GitHub API 调试、JSON 解析异常、提示工程优化、异步任务阻塞、数据清洗策略 5.5 测试与调试：调试常见问题 问题1：GitHub API 调用异常 现象： requests.exceptions.HTTPError: 403 Client Error…...

编程日记 2025/9/5 22:47:53

协程的原生挂起与恢复机制

目录 &#x1f50d; 一、从开发者视角看协程挂起与恢复 &#x1f9e0; 二、协程挂起和恢复的机制原理&#xff1a;核心关键词 ✅ suspend 函数 ≠ 普通函数 ✅ Continuation&#xff08;协程的控制器&#xff09; &#x1f527; 三、编译器做了什么&#xff1f;&#xff0…...

编程日记 2025/9/4 7:22:57

机器学习中的数学(PartⅡ)——线性代数：2.2矩阵

概述 本节内容也相对简单&#xff0c;首先介绍了矩阵的定义&#xff0c;矩阵的表示方法&#xff1b;然后介绍了矩阵的加法和乘法&#xff0c;与标量的乘法&#xff0c;以及一些矩阵相关算数运算的性质&#xff0c;包括满足结合律、交换律&#xff1b;矩阵的逆和转置&#xff1…...

编程日记 2025/9/4 14:36:42

泉涌未来：科技与生态的共生诗篇-济南

故事背景 故事发生在中国山东济南的未来城市环境&#xff0c;这里不再是单纯的自然景观与现代建筑的堆砌&#xff0c;而是科技与生态深度融合的奇妙世界。泉水&#xff0c;这一济南的灵魂元素&#xff0c;在未来科技的赋能下&#xff0c;成为连接城市各个角落的纽带。量子态泉水…...

编程日记 2025/9/3 6:20:59

用AI生成系统架构图

DeepSeek+Drawio+SVG绘制架构图-找到一种真正可行实用的方法和思路 1、使用DeepSeek生成SVG文件，导入drawio工具的方法 🔥 问题根源分析 错误现象： • 导入时报错包含 data:image/SVG;base64 和 %20 等 URL 编码字符 • 代码被错误转换为 Base64 格式（适用于网页嵌入，但…...

编程日记 2025/9/2 15:28:42

网络基础1

目录 初识协议 协议分层 软件分层的好处 OSI七层模型 TCP/IP 五层(或四层)模型 再谈协议 为什么要有 TCP/IP 协议&#xff1f; TCP/IP 协议与操作系统的关系 所以究竟什么是协议&#xff1f; 网络传输基本流程 认识 MAC 地址 局域网(以太网为例)通信原理 报文的传…...

编程日记 2025/9/7 21:02:48

免费且好用的PDF水印添加工具

软件介绍 今天要给大家推荐一款超实用的PDF添加水印工具&#xff0c;它能够满足用户给PDF文件添加水印的需求&#xff0c;而且完全免费。 这款PDF添加水印的软件有着简洁的界面&#xff0c;操作简便&#xff0c;无需安装&#xff0c;解压后即可使用。 在使用前&#xff0c;先…...

编程日记 2025/9/7 8:51:13