前言
去年無意間知道了RxJava這個(gè)東東卤妒，但一直沒時(shí)間去看看。最近字币，終于有了不少時(shí)間则披，經(jīng)過兩周的學(xué)習(xí)，對RxJava有了初步的認(rèn)識(shí)洗出。下面我會(huì)記錄一些個(gè)人認(rèn)為比較重要的知識(shí)士复，以備以后查看(并沒有深層的原理解析，僅僅在應(yīng)用層面上)翩活。
個(gè)人對RxJava的理解
RxJava是一個(gè)對數(shù)據(jù)流和事件流操作的庫阱洪，它是對數(shù)據(jù)的一種鏈?zhǔn)讲僮鳎诓僮鬟^程中菠镇，可以方便的進(jìn)行數(shù)據(jù)加工冗荸，線程切換，從而避免了復(fù)雜的嵌套利耍，縮進(jìn)蚌本，提高代碼的可讀性，可維護(hù)性堂竟。
RxJava的使用
- 簡單的例子
Observable.create(new Observable.OnSubscribe<Integer>() {
@Override
public void call(Subscriber<? super Integer> subscriber) {
subscriber.onNext(20);
}
}).map(new Func1<Integer, String>() {
@Override
public String call(Integer integer) {
return integer.toString();
}
}).subscribe(new Subscriber<String>() {
@Override
public void onCompleted() {
}
@Override
public void onError(Throwable e) {
}
@Override
public void onNext(String s) {
System.out.println(s);
}
});
Observable.create()可以用來創(chuàng)建一個(gè)被觀察者魂毁，Observable.OnSubscribe中有被訂閱時(shí)執(zhí)行的操作。
這時(shí)可以使用操作符對得到的Observable進(jìn)行一些變換出嘹。比如map()席楚，對單一的數(shù)據(jù)流進(jìn)行變換操作，如將Integer轉(zhuǎn)為String類型税稼。每進(jìn)行一次變換烦秩，就得到了一個(gè)新的Observable垮斯。
最后，使用subscribe()方法只祠，對其進(jìn)行訂閱操作兜蠕。其中Subscriber為訂閱者。
- 常用的創(chuàng)建操作符
-
create()從頭創(chuàng)建一個(gè)Observable -
just()將對象或者對象集合轉(zhuǎn)換為一個(gè)會(huì)發(fā)射這些對象的Observable
Observable.just(1, 2, 3)
.subscribe(new Action1<Integer>() {
@Override
public void call(Integer integer) {
System.out.println(integer);
}
});
-
from()將其它的對象或數(shù)據(jù)結(jié)構(gòu)轉(zhuǎn)換為Observable抛寝，比如數(shù)組
Integer[] numbers = new Integer[]{1, 2, 3};
Observable.from(numbers)
.subscribe(new Action1<Integer>() {
@Override
public void call(Integer integer) {
System.out.println(integer);
}
});
- 線程控制
在不指定線程時(shí)熊杨，RxJava遵循線程不變原則，在哪個(gè)線程中執(zhí)行subscribe()盗舰，就在哪個(gè)線程產(chǎn)生事件晶府，消費(fèi)事件。如需切換線程钻趋，需要用到Schedules(調(diào)度器)川陆。
- 常用的調(diào)度器
-
Schedulers.immediate()直接在當(dāng)前線程運(yùn)行，相當(dāng)于不指定線程蛮位。這是默認(rèn)的Scheduler较沪。 -
Schedulers.newThread()總是啟用新線程，并在新線程執(zhí)行操作失仁。 -
Schedulers.io()I/O操作(讀寫文件尸曼、讀寫數(shù)據(jù)庫、網(wǎng)絡(luò)信息交互等)所使用的Scheduler陶因。行為模式和newThread()差不多骡苞，區(qū)別在于io()的內(nèi)部實(shí)現(xiàn)是是用一個(gè)無數(shù)量上限的線程池垂蜗，可以重用空閑的線程楷扬，因此多數(shù)情況下io()比newThread()更有效率。不要把計(jì)算工作放在io()中贴见，可以避免創(chuàng)建不必要的線程烘苹。 -
Schedulers.computation()計(jì)算所使用的Scheduler。這個(gè)計(jì)算指的是CPU密集型計(jì)算片部，即不會(huì)被I/O等操作限制性能的操作镣衡，例如圖形的計(jì)算。這個(gè)Scheduler使用的固定的線程池档悠，大小為CPU核數(shù)廊鸥。不要把I/O操作放在computation()中，否則 I/O操作的等待時(shí)間會(huì)浪費(fèi)CPU辖所。 -
AndroidSchedulers.mainThread()Android專用的Schedule惰说，指定操作在Android主線程(UI線程)中運(yùn)行。
-
- 線程控制操作符
-
subscribeOn()指定subscribe()所發(fā)生的線程缘回，即Observable.OnSubscribe被激活時(shí)所處的線程吆视，或者叫做事件產(chǎn)生的線程典挑。subscribeOn()的位置放在哪里都可以，但它是只能調(diào)用一次啦吧。不過您觉，可以在Observable.doOnSubscribe()后使用subscribeOn()來指定subscribe()時(shí)，執(zhí)行doOnSubscribe()所在線程授滓。
-
Integer[] numbers = new Integer[]{1, 2, 3};
Observable.from(numbers)
.subscribeOn(Schedulers.io())
.doOnSubscribe(new Action0() {
@Override
public void call() {
System.out.println("toast " + Thread.currentThread().getName());
Toast.makeText(MainActivity.this, "hello", Toast.LENGTH_SHORT).show();
}
})
.subscribeOn(AndroidSchedulers.mainThread()) //①
.observeOn(AndroidSchedulers.mainThread())
.subscribe(new Action1<Integer>() {
@Override
public void call(Integer integer) {
System.out.println(integer + " " + Thread.currentThread().getName());
}
});
如沒有①處的subscribeOn(AndroidSchedulers.mainThread())琳水，doOnSubscribe將在當(dāng)前執(zhí)行subscribe()的線程中運(yùn)行。
- observeOn() 指定Subscriber所運(yùn)行在的線程,或者叫做事件消費(fèi)的線程般堆。這里的Subscriber可以是變換以后的炫刷，換句話說，observeOn()指定的是它之后的操作所在的線程郁妈。因此如果有多次切換線程的需求浑玛，只要在每個(gè)想要切換線程的位置調(diào)用一次observeOn()即可。
Observable.just(1, 2, 3, 4) // IO 線程噩咪，由 subscribeOn() 指定
.subscribeOn(Schedulers.io())
.observeOn(Schedulers.newThread())
.map(mapOperator) // 新線程顾彰，由 observeOn() 指定
.observeOn(Schedulers.io())
.map(mapOperator2) // IO 線程，由 observeOn() 指定
.observeOn(AndroidSchedulers.mainThread)
.subscribe(subscriber); // Android 主線程胃碾，由 observeOn() 指定
說明
這篇筆記是在看完 扔物線 大大的 給 Android 開發(fā)者的 RxJava 詳解 一文后的筆記，并引用了文章里的部分代碼和圖片仆百，僅供個(gè)人學(xué)習(xí)厕隧，還請大大不要責(zé)怪(●'?'●)。這也是我寫的第一篇文章俄周，好開心吁讨，以后會(huì)堅(jiān)持下去的。在水平提高后峦朗，也會(huì)努力寫一些原創(chuàng)文章建丧，與大家共同進(jìn)步~
