Java编程方法论 响应式RxJava与代码设计实战

  

本书主要讲解了到底什么是响应式，从代码设计层面将JDK 9+中的Flow API、RxJava 2中关于源的创建，以及调度与背压等相关核心操作娓娓道来，并通过实战案例帮助大家更好地理解和使用相关的API。本书涉及了大量并发编程方面的技巧，以及从基础代码角度介绍了各种接口、设计模式和与之相关的基础知识点，并将它们融会贯通。这就好比我们上学的时候，老师向我们传授基础知识，然后通过习题让我们掌握这些基础知识的运用技巧。本书也遵循了这个思路，同时这也符合我写书的初衷。

  

第1章响应式编程总览（Reactive Programming）1
1.1异步编程模式1
1.1.1并发2
1.1.2并行开发初探3
1.2流（Stream）3
1.3响应式流（ReactiveStream）4
1.3.1响应式流的特性4
1.3.2响应式开发的设计原则5
1.3.3响应式开发的好处6
1.4响应式开发工具库6
1.4.1RxJava简介6
1.4.2Reactor简介7
1.4.3MongoDB简介8
1.4.4响应式项目用例8
1.5Java9中的响应式编程10
1.5.1响应式编程接口10
1.5.2Java9响应式编程入门Demo12
1.5.3SubmissionPublisher类的源码解读18
1.5.4响应式编程整合Spring实战案例23
1.6小结29
第2章在RxJava中创建Observable30
2.1响应式编程所涉及的设计模式30
2.1.1观察者模式30
2.1.2迭代器模式30
2.2解读reactivex.Observable31
2.2.1从Flow.Publisher到Observable33
2.2.2subscribe的二三事33
2.2.3create方法的设计思想36
2.2.4各式各样的Observable40
2.2.5Observable.cache43
2.2.6无限流49
2.2.7在Observable内处理错误54
2.2.8定时控制Observable发送数据56
2.2.9Disposable延伸59
2.2.10ConnectableObservable解读67
2.2.11Observable中的publish.refCount解读76
2.2.12RxJava中的Subject解读79
2.3小结89
第3章RxJava2中的操作90
3.1核心操作90
3.1.1使用filter进行条件过滤90
3.1.2使用map进行元素转换96
3.1.3使用flatMap进行扁平化转换98
3.1.4使用scan累加器112
3.1.5使用groupBy进行分组114
3.2多个Observable的合并操作122
3.2.1使用merge对Observable进行合并122
3.2.2使用zip方法进行合并124
3.2.3combineLatest操作135
3.2.4withLatestFrom操作141
3.2.5amb操作142
3.3高级操作143
3.3.1再谈累加器scan143
3.3.2聚合操作reduce144
3.3.3收集操作collect146
3.3.4使用distinct去重148
3.3.5使用distinctUntilChanged过滤重复数据152
3.3.6其他操作152
3.3.7自定义操作153
3.4小结159
第4章对RxJava2的设计探索160
4.1源的创建设计思路160
4.2中间操作的转承162
4.3小结166
第5章Observable实战167
5.1初版架子实现167
5.1.1DAO层面的处理工作167
5.1.2控制层的响应式实现172
5.2基于架子实现一个汇率查询的服务175
5.3rxjava-web-spring-boot-starter的抽取设计179
5.4ObservableSseEmitter的设计实现188
5.5小结196
第6章RxJava2中的多线程操作197
6.1初探RxJava并发编程197
6.2subscribeOn操作211
6.3observeOn操作216
6.4unsubscribeOn操作220
6.5调度器Scheduler226
6.5.1Schedulers.newThread方式227
6.5.2Schedulers.io方式227
6.5.3Schedulers.computation方式228
6.5.4Schedulers.from(Executorexecutor)自定义方式228
6.6小结230
第7章Flowable与背压231
7.1回顾背压231
7.2引入Flowable233
7.3探索Flowable.create234
7.3.1BackpressureStrategy.BUFFER策略239
7.3.2BackpressureStrategy.LATEST策略246
7.3.3BackpressureStrategy.DROP策略249
7.4将一个Observable转化为一个Flowable251
7.5通过onBackpressureXXX操作来实现背压策略252
7.5.1onBackPressureBuffer操作255
7.5.2onBackpressureLatest与onBackpressureDrop操作256
7.6Flowable.generate操作257
7.7小结262
第8章Flowable实战263
8.1使用Flowable封装JDBC263
8.1.1封装部分查询逻辑263
8.1.2封装update逻辑265
8.2结合SpringWeb应用使用Flowable268
8.2.1接口数据的获取269
8.2.2响应式服务的源设计271
8.3单元测试274
8.3.1使用MockServiceServer进行测试274
8.3.2使用@Mock来进行一些服务测试277
8.4controller层的实现逻辑改造279
8.5小结282