Java编程方法论 响应式RxJava与代码设计实战2025|PDF|Epub|mobi|kindle电子书版本百度云盘下载

Java编程方法论 响应式RxJava与代码设计实战PDF格式电子书版下载

注意：本站所有压缩包均有解压码： 点击下载压缩包解压工具

第1章 响应式编程总览（Reactive Programming）1

1.1 异步编程模式1

1.1.1 并发2

1.1.2 并行开发初探3

1.2 流（Stream）3

1.3 响应式流（Reactive Stream）4

1.3.1 响应式流的特性4

1.3.2 响应式开发的设计原则5

1.3.3 响应式开发的好处6

1.4 响应式开发工具库6

1.4.1 RxJava简介6

1.4.2 Reactor简介7

1.4.3 MongoDB简介8

1.4.4 响应式项目用例8

1.5 Java 9中的响应式编程10

1.5.1 响应式编程接口10

1.5.2 Java 9响应式编程入门Demo12

1.5.3 SubmissionPublisher类的源码解读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.2 subscribe的二三事33

2.2.3 create方法的设计思想36

2.2.4 各式各样的Observable40

2.2.5 Observable.cache43

2.2.6 无限流49

2.2.7 在Observable内处理错误54

2.2.8 定时控制Observable发送数据56

2.2.9 Disposable延伸59

2.2.10 ConnectableObservable解读67

2.2.11 Observable中的publish.refCount解读76

2.2.12 RxJava中的Subject解读79

2.3 小结89

第3章 RxJava 2中的操作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.3 combineLatest操作135

3.2.4 withLatestFrom操作141

3.2.5 amb操作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章 对RxJava 2的设计探索160

4.1 源的创建设计思路160

4.2 中间操作的转承162

4.3 小结166

第5章 Observable实战167

5.1 初版架子实现167

5.1.1 DAO层面的处理工作167

5.1.2 控制层的响应式实现172

5.2 基于架子实现一个汇率查询的服务175

5.3 rxjava-web-spring-boot-starter的抽取设计179

5.4 ObservableSseEmitter的设计实现188

5.5 小结196

第6章 RxJava 2中的多线程操作197

6.1 初探RxJava并发编程197

6.2 subscribeOn操作211

6.3 observeOn操作216

6.4 unsubscribeOn操作220

6.5 调度器Scheduler226

6.5.1 Schedulers.newThread方式227

6.5.2 Schedulers.io方式227

6.5.3 Schedulers.computation方式228

6.5.4 Schedulers.from（Executor executor）自定义方式228

6.6 小结230

第7章 Flowable与背压231

7.1 回顾背压231

7.2 引入Flowable233

7.3 探索Flowable.create234

7.3.1 BackpressureStrategy.BUFFER策略239

7.3.2 BackpressureStrategy.LATEST策略246

7.3.3 BackpressureStrategy.DROP策略249

7.4 将一个Observable转化为一个Flowable251

7.5 通过onBackpressureXXX操作来实现背压策略252

7.5.1 onBackPressureBuffer操作255

7.5.2 onBackpressureLatest与onBackpressureDrop操作256

7.6 Flowable.generate操作257

7.7 小结262

第8章 Flowable实战263

8.1 使用Flowable封装JDBC263

8.1.1 封装部分查询逻辑263

8.1.2 封装update逻辑265

8.2 结合Spring Web应用使用Flowable268

8.2.1 接口数据的获取269

8.2.2 响应式服务的源设计271

8.3 单元测试274

8.3.1 使用Mock Service Server进行测试274

8.3.2 使用@Mock来进行一些服务测试277

8.4 controller层的实现逻辑改造279

8.5 小结282