From a74f948934bc7e6e841bd86ce73e1080cb0c7868 Mon Sep 17 00:00:00 2001 From: asahi Date: Tue, 25 Mar 2025 18:59:09 +0800 Subject: [PATCH] =?UTF-8?q?doc:=20reactor=E6=96=87=E6=A1=A3=E6=B7=BB?= =?UTF-8?q?=E5=8A=A0=E7=9B=AE=E5=BD=95?= MIME-Version: 1.0 Content-Type: text/plain; charset=UTF-8 Content-Transfer-Encoding: 8bit --- spring/webflux/Reactor.md | 32 ++++++++++++++++++++++++++++++++ 1 file changed, 32 insertions(+) diff --git a/spring/webflux/Reactor.md b/spring/webflux/Reactor.md index f34321e..7564ae7 100644 --- a/spring/webflux/Reactor.md +++ b/spring/webflux/Reactor.md @@ -1,3 +1,35 @@ +- [Reactor](#reactor) + - [Reactive Programming](#reactive-programming) + - [命令式迁移到响应式](#命令式迁移到响应式) + - [可组合性与可读性](#可组合性与可读性) + - [Assembly Line](#assembly-line) + - [Operators](#operators) + - [Nothing Happens Until You subscribe()](#nothing-happens-until-you-subscribe) + - [backpressure](#backpressure) + - [hot \& cold](#hot--cold) + - [Subscriber和Publisher](#subscriber和publisher) + - [Publisher](#publisher) + - [Subscriber](#subscriber) + - [Reactor Core](#reactor-core) + - [Flux `0...n`](#flux-0n) + - [Mono `0...1`](#mono-01) + - [创建Mono/Flux并进行订阅的方式](#创建monoflux并进行订阅的方式) + - [String sequence](#string-sequence) + - [Flux.empty](#fluxempty) + - [Flux.range](#fluxrange) + - [Lambda Subscribe](#lambda-subscribe) + - [Disposable](#disposable) + - [BaseSubscriber](#basesubscriber) + - [backpressure](#backpressure-1) + - [buffer](#buffer) + - [prefetch](#prefetch) + - [初始请求](#初始请求) + - [补充优化(Replenishing Optimization)](#补充优化replenishing-optimization) + - [limitRate](#limitrate) + - [lowTie](#lowtie) + - [limitRequest](#limitrequest) + + # Reactor ## Reactive Programming 响应式编程是一种异步编程范式,关注于`数据流`和`状态变化的传播`。java的响应式编程接口被包含在java9的`Flow`中。