前言
在過(guò)去的一年里徒役，出現(xiàn)大量?jī)?yōu)秀的框架捏境，火的不行于游，我也是從網(wǎng)上了解到Rx，特意搜索了相關(guān)文章垫言，我也是通過(guò)它初步了解了Rxjava, 通過(guò)使用也慢慢領(lǐng)會(huì)到了其獨(dú)特的魅力贰剥。
先談?wù)勎覍?duì)Rxjava的認(rèn)識(shí)
首先說(shuō)一下使用的感受：作為一只程序猿，最煩的就是那無(wú)窮無(wú)盡的for循環(huán)筷频，以及那看起來(lái)都有點(diǎn)喪心病狂的 格式縮進(jìn)鸠澈，而如果使用Rxjava來(lái)進(jìn)行數(shù)據(jù)處理的話，完全沒(méi)有這方面的問(wèn)題截驮，你只要依次實(shí)現(xiàn)每一個(gè)方法就可以迅速獲得同樣的效果笑陈。
這里借鑒一下 給 Android 開(kāi)發(fā)者的 RxJava 詳解一文中的例子，來(lái)給大家說(shuō)明一下：
假設(shè)有這樣一個(gè)需求：界面上有一個(gè)自定義的視圖 imageCollectorView 葵袭，它的作用是顯示多張圖片涵妥，并能使用 addImage(Bitmap) 方法來(lái)任意增加顯示的圖片。現(xiàn)在需要程序?qū)⒁粋€(gè)給出的目錄數(shù)組 File[] folders 中每個(gè)目錄下的 png 圖片都加載出來(lái)并顯示在 imageCollectorView 中坡锡。需要注意的是蓬网，由于讀取圖片的這一過(guò)程較為耗時(shí)，需要放在后臺(tái)執(zhí)行鹉勒，而圖片的顯示則必須在 UI 線程執(zhí)行帆锋。常用的實(shí)現(xiàn)方式有多種，我這里貼出其中一種：
new Thread() {
@Override
public void run() {
super.run();
for (File folder : folders) {
File[] files = folder.listFiles();
for (File file : files) {
if (file.getName().endsWith(".png")) {
final Bitmap bitmap = getBitmapFromFile(file);
getActivity().runOnUiThread(new Runnable() {
@Override
public void run() {
imageCollectorView.addImage(bitmap);
}
});
}
}
}
}
}.start();
而如果使用 RxJava 禽额，實(shí)現(xiàn)方式是這樣的：
Observable.from(folders)
.flatMap(new Func1<File, Observable<File>>() {
@Override
public Observable<File> call(File file) {
return Observable.from(file.listFiles());
}
})
.filter(new Func1<File, Boolean>() {
@Override
public Boolean call(File file) {
return file.getName().endsWith(".png");
}
})
.map(new Func1<File, Bitmap>() {
@Override
public Bitmap call(File file) {
return getBitmapFromFile(file);
}
})
.subscribeOn(Schedulers.io())
.observeOn(AndroidSchedulers.mainThread())
.subscribe(new Action1<Bitmap>() {
@Override
public void call(Bitmap bitmap) {
imageCollectorView.addImage(bitmap);
}
});
這樣锯厢，大家就可以理解皮官， RxJava 的優(yōu)秀在于其可讀性，只要熟悉編寫(xiě)習(xí)慣后不管過(guò)多久再來(lái)看這部分代碼实辑，仍然可以很快的理解捺氢，而上面的各種for循環(huán)寫(xiě)出來(lái)的代碼，并不具備這樣的屬性剪撬。
下面就來(lái)簡(jiǎn)單的講一下Rxjava的使用
1.引入RxJava
RxJava 支持Java 6或者更新的版本,引入前請(qǐng)更新到Java 6或以上版本摄乒。
compile 'io.reactivex:rxandroid:1.2.1'
compile 'io.reactivex:rxjava:1.1.8'
RxAndroid 是 Android 開(kāi)發(fā)中使用 RxJava 必備元素，雖然里面只是提供了簡(jiǎn)單的兩個(gè)功能残黑。 AndroidSchedulers.mainThread()
和 AndroidSchedulers.handlerThread(handler) 馍佑，但這確是 Android 開(kāi)發(fā)中最核心的功能之一。
2.Rxjava基本概念
下面來(lái)談?wù)凴xjava幾個(gè)基本概念的介紹:
- Observer（觀察者）
- Observable （被觀察者）
- subscribe(* observer *) （訂閱）
Observer（觀察者）
Observer 提供一組不同的事件梨水，并對(duì)各個(gè)事件進(jìn)行實(shí)現(xiàn)挤茄，不關(guān)心事件何時(shí)發(fā)生，只決定事件觸發(fā)的時(shí)候?qū)⒂性鯓拥男袨椤?/p>
本質(zhì)是一個(gè)接口冰木，提供了三個(gè)方法穷劈，需要實(shí)現(xiàn)。
onNext(Object o): 事件隊(duì)列中踊沸，RxJava 每完成一次事件都會(huì)通過(guò)調(diào)用onNext(Object o), 對(duì)結(jié)果進(jìn)行相應(yīng)的操作歇终。
onCompleted(): 當(dāng)整個(gè)事件隊(duì)列完成所有的數(shù)據(jù)處理時(shí)，其將被調(diào)用逼龟。
onError(): 在整個(gè)事件隊(duì)列中评凝，只要有一個(gè)事件處理出現(xiàn)問(wèn)題，其將被調(diào)用腺律，并放棄對(duì)剩下事件的處理奕短。
Subscriber<String> subscriber = new Subscriber<String>() {
@Override
public void onNext(String s) {
Log.d(tag, "Item: " + s);
}
@Override
public void onCompleted() {
Log.d(tag, "Completed!");
}
@Override
public void onError(Throwable e) {
Log.d(tag, "Error!");
}
};
Observable（被觀察者）
Observable 提供事件觸發(fā)的場(chǎng)景，即決定什么時(shí)候觸發(fā)事件和此時(shí)該觸發(fā)什么事件匀钧，不關(guān)心事件的具體實(shí)現(xiàn)翎碑。
其提供了多種初始化，創(chuàng)建對(duì)象的方法：
- create()
//使用Observable.create()創(chuàng)建被觀察者
Observable observable1 = Observable.create(new Observable.OnSubscribe<String>() {
@Override
public void call(Subscriber<? super String> subscriber) {
subscriber.onNext("Hello");
subscriber.onNext("Wrold");
subscriber.onCompleted();
}
});
- just(T...)
Observable observable2 = Observable.just("Hello", "World");
- from(T[])
String [] words = {"Hello", "World"};
Observable observable3 = Observable.from(words);
或者
List<String> list = new ArrayList<String>();
list.add("Hellow");
list.add("Wrold");
Observable observable4 = Observable.from(list);
subscribe(* observer *) （訂閱）
創(chuàng)建Observable和Observer之后之斯，通過(guò)subscribe()方法將它們結(jié)合起來(lái)日杈。
小結(jié)
對(duì)Rxjava作了一個(gè)簡(jiǎn)單的介紹，從基礎(chǔ)知識(shí)開(kāi)始講起可能比較枯燥佑刷，沒(méi)有多少實(shí)踐莉擒，但是基礎(chǔ)的重要性不言而喻，尤其對(duì)于Rxjava來(lái)說(shuō)瘫絮，其代碼的編寫(xiě)習(xí)慣與我們平常不太一樣涨冀，其鏈?zhǔn)降娘L(fēng)格更加簡(jiǎn)潔，當(dāng)你慢慢習(xí)慣麦萤，你將領(lǐng)會(huì)其獨(dú)特的魅力鹿鳖。
