123,123

內(nèi)容簡(jiǎn)介

　　本書(shū)對(duì)RxJava 2的源碼進(jìn)行了深入解讀，讓讀者可以從設(shè)計(jì)到實(shí)現(xiàn)細(xì)節(jié)上全面了解它，從而達(dá)到不僅會(huì)用而且可以進(jìn)行RxJava 2源碼庫(kù)組件級(jí)別的拓展的程度。本書(shū)的目的不僅是介紹RxJava 2，而且更希望通過(guò)一個(gè)成熟、優(yōu)秀的代碼庫(kù)來(lái)向讀者展示閱讀源碼的思路及編程方面的技巧，其中包含了并發(fā)編程的實(shí)戰(zhàn)技巧、數(shù)據(jù)結(jié)構(gòu)的設(shè)計(jì)方法、設(shè)計(jì)模式的使用方法、函數(shù)式編程的各種技巧等，希望讀者可以深入思考并獲得屬于自己的一套編程方法論。這也是“Java編程方法論系列叢書(shū)”的初衷，授之以魚(yú)不如授之以漁。

作者簡(jiǎn)介

　　知秋，本名李飛，長(zhǎng)期致力于基礎(chǔ)代碼庫(kù)的研發(fā)工作，通過(guò)博客與視頻平臺(tái)bilibili，結(jié)合自己的經(jīng)驗(yàn)做了大量源碼解讀的分享。對(duì)JDK、Spring、RxJava、Spring Reactor、Netty、Reactor-Netty等有很深刻的研究和獨(dú)到的見(jiàn)解，并以此打造“Java編程方法論系列叢書(shū)”?；陂_(kāi)源精神，與志同道合的伙伴們一起創(chuàng)建了simviso開(kāi)源分享團(tuán)隊(duì)，為開(kāi)源社區(qū)服務(wù)。

圖書(shū)目錄

第1章響應(yīng)式編程總覽（Reactive Programming） 1
1.1 異步編程模式 1
1.1.1 并發(fā) 2
1.1.2 并行開(kāi)發(fā)初探 3
1.2 流（Stream） 3
1.3 響應(yīng)式流（Reactive Stream） 4
1.3.1 響應(yīng)式流的特性 4
1.3.2 響應(yīng)式開(kāi)發(fā)的設(shè)計(jì)原則 5
1.3.3 響應(yīng)式開(kāi)發(fā)的好處 6
1.4 響應(yīng)式開(kāi)發(fā)工具庫(kù) 6
1.4.1 RxJava簡(jiǎn)介 6
1.4.2 Reactor簡(jiǎn)介 7
1.4.3 MongoDB簡(jiǎn)介 8
1.4.4 響應(yīng)式項(xiàng)目用例 8
1.5 Java 9中的響應(yīng)式編程 10
1.5.1 響應(yīng)式編程接口 10
1.5.2 Java 9響應(yīng)式編程入門(mén)Demo 12
1.5.3 SubmissionPublisher類的源碼解讀 18
1.5.4 響應(yīng)式編程整合Spring實(shí)戰(zhàn)案例 23
1.6 小結(jié) 29
第2章在RxJava中創(chuàng)建Observable 30
2.1 響應(yīng)式編程所涉及的設(shè)計(jì)模式 30
2.1.1 觀察者模式 30
2.1.2 迭代器模式 30
2.2 解讀reactivex.Observable 31
2.2.1 從Flow.Publisher到Observable 33
2.2.2 subscribe的二三事 33
2.2.3 create方法的設(shè)計(jì)思想 36
2.2.4 各式各樣的Observable 40
2.2.5 Observable.cache 43
2.2.6 無(wú)限流 49
2.2.7 在Observable內(nèi)處理錯(cuò)誤 54
2.2.8 定時(shí)控制Observable發(fā)送數(shù)據(jù) 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 小結(jié) 89
第3章 RxJava 2中的操作 90
3.1 核心操作 90
3.1.1 使用filter進(jìn)行條件過(guò)濾 90
3.1.2 使用map進(jìn)行元素轉(zhuǎn)換 96
3.1.3 使用flatMap進(jìn)行扁平化轉(zhuǎn)換 98
3.1.4 使用scan累加器 112
3.1.5 使用groupBy進(jìn)行分組 114
3.2 多個(gè)Observable的合并操作 122
3.2.1 使用merge對(duì)Observable進(jìn)行合并 122
3.2.2 使用zip方法進(jìn)行合并 124
3.2.3 combineLatest操作 135
3.2.4 withLatestFrom操作 141
3.2.5 amb操作 142
3.3 高級(jí)操作 143
3.3.1 再談累加器scan 143
3.3.2 聚合操作reduce 144
3.3.3 收集操作collect 146
3.3.4 使用distinct去重 148
3.3.5 使用distinctUntilChanged過(guò)濾重復(fù)數(shù)據(jù) 152
3.3.6 其他操作 152
3.3.7 自定義操作 153
3.4 小結(jié) 159
第4章對(duì)RxJava 2的設(shè)計(jì)探索 160
4.1 源的創(chuàng)建設(shè)計(jì)思路 160
4.2 中間操作的轉(zhuǎn)承 162
4.3 小結(jié) 166
第5章 Observable實(shí)戰(zhàn) 167
5.1 初版架子實(shí)現(xiàn) 167
5.1.1 DAO層面的處理工作 167
5.1.2 控制層的響應(yīng)式實(shí)現(xiàn) 172
5.2 基于架子實(shí)現(xiàn)一個(gè)匯率查詢的服務(wù) 175
5.3 rxjava-web-spring-boot-starter的抽取設(shè)計(jì) 179
5.4 ObservableSseEmitter的設(shè)計(jì)實(shí)現(xiàn) 188
5.5 小結(jié) 196
第6章 RxJava 2中的多線程操作 197
6.1 初探RxJava并發(fā)編程 197
6.2 subscribeOn操作 211
6.3 observeOn操作 216
6.4 unsubscribeOn操作 220
6.5 調(diào)度器Scheduler 226
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 小結(jié) 230
第7章 Flowable與背壓 231
7.1 回顧背壓 231
7.2 引入Flowable 233
7.3 探索Flowable.create 234
7.3.1 BackpressureStrategy.BUFFER策略 239
7.3.2 BackpressureStrategy.LATEST策略 246
7.3.3 BackpressureStrategy.DROP策略 249
7.4 將一個(gè)Observable轉(zhuǎn)化為一個(gè)Flowable 251
7.5 通過(guò)onBackpressureXXX操作來(lái)實(shí)現(xiàn)背壓策略 252
7.5.1 onBackPressureBuffer操作 255
7.5.2 onBackpressureLatest與onBackpressureDrop操作 256
7.6 Flowable.generate操作 257
7.7 小結(jié) 262
第8章 Flowable實(shí)戰(zhàn) 263
8.1 使用Flowable封裝JDBC 263
8.1.1 封裝部分查詢邏輯 263
8.1.2 封裝update邏輯 265
8.2 結(jié)合Spring Web應(yīng)用使用Flowable 268
8.2.1 接口數(shù)據(jù)的獲取 269
8.2.2 響應(yīng)式服務(wù)的源設(shè)計(jì) 271
8.3 單元測(cè)試 274
8.3.1 使用Mock Service Server進(jìn)行測(cè)試 274
8.3.2 使用@Mock來(lái)進(jìn)行一些服務(wù)測(cè)試 277
8.4 controller層的實(shí)現(xiàn)邏輯改造 279
8.5 小結(jié) 282