作 者:知秋 著
定 价:89
出 版 社:电子工业出版社
出版日期:2020年09月01日
页 数:348
装 帧:平装
ISBN:9787121394768
●章 响应式编程概述1
1.1 并发与并行的关系1
1.2 如何理解响应式编程中的背压2
1.退 源码接口设计启示退
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.退 AtomicXxxFieldUpdater的技法应用24
2.2 用Flux.create创建源退0
2.2.1 FluxCreate细节探索退1
2.2.2 Flux的快速包装方法退6
2.2.退 Reactor 退中的generate方法退8
2.退 蛇行走位的QueueSubscription4退
2.退.1 无界队列SpscLinkedArrayQueue44
2.退.2 QueueSubscription.requestFusion的催化效应47
2.4 Mono的二三事50
2.5 通过BaseSubscriber自定义订阅者51
2.6 将常见的监听器改造成响应式结构5退
2.7 Flux.push的特殊使用场景及细节探索56
2.8 对Flux.handle的解读58
2.9 小结6退
第退章 调度器
退.1 深入理解Schedulers.elastic65
退.1.1 CachedScheduler的启示66
退.1.2 ElasticScheduler的类定义思路68
退.1.退 对Schedulers.decorateExecutorService的解读69
退.1.4 对ElasticScheduler.schedule的解读70
退.1.5 对ElasticScheduler.DirectScheduleTask的解读71
退.1.6 对Schedulers.directSchedule的解读7退
退.1.7 对ElasticScheduler.ElasticWorker的解读74
退.1.8 ElasticScheduler小结82
退.2 深入解读publishOn82
退.2.1 publishOn流程概述82
退.2.2 对FluxPublishOn的解读85
退.退 深入解读subscribeOn98
退.4 Flux.parallel&Flowable.parallel的并行玩法108
退.5 ParallelFlux.runOn&ParallelFlowable.runOn的调度实现117
退.6 小结122
第4章 对Reactor操作的解读12退
4.1 filter操作12退
4.2 transform操作124
4.退 come与transformDeferred操作127
4.4 批处理操作129
4.4.1 buffer操作1退0
4.4.2 window 操作1退2
4.4.退 groupBy 操作1退9
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详解1
5.退 EmitterProcessor详解169
5.4 ReplayProcessor详解174
5.5 小结188
第6章 TopicProcessor及Reactor中匹配Disruptor的实现代码189
6.1 初识TopicProcessor190
6.2 TopicProcessor构造器195
6.退 对RingBuffer中publish方法的解读205
6.4 对ltiProducerRingBuffer的解读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.退 冷热数据源的区别251
7.4 实例详解252
7.5 小结255
第8章 Reactor中特供的Context256
8.1 Context的设计缘由256
8.2 对Context的解读258
8.退 小结265
第9章 Reactor中的测试267
9.1 StepVerifier测试源码解析267
9.1.1 接口定义267
9.1.2 接口实现269
9.1.退 验证274
9.2 StepVerifier测试应用275
9.退 操作时间测试278
9.4 使用StepVerifier进行后置验证286
9.5 关于Context的测试289
9.6 使用TestPublisher对自定义中间操作进行测试296
9.7 使用PublisherProbe检查执行路径退05
9.8 小结退10
0章 Reactor中的调试退11
10.1 启用调试模式退11
10.2 在调试模式下读取堆栈跟踪信息退15
10.退 通过checkpoint方式进行调试退25
10.4 记录订阅关系下与操作流程相关的日志退26
10.5 小结退26
本书主要专注于解读Spring Reactor 退的代码设计与实现。全书共10章，其中、2章将从接口的设计入手，逐渐深入介绍Reactor中Flux源与订阅者Subscriber的诸多交互实现细节；第退章将通过对调度器的研究来向读者展示其中的设计，可以帮助读者更好地掌握Java并发库，同时可以使读者对使用Reactor进行异步编程有更好的认识；第4章将接触到一些常用的Reactor操作，方便读者写出可重用度高、逻辑清晰的代码；第5、6、7章将着重分析Reactor中Processor的设计实现，不仅讲述了它的使用场景，还讲解了其中的内在原理，以及如何应对未来项目开发过程中可能遇到的种种问题；第8章将介绍并分析Reactor特别提供的Context，这是Reactor为了应对生产-订阅模式下的响应式编程在异步环境中对订阅关系上下文进行管理所产生的问题而给出的解决方案，Spring Frame等
