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

10.4 记录订阅关系下与操作流程相关的日志

10.3 通过checkpoint方式进行调试

10.2 在调试模式下读取堆栈跟踪信息

10.1 启用调试模式

第10章 Reactor中的调试

9.8 小结

9.7 使用PublisherProbe检查执行路径

9.6 使用TestPublisher对自定义中间操作进行测试

9.5 关于Context的测试

9.4 使用StepVerifier进行后置验证

9.3 操作时间测试

9.2 StepVerifier测试应用

9.1 StepVerifier测试源码解析

第9章 Reactor中的测试

8.3 小结

8.2 对Context的解读

8.1 Context的设计缘由

第8章 Reactor中特供的Context

7.5 小结

7.4 实例详解

7.3 冷热数据源的区别

7.2 WorkQueueProcessor的subscribe

7.1 WorkQueueProcessor的requestTask

第7章 对WorkQueueProcessor的解读

6.7 小结

6.6 TopicProcessor.subscribe及类WorkerEventLoopGroup的设计

6.5 TopicProcessor.onSubscribe及类BossEventLoopGroup的设计

6.4 对MultiProducerRingBuffer的解读

6.3 对RingBuffer中publish方法的解读

6.2 TopicProcessor构造器

6.1 初识TopicProcessor

第6章 TopicProcessor及Reactor中匹配Disruptor的实现代码

5.5 小结

5.4 ReplayProcessor详解

5.3 EmitterProcessor详解

5.2 DirectProcessor详解

5.1 UnicastProcessor详解

第5章 对Processor的探索

4.10 小结

4.9 ConnectableFlux的二三事及对reactor-bug的分析

4.8 combineLatest操作

4.7 concatMap操作

4.6 flatMap和flatMapSequential操作

4.5 merge和mergeSequential操作

4.4 批处理操作

4.3 compose与transformDeferred操作

4.2 transform操作

4.1 filter操作

第4章 对Reactor操作的解读

3.6 小结

3.5 ParallelFlux.runOn&ParallelFlowable.runOn的调度实现

3.4 Flux.parallel&Flowable.parallel的并行玩法

3.3 深入解读subscribeOn

3.2 深入解读publishOn

3.1 深入理解Schedulers.elastic

第3章 调度器

2.9 小结

2.8 对Flux.handle的解读

2.7 Flux.push的特殊使用场景及细节探索

2.6 将常见的监听器改造成响应式结构

2.5 通过BaseSubscriber自定义订阅者

2.4 Mono的二三事

2.3 蛇行走位的QueueSubscription

2.2 用Flux.create创建源

2.1 对Flux.subscribe订阅逻辑的解读

第2章 对Flux的探索

1.6 小结

1.5 Reactor与RxJava的对比

1.4 如何看待众多函数表达式

1.3 源码接口设计启示

1.2 如何理解响应式编程中的背压

1.1 并发与并行的关系

第1章 响应式编程概述

前言

推荐序七

推荐序六

推荐序五

推荐序四

推荐序三

推荐序二

推荐序一

内容简介

版权信息

封面

封面

版权信息

内容简介

推荐序一

推荐序二

推荐序三

推荐序四

推荐序五

推荐序六

推荐序七

前言

第1章 响应式编程概述

1.1 并发与并行的关系

1.2 如何理解响应式编程中的背压

1.3 源码接口设计启示

1.4 如何看待众多函数表达式

1.5 Reactor与RxJava的对比

1.6 小结

第2章 对Flux的探索

2.1 对Flux.subscribe订阅逻辑的解读

2.2 用Flux.create创建源

2.3 蛇行走位的QueueSubscription

2.4 Mono的二三事

2.5 通过BaseSubscriber自定义订阅者

2.6 将常见的监听器改造成响应式结构

2.7 Flux.push的特殊使用场景及细节探索

2.8 对Flux.handle的解读

2.9 小结

第3章 调度器

3.1 深入理解Schedulers.elastic

3.2 深入解读publishOn

3.3 深入解读subscribeOn

3.4 Flux.parallel&Flowable.parallel的并行玩法

3.5 ParallelFlux.runOn&ParallelFlowable.runOn的调度实现

3.6 小结

第4章 对Reactor操作的解读

4.1 filter操作

4.2 transform操作

4.3 compose与transformDeferred操作

4.4 批处理操作

4.5 merge和mergeSequential操作

4.6 flatMap和flatMapSequential操作

4.7 concatMap操作

4.8 combineLatest操作

4.9 ConnectableFlux的二三事及对reactor-bug的分析

4.10 小结

第5章 对Processor的探索

5.1 UnicastProcessor详解

5.2 DirectProcessor详解

5.3 EmitterProcessor详解

5.4 ReplayProcessor详解

5.5 小结

第6章 TopicProcessor及Reactor中匹配Disruptor的实现代码

6.1 初识TopicProcessor

6.2 TopicProcessor构造器

6.3 对RingBuffer中publish方法的解读

6.4 对MultiProducerRingBuffer的解读

6.5 TopicProcessor.onSubscribe及类BossEventLoopGroup的设计

6.6 TopicProcessor.subscribe及类WorkerEventLoopGroup的设计

6.7 小结

第7章 对WorkQueueProcessor的解读

7.1 WorkQueueProcessor的requestTask

7.2 WorkQueueProcessor的subscribe

7.3 冷热数据源的区别

7.4 实例详解

7.5 小结

第8章 Reactor中特供的Context

8.1 Context的设计缘由

8.2 对Context的解读

8.3 小结

第9章 Reactor中的测试

9.1 StepVerifier测试源码解析

9.2 StepVerifier测试应用

9.3 操作时间测试

9.4 使用StepVerifier进行后置验证

9.5 关于Context的测试

9.6 使用TestPublisher对自定义中间操作进行测试

9.7 使用PublisherProbe检查执行路径

9.8 小结

第10章 Reactor中的调试

10.1 启用调试模式

10.2 在调试模式下读取堆栈跟踪信息

10.3 通过checkpoint方式进行调试

10.4 记录订阅关系下与操作流程相关的日志