Java编程方法论 响应式Spring Reactor 3设计与实现

"1.Spring官方布道师Josh Long、Spring Reactor项目创始人Stephane Maldini以及业内专家翟永超、梁桂钊、方志斌、于文龙、尹相宇、刘嘉诚联袂力荐。 2.本书包含配套视频及源码资源，以及免费观看国外知名Java开发者分享视频（中文字幕）。 3.本书主要专注于解读Spring Reactor 3的代码设计与实现，以揭示其中的设计精髓，帮助大家灵活运用及提升代码设计思维。 4.本书是学习响应式编程非常好的参考资料，是成体系的、传授编程思想和技巧的图书。"

本书主要专注于解读Spring Reactor 3的代码设计与实现。全书共10章，其中第1、2章将从接口的设计入手，逐渐深入介绍Reactor中Flux源与订阅者Subscriber的诸多交互实现细节；第3章将通过对调度器的研究来向读者展示其中的优秀设计，可以帮助读者更好地掌握Java并发库，同时可以使读者对使用Reactor进行异步编程有更好的认识；第4章将接触到一些常用的Reactor操作，方便读者写出可重用度高、逻辑清晰的代码；第5、6、7章将着重分析Reactor中Processor的设计实现，不仅讲述了它的使用场景，还讲解了其中的内在原理，以及如何应对未来项目开发过程中可能遇到的种种问题；第8章将介绍并分析Reactor特别提供的Context，这是Reactor为了应对生产-订阅模式下的响应式编程在异步环境中对订阅关系上下文进行管理所产生的问题而给出的解决方案，Spring Framework 5.2中的响应式事务也是基于它实现的；第9章将主要介绍Reactor中的测试，同时带着读者一步一步设计实现一个针对Reactor项目的测试库；第10章将主要介绍Reactor中的调试，可以教会读者根据不同的需求采取不同的调试方式。本书适合有Java编程基础的中高级Java开发工程师、想要学习代码设计思路与技巧的读者、对响应式编程感兴趣的读者阅读。

 

第1章 响应式编程概述1
1.1 并发与并行的关系1
1.2 如何理解响应式编程中的背压2
1.3 源码接口设计启示3
1.4 如何看待众多函数表达式11
1.5 Reactor与RxJava的对比12
1.6 小结14
第2章 对Flux的探索15
2.1 对Flux.subscribe订阅逻辑的解读16
2.1.1 对CoreSubscriber的解读17
2.1.2 对LambdaSubscriber的解读22
2.1.3 AtomicXxxFieldUpdater的技法应用24
2.2 用Flux.create创建源30
2.2.1 FluxCreate细节探索31
2.2.2 Flux的快速包装方法36
2.2.3 Reactor 3中的generate方法38
2.3 蛇行走位的QueueSubscription43
2.3.1 无界队列SpscLinkedArrayQueue44
2.3.2 QueueSubscription.requestFusion的催化效应47
2.4 Mono的二三事50
2.5 通过BaseSubscriber自定义订阅者51
2.6 将常见的监听器改造成响应式结构53
2.7 Flux.push的特殊使用场景及细节探索56
2.8 对Flux.handle的解读58
2.9 小结63
第3章 调度器64
3.1 深入理解Schedulers.elastic65
3.1.1 CachedScheduler的启示66
3.1.2 ElasticScheduler的类定义思路68
3.1.3 对Schedulers.decorateExecutorService的解读69
3.1.4 对ElasticScheduler.schedule的解读70
3.1.5 对ElasticScheduler.DirectScheduleTask的解读71
3.1.6 对Schedulers.directSchedule的解读73
3.1.7 对ElasticScheduler.ElasticWorker的解读74
3.1.8 ElasticScheduler小结82
3.2 深入解读publishOn82
3.2.1 publishOn流程概述82
3.2.2 对FluxPublishOn的解读85
3.3 深入解读subscribeOn98
3.4 Flux.parallel&Flowable.parallel的并行玩法108
3.5 ParallelFlux.runOn&ParallelFlowable.runOn的调度实现117
3.6 小结122
第4章 对Reactor操作的解读123
4.1 filter操作123
4.2 transform操作124
4.3 compose与transformDeferred操作127
4.4 批处理操作129
4.4.1 buffer操作130
4.4.2 window 操作132
4.4.3 groupBy 操作139
4.5 merge和mergeSequential操作140
4.6 flatMap和flatMapSequential操作142
4.7 concatMap操作144
4.8 combineLatest操作145
4.9 ConnectableFlux的二三事及对reactor-bug的分析146
4.10 小结158
第5章 对Processor的探索159
5.1 UnicastProcessor详解160
5.2 DirectProcessor详解164
5.3 EmitterProcessor详解169
5.4 ReplayProcessor详解174
5.5 小结188
第6章 TopicProcessor及Reactor中匹配Disruptor的实现代码189
6.1 初识TopicProcessor190
6.2 TopicProcessor构造器195
6.3 对RingBuffer中publish方法的解读205
6.4 对MultiProducerRingBuffer的解读208
6.4.1 RingBuffer中的UnsafeSupport210
6.4.2 RingBuffer中的next与publish操作216
6.5 TopicProcessor.onSubscribe及类BossEventLoopGroup的设计221
6.6 TopicProcessor.subscribe及类WorkerEventLoopGroup的设计225
6.7 小结241
第7章 对WorkQueueProcessor的解读242
7.1 WorkQueueProcessor的requestTask244
7.2 WorkQueueProcessor的subscribe247
7.3 冷热数据源的区别251
7.4 实例详解252
7.5 小结255
第8章 Reactor中特供的Context256
8.1 Context的设计缘由256
8.2 对Context的解读258
8.3 小结265
第9章 Reactor中的测试267
9.1 StepVerifier测试源码解析267
9.1.1 接口定义267
9.1.2 接口实现269
9.1.3 验证274
9.2 StepVerifier测试应用275
9.3 操作时间测试278
9.4 使用StepVerifier进行后置验证286
9.5 关于Context的测试289
9.6 使用TestPublisher对自定义中间操作进行测试296
9.7 使用PublisherProbe检查执行路径305
9.8 小结310
第10章 Reactor中的调试311
10.1 启用调试模式311
10.2 在调试模式下读取堆栈跟踪信息315
10.3 通过checkpoint方式进行调试325
10.4 记录订阅关系下与操作流程相关的日志326
10.5 小结326