第1章 响应式编程概述 1
$ t P x q# y+ V# F9 q1．1 并发与并行的关系 1
( P0 B w1 k" M1 Z1．2 如何理解响应式编程中的背压 2
9 B8 Z6 W" V' Y8 B D1．3 源码接口设计启示 3
! P: K$ H( y' s9 h6 N6 w2 v& {1．4 如何看待众多函数表达式 11# P% K+ s4 N' s, W7 }: \; |
1．5 Reactor与RxJava的对比 12
2 D6 i2 K& T5 C |1 P+ ?1．6 小结 14& i4 a7 o% e6 A* O( p! d
第2章 对Flux的探索 15
5 i# _6 j: h1 C6 k) Z& m4 h2．1 对Flux．subscribe订阅逻辑的解读 16: Q; N6 A1 i( a5 }2 ]. U7 a, ]
2．1．1 对CoreSubscriber的解读 17
# Z& K% ]1 \9 R4 H, f; w' a# v, W2．1．2 对LambdaSubscriber的解读 226 P( X0 {% u/ m5 w* K
2．1．3 AtomicXxxFieldUpdater的技法应用 24
: r% U- @( F2 e- t" |! N4 \2．2 用Flux．create创建源 30 M7 f9 _ ?, @2 d, n1 v
2．2．1 FluxCreate细节探索 31
% X; @0 j' ?7 Z- S- A. ?2．2．2 Flux的快速包装方法 36
% B/ h7 B* m9 a0 f) m2．2．3 Reactor 3中的generate方法 38
( g& I, P+ X& O# p: `9 u! F2．3 蛇行走位的QueueSubscription 435 Z+ ~& C+ J/ ]: ~" T9 e
2．3．1 无界队列SpscLinkedArrayQueue 44
; r: A/ r6 ]% {! J B: I" J, S+ @2．3．2 QueueSubscription．requestFusion的催化效应 47 w2 O, |, L/ u5 I) ^9 w
2．4 Mono的二三事 50
8 \( ~, O' \+ q3 T2．5 通过BaseSubscriber自定义订阅者 51
/ N# D' f* E8 i2．6 将常见的监听器改造成响应式结构 53
3 p5 E9 m9 ?7 K7 _: G9 Y m2．7 Flux．push的特殊使用场景及细节探索 56
6 V! F! z5 A7 \9 c3 _2．8 对Flux．handle的解读 587 I0 D; i! T: A! h( F1 b
2．9 小结 63( V) w0 j4 U9 E- z
第3章 调度器 64
' m& L" h- W1 u( x7 Z; U p3．1 深入理解Schedulers．elastic 65+ s4 h. w5 U' v, E& y4 D! y
3．1．1 CachedScheduler的启示 66
! S0 ~8 \/ i6 t5 n+ n5 `* u: c3．1．2 ElasticScheduler的类定义思路 68
7 V9 V3 S9 s* d" a# V! Q, c. W3．1．3 对Schedulers．decorateExecutorService的解读 69
1 F" q' V2 N8 n6 D3．1．4 对ElasticScheduler．schedule的解读 70' i k2 c* h a) o& a, K0 X$ c
3．1．5 对ElasticScheduler．DirectScheduleTask的解读 71
- P% ]. z; |! ^ w5 u* \/ W# a8 o3．1．6 对Schedulers．directSchedule的解读 73
' W) e; Z {& H: r( N* @) m6 ?3．1．7 对ElasticScheduler．ElasticWorker的解读 74; W4 _& N$ c+ z
3．1．8 ElasticScheduler小结 82' T9 z7 u) T% }* M6 Q+ ~" Y
3．2 深入解读publishOn 82- B& f0 U8 g/ O
3．2．1 publishOn流程概述 826 T3 c& V1 G$ n2 J% G$ l; t
3．2．2 对FluxPublishOn的解读 85
* w' d/ |5 Z0 k; K3．3 深入解读subscribeOn 98
: D" F \- q. s. J( s1 m3．4 Flux．parallel＆Flowable．parallel的并行玩法 1089 k# [: v6 ~' A+ T6 L$ K8 N
3．5 ParallelFlux．runOn＆ParallelFlowable．runOn的调度实现 117$ d4 P3 u' {% g- T. p+ z- S @
3．6 小结 122
- J' F6 `+ u/ r- v第4章 对Reactor操作的解读 123
7 j% z! q/ B, |5 |+ t0 {: i4．1 filter操作 123
6 d) a$ b% `( x7 M1 Q9 a" [; r5 B4．2 transform操作 124! o! s) f2 l; C U# E0 d
4．3 compose与transformDeferred操作 127
! D( a, \" B8 E4．4 批处理操作 129% {; u: C4 b, c; g& X* S4 b' [$ k0 P
4．4．1 buffer操作 1307 v4 k7 `% s$ |3 ^, Q
4．4．2 window 操作 132, ?5 X% V% w' f# s* @# d. n
4．4．3 groupBy 操作 139- H0 j a8 e4 O: F0 x9 ~
4．5 merge和mergeSequential操作 140. o+ ~8 N# F0 I; f4 V5 d, V
4．6 flatMap和flatMapSequential操作 142( A% {$ W F/ b; `4 J) f" v' S
4．7 concatMap操作 144
2 ~: H! L$ g; p7 h4．8 combineLatest操作 145 `0 k$ }& F }% C1 c
4．9 ConnectableFlux的二三事及对reactor-bug的分析 146
* e$ P" C4 e& r2 ?# U$ N4．10 小结 158
! E0 k; a6 u9 S; s# [7 L( W2 X+ q+ F第5章 对Processor的探索 159
t& N$ n4 u' V/ q: Y2 ]5．1 UnicastProcessor详解 160+ I2 L; S4 Q Z
5．2 DirectProcessor详解 164
x8 y% V2 M+ u: j; z5．3 EmitterProcessor详解 1690 {& k+ z, D# F# X
5．4 ReplayProcessor详解 174
; Z9 d0 j- p0 G5．5 小结 1889 q3 }9 i/ v( M+ s& x8 x
第6章 TopicProcessor及Reactor中匹配Disruptor的实现代码 189
% P5 [2 D2 n: z7 W/ v) G6．1 初识TopicProcessor 1908 w7 V8 f' V3 Z
6．2 TopicProcessor构造器 195
! Y7 J$ s4 f" N+ v, ~6．3 对RingBuffer中publish方法的解读 205
! X( m; b- r I+ _; q6．4 对MultiProducerRingBuffer的解读 2082 |2 q0 X; p: i7 N( b$ m
6．4．1 RingBuffer中的UnsafeSupport 210
0 u3 I( _6 z7 d6．4．2 RingBuffer中的next与publish操作 216
- W9 d; p! I8 T( n9 N6．5 TopicProcessor．onSubscribe及类BossEventLoopGroup的设计 221
6 ?9 y0 ~1 Z. @8 y6．6 TopicProcessor．subscribe及类WorkerEventLoopGroup的设计 225
! k: u' r( B) M! n6．7 小结 241( U# m/ W8 \ ?
第7章 对WorkQueueProcessor的解读 242$ ?4 R% K+ H# M, ]# ?; t( P
7．1 WorkQueueProcessor的requestTask 244
# @" Q0 ~ A# S% C1 F7．2 WorkQueueProcessor的subscribe 2477 \2 |9 f+ F' ^# X7 @: Z* f
7．3 冷热数据源的区别 251
, A6 r, j: t% V) z. o7．4 实例详解 252- j% Q6 |7 d v' n
7．5 小结 255) r9 A# W3 I+ W" F S
第8章 Reactor中的Context 256
- D: G, c* I( _2 F: Z8．1 Context的设计缘由 256
% {( W/ K2 C/ |/ |8．2 对Context的解读 258
& u3 i3 {5 |! d7 c8．3 小结 265
4 z# L% [/ V! T( S! f) t' |% @第9章 Reactor中的测试 2679 R2 e2 O7 R- j+ f3 \, b
9．1 StepVerifier测试源码解析 267
7 v" Y" b7 q" F/ `9．1．1 接口定义 2674 O8 m$ l1 E& M B
9．1．2 接口实现 2692 [9 W3 K) h/ e, l, C! m
9．1．3 验证 274& h+ c/ `+ l6 {. Q9 T
9．2 StepVerifier测试应用 275
7 H$ [3 V7 v! c) L9 j% c: g9．3 操作时间测试 278
1 l5 ~9 g9 G+ q. @9 ]9．4 使用StepVerifier进行后置验证 286
& Z- G; w+ J" G! ?( ~ q; ^9．5 关于Context的测试 289
* H" Z( H. X) T3 U% o7 h) X9．6 使用TestPublisher对自定义中间操作进行测试 296
; @# K& x5 X0 M8 T1 N6 v9．7 使用PublisherProbe检查执行路径 305
- k6 N; S) B4 m+ m/ F# s4 d, k9．8 小结 3104 ~7 [( `" @9 \# s1 @, _+ |
第10章 Reactor中的调试 311
, ]. q' M( G p* C; n10．1 启用调试模式 311
# P& N9 k+ Q1 k* H1 h2 {* |10．2 在调试模式下读取堆栈跟踪信息 3153 ?+ r% N$ L. V. n
10．3 通过checkpoint方式进行调试 325
# [; T6 n3 |2 n- E1 v8 ^6 r10．4 记录订阅关系下与操作流程相关的日志 326
' ?- _3 O2 _$ K9 s10．5 小结 326
0 c5 o( ~, m* X7 k
电子书
1031 人阅读
|
16 人回复
|
2022-08-14
