欢迎来到我的博客

分享技术、记录成长

最新文章

Request

Request

public class Part06Request { ReactiveRepository<User> repository = new ReactiveUserRepository(); //======================================================================================== // TOD...

阅读全文 →

Merge

Merge

public class Part05Merge { //======================================================================================== // TODO Merge flux1 and flux2 values with interleave public Flux<User> merge...

阅读全文 →

学习如何转换异步数据

学习如何转换异步数据

学习如何转换异步数据 描述 Reactor 附带多个可用于转换数据的操作符。 public class Part04Transform { //======================================================================================== // TODO Capitalize the user username, f...

阅读全文 →

StepVerifier-步骤验证器及其使用方法

HTTPS API StepVerifier

StepVerifier 描述 到目前为止，你对每个练习的解答都是通过将 Publisher 你定义的答案传递给一个测试用例来检查的 StepVerifier。 该工件中的此类 reactor-test 能够订阅任何 Publisher （例如，Flux Akka Stream 或 A 流……），然后断言一组关于该序列的用户定义期望。 如果触发的任何事件与当前预期不符，则会 StepVerifie...

阅读全文 →

学习如何创建 Mono 实例

HTTPS API 学习如何创建

学习如何创建 Mono 实例 Flux 描述 AMono<T>是一个响应式流 Publisher，还增强了许多可用于生成、转换、编排 Mono 序列的操作符。 它是最多 Flux 可以发出 1 个<T>元素的特例：Mono 要么有值（包含元素），要么为空（不包含元素），要么失败（错误）。 AMono<Void>可用于仅对完成信号感兴趣的情况（相当于 Reacti...

阅读全文 →

学习如何创建 Flux 实例

Java HTTPS 学习如何创建

学习如何创建 Flux 实例 描述 AFlux<T>是一个响应式流Publisher，它增强了许多操作符，可用于生成、转换、编排 Flux 序列。 它可以发出 0 到n 个 <T>元素（onNext事件），然后完成或出错（onComplete以及onError终止事件）。如果没有触发终止事件，则循环Flux将无限进行。 Flux 上的静态工厂允许创建源，或从多个回调类型生成...

阅读全文 →

响应式编程简介

GitHub HTTPS JDK

响应式编程入门 Reactor 3 是一个围绕该规范构建的库，将响应式编程Reactive Streams范式引入JVM。 在本课程中，你将熟悉 Reactor API。那么，让我们快速介绍一下响应式流和响应式编程中更通用的概念。 为什么 响应式编程是一种新的编程范式，它使用声明式代码（类似于函数式编程）来构建异步处理管道。它是一种基于事件的模型，数据一旦可用就会被推送给消费者：我们处理的是异步事...

阅读全文 →

开源MQTT协议记录

MQTT 开源MQTT协议记录

JetLinks 分组 topic 上下行 说明 属性上报 /{productId:产品ID}/{deviceId:设备ID}/properties/report 上行 上报物模型属性数据 读取属性 /{productId:产品ID}/{deviceId:设备ID}/properties/read 下行 平台下发读取物模型属性数据指令 /{productId:产品ID}/{deviceId:设备I...

阅读全文 →

k8s nacos 集群部署流程

K8s MySQL Nacos

一、核心配置解析 Headless Service (nacos-headless) 类型为 ClusterIP: None，用于为 StatefulSet 提供稳定的 DNS 记录（如 nacos-0.nacos-headless.default.svc.cluster.local）。 暴露 4 个端口： 8848：Nacos 客户端访问端口 9848/9849：Nacos 2.0+ 的 gRP...

阅读全文 →