���] Java���̷���Փϵ�Ѕ���(sh��)JAVA���̷���Փ:푑�(y��ng)ʽRXJAVA�c���a�O(sh��)Ӌ(j��)��(sh��)��(zh��n)

��1�� 푑�(y��ng)ʽ���̿��[��Reactive Programming�� 1
1.1 ��������ģʽ 1
1.1.1 ���l(f��) 2
1.1.2 �����_(k��i)�l(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)�l(f��)���O(sh��)Ӌ(j��)ԭ�t 5
1.3.3 푑�(y��ng)ʽ�_(k��i)�l(f��)�ĺ�̎ 6
1.4 푑�(y��ng)ʽ�_(k��i)�l(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)ʽ�������T(m��n)Demo 12
1.5.3 SubmissionPublisher�(l��i)��Դ�a���x 18
1.5.4 푑�(y��ng)ʽ��������Spring��(sh��)��(zh��n)���� 23
1.6 �Y(ji��) 29
��2�� ��RxJava�Є�(chu��ng)��Observable 30
2.1 푑�(y��ng)ʽ�������漰���O(sh��)Ӌ(j��)ģʽ 30
2.1.1 �^����ģʽ 30
2.1.2 ������ģʽ 30
2.2 ���xreactivex.Observable 31
2.2.1 ��Flow.Publisher��Observable 33
2.2.2 subscribe�Ķ����� 33
2.2.3 create�������O(sh��)Ӌ(j��)˼�� 36
2.2.4 ��ʽ���ӵ�Observable 40
2.2.5 Observable.cache 43
2.2.6 �o(w��)���� 49
2.2.7 ��Observable��(n��i)̎���e(cu��)�` 54
2.2.8 ���r(sh��)����Observable�l(f��)�͔�(sh��)��(j��) 56
2.2.9 Disposable���� 59
2.2.10 ConnectableObservable���x 67
2.2.11 Observable�е�publish.refCount���x 76
2.2.12 RxJava�е�Subject���x 79
2.3 �Y(ji��) 89
��3�� RxJava 2�еIJ��� 90
3.1 ���IJ��� 90
3.1.1 ʹ��filter�M(j��n)�Зl���^(gu��)�V 90
3.1.2 ʹ��map�M(j��n)��Ԫ���D(zhu��n)�Q 96
3.1.3 ʹ��flatMap�M(j��n)�б�ƽ���D(zhu��n)�Q 98
3.1.4 ʹ��scan�ۼ��� 112
3.1.5 ʹ��groupBy�M(j��n)�зֽM 114
3.2 ����(g��)Observable�ĺϲ����� 122
3.2.1 ʹ��merge��(du��)Observable�M(j��n)�кϲ� 122
3.2.2 ʹ��zip�����M(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��)�V�؏�(f��)��(sh��)��(j��) 152
3.3.6 �������� 152
3.3.7 �Զ��x���� 153
3.4 �Y(ji��) 159
��4�� ��(du��)RxJava 2���O(sh��)Ӌ(j��)̽�� 160
4.1 Դ�Ą�(chu��ng)���O(sh��)Ӌ(j��)˼· 160
4.2 ���g�������D(zhu��n)�� 162
4.3 �Y(ji��) 166
��5�� Observable��(sh��)��(zh��n) 167
5.1 ������ӌ�(sh��)�F(xi��n) 167
5.1.1 DAO�����̎������ 167
5.1.2 ���ƌӵ�푑�(y��ng)ʽ��(sh��)�F(xi��n) 172
5.2 ���ڼ��ӌ�(sh��)�F(xi��n)һ��(g��)�R�ʲ�ԃ(x��n)�ķ���(w��) 175
5.3 rxjava-web-spring-boot-starter�ij�ȡ�O(sh��)Ӌ(j��) 179
5.4 ObservableSseEmitter���O(sh��)Ӌ(j��)��(sh��)�F(xi��n) 188
5.5 �Y(ji��) 196
��6�� RxJava 2�еĶྀ�̲��� 197
6.1 ��̽RxJava���l(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)�Զ��x��ʽ 228
6.6 �Y(ji��) 230
��7�� Flowable�c���� 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�D(zhu��n)����һ��(g��)Flowable 251
7.5 ͨ�^(gu��)onBackpressureXXX������(l��i)��(sh��)�F(xi��n)�������� 252
7.5.1 onBackPressureBuffer���� 255
7.5.2 onBackpressureLatest�conBackpressureDrop���� 256
7.6 Flowable.generate���� 257
7.7 �Y(ji��) 262
��8�� Flowable��(sh��)��(zh��n) 263
8.1 ʹ��Flowable���bJDBC 263
8.1.1 ���b���ֲ�ԃ(x��n)߉݋ 263
8.1.2 ���bupdate߉݋ 265
8.2 �Y(ji��)��Spring Web��(y��ng)��ʹ��Flowable 268
8.2.1 �ӿڔ�(sh��)��(j��)�ī@ȡ 269
8.2.2 푑�(y��ng)ʽ����(w��)��Դ�O(sh��)Ӌ(j��) 271
8.3 ��Ԫ�y(c��)ԇ 274
8.3.1 ʹ��Mock Service Server�M(j��n)�Мy(c��)ԇ 274
8.3.2 ʹ��@Mock��(l��i)�M(j��n)��һЩ����(w��)�y(c��)ԇ 277
8.4 controller�ӵČ�(sh��)�F(xi��n)߉݋���� 279
8.5 �Y(ji��) 282