响应式编程
0 人感兴趣 · 35 次引用
- 最新
- 推荐
响应式编程——初识 Flux 和 Mono
Reactor 是一个响应式编程的基础类库,其中有两个很关键的类:Flux 和 Mono。掌握这两个类和相关概念有助于我们学习响应式编程。
响应式编程:Vert.x 官网学习
本文基于 Vert.x 官网 https://vertx.io/ 内容,带领大家学习响应式编程里比较有名的工具包 Vert.x 。文章内容取自官网由博主简化总结,希望帮助大家理解响应式编程。
新一代通信协议—— RSocket
RSocket 是一种二进制字节流传输协议,位于 OSI 模型中的5~6层,底层可以依赖 TCP、WebSocket、Aeron 协议。最初由 Netflix 开发,支持 Reactive Streams。其开发背后的动机是用开销更少的协议取代超文本传输协议(HTTP),HTTP 协议对于许多任务(如微服务通信
响应式流的核心机制——背压机制
采用背压机制,消费者会根据自身的处理能力来请求数据,而生产者也会根据消费者的能力来生产数据,从而在两者之间达成一种动态的平衡,确保系统的即时响应性。
java Reactive Streams 响应式流式编程
Java 9的 Reactive Streams是对异步流式编程的一种实现。它基于异步发布和订阅模型,具有非阻塞“背压”数据处理的特点。
rxjs Observable filter Operator 的实现原理介绍
看下面这段使用 filter Operator 的代码:
rxjs Observable 自定义 Operator 的开发技巧
操作符是 RxJS 库和 Observables 的基础块。 它使我们能够通过使用一些关键字(函数)来执行复杂的操作。 运算符只不过是获取源 Observable、对其执行操作并返回新 Observable 的函数。
rxjs Observable 设计原理背后的 Pull 和 Push 思路
Observables 顾名思义,是可以被观察的事务。在 Rxjs 的上下文里,Observable 会随着时间的推移,在某个时间点产生数据。
Rxjs TakeUntil 操作符的学习笔记
TakeUntil 的官方文档对这个操作符的解释是:即它可以被赋予另一个起锚定作用的 Observable,当该锚定 Observable emit 值时,原始的 Observable 就停止发射值,进入 complete 操作。
GrowingIO Reactor 速成指南
所以在本文档中我们主要针对的是一些学习过程容易让新人感到迷茫的知识点(map、flatMap、异步、并发),期望能让新人更好上手 Spring WebFlux。
Reactive Spring 实战 -- 响应式 MySql 交互
本文与大家探讨Spring中如何实现MySql响应式交互。
SpringCloud Gateway 动态路由
阅读源码学习 SpringCloud Gateway 工作原理,研究路由加载和查找的过程,并在此基础上,设计实现动态路由持久化存储。
Reactive Spring 实战 -- WebFlux 使用教程
WebFlux是Spring 5提供的响应式Web应用框架。 本文主要介绍WebFlux的使用。
深入理解 r2dbc-mysql
mysql应该是我们在日常工作中使用到的一个非常普遍的数据库,虽然mysql现在是oracle公司的,但是它是开源的,市场占有率还是非常高的。