歡迎訪問微涼一季
本文翻譯來自-->Why should we use RxJava on Android
感覺RxJava最近風(fēng)生水起杉辙，不學(xué)習(xí)一下都不好意思了怕篷，灑家也是初學(xué)RxJava啄踊，也是感覺代碼好像更復(fù)雜更難懂了遭殉，看了一篇外文感同身受，簡單翻譯一下避凝。本文簡單介紹使用RxJava優(yōu)勢所在舞萄。但可能需要有一點RxJava基礎(chǔ)眨补，推薦先看一下拋物線的那篇經(jīng)典的匠心寫作管削。
-----華麗分割線，譯文開始---------
Reactive Extensions (Rx) 是一系列接口和方法撑螺，為開發(fā)者提供了一種易懂且迅速簡單易維護(hù)的方法含思。RxJava就是干這事兒的，提供一系列tools來幫你寫出簡潔的代碼。
老實說含潘，一開始我認(rèn)為RxJava 寫的代碼理解起來很困難饲做，并且引入一個庫，單單就是為了用用這種新式的api遏弱，這困擾到了我盆均。后來，我懂了漱逸。以傳統(tǒng)的編碼方式泪姨，隨著app的發(fā)展，我需要重構(gòu)代碼饰抒、一遍一遍的重復(fù)樣板代碼肮砾，以滿足用戶不斷變更的新需求，這讓我苦不堪言袋坑。
我做的大量工作仗处，其實是改寫相關(guān)方法和接口，就是因為需求的變更（這是開發(fā)與產(chǎn)品間那些血案的原罪）或者需要改變展示的信息亦或是需要改變處理信息數(shù)據(jù)..這很抓狂枣宫。另外婆誓，這種代碼讓其他來維護(hù)的人來理解，通常是很耗時的也颤。
舉個栗子:我們需要從數(shù)據(jù)庫獲取一組用戶的鏈表數(shù)據(jù)旷档，并展示出來。我們可以用AsyncTask后臺查詢數(shù)據(jù)庫歇拆，獲得的結(jié)果給Ui的適配器展示出來鞋屈。簡單示例代碼：
public class SampleTask extends AsyncTask<Void,Void,List<Users>> {
private final SampleAdapter mAdapter;
public SampleTask(SampleAdapter sampleAdapter) {
mAdapter = sampleAdapater;
}
@Override
protected List<Users> doInBackground(Void... voids) {
//fetch there results from the database and return them to the onPostExecute
List<Users> users = getUsersFromDatabase();
return users;
}
@Override
protected void onPostExecute(List<Users> users) {
super.onPostExecute(products);
// Checking if there are users on the database
if(users == null) {
//No users, presenting a view saying there are no users
showEmptyUsersMessageView();
return;
}
for(User user : users){
mAdapter.add(user);
}
mAdapter.notifyDataSetChanged();
}
}
現(xiàn)在有個新需求，要求只顯示非guest的user故觅，我們處理的方法是厂庇，在添加到adapter前加個條件判斷是不是guset，或者改變數(shù)據(jù)庫查詢的條件输吏。更有甚者权旷，你又被要求從數(shù)據(jù)庫中獲取另外的其他信息，跟user一并在這個adapter中顯示出來呢贯溅？
這就是我們?yōu)槭裁匆肦xJava了拄氯，把我們從這個泥潭中拉出來。換個姿勢它浅，我們Rx代碼是這樣子（假設(shè)您已學(xué)習(xí)過Rx基礎(chǔ)用法）：
public Observable<List<User>> fetchUsersFromDatabase() {
return Observable.create(new Observable.OnSubscribe<List<User>(){
@Override
public void call(Subscriber<? super List<User>> subscriber){
// Fetch information from database
subscriber.onNext(getUserList());
subscriber.onCompleted();
}
});
}
像這樣被調(diào)用：
fetchUsersFromDatabase()
.subscribeOn(Schedulers.io())
//will process everything in a new thread
.observeOn(AndroidSchedulers.mainThread())
//will listen the results on the main thread
.subscribe(new Subscriber<List<User>>() {
@Override
public void onCompleted() {
}
@Override
public void onError(Throwable e) {
}
@Override
public void onNext(List<User> users) {
//Do whatever you want with each user
}
});
開始改需求了哈
怎么不顯示guests呢译柏，RxJava分分鐘過濾掉這種不速之客：
fetchUsersFromDatabase()
.filter(new Func1<User, Boolean>() {
@Override
public Boolean call(User user) {
//only return the users which are not guests
return !user.isGuest();
}
})
.subscribeOn(Schedulers.io())
.observeOn(AndroidSchedulers.mainThread())
.subscribe(new Subscriber<User>() {
@Override
public void onCompleted() {
}
@Override
public void onError(Throwable e) {
/*Check if there was any error while retrieving from database*/
}
@Override
public void onNext(User user) {
//Do whatever you want with each user
}
}
);
傳統(tǒng)的方式，即便是個簡單的變更姐霍，為了保持優(yōu)雅的接口化編程鄙麦，我們也得創(chuàng)建新接口典唇，重構(gòu)代碼來實現(xiàn)過濾。但是使用RxJava讓這一切變得優(yōu)雅了胯府，我們只需要一個被觀察者用來獲取所有的信息介衔，讓后你就可以盡情的用這些方法來過濾獲取你想要的數(shù)據(jù)。
可能你又會說了骂因，ok炎咖，這是很好很易讀的結(jié)構(gòu)，但是這似乎使代碼量變多了呢寒波。well you are right塘装，但是這就是Retrolambda閃耀的時候了，這個庫為我們兼容了以使用java8 lambda表達(dá)式影所，方法引用等等蹦肴。
幫我們簡化代碼如下：
fetchUsersFromDatabase()
.subscribeOn(Schedulers.io())
.observeOn(AndroidSchedulers.mainThread())
.subscribe(value -> {
//Do whatever with the value
},error -> {
//do something with in case of error
}
);
這個問題完美搞定，然后你又開始問了猴娩，我需要增加另外的查詢結(jié)果和user一同顯示在這個adapter中怎么破阴幌。這真不是事兒：
fetchUsersFromDatabase()
.zipWith(fetchSomethingElseFromDatabase(), (users, somethingElse) -> {
/*here combine users and something else into a new object*/
})
.subscribe( o -> {
/*use the combine object from users and something else to fill the adapter */
});
如上，我們可以輕松組合數(shù)據(jù)庫查出來的其他數(shù)據(jù)和users給一個adapter一同顯示卷中。是不是更易維護(hù)矛双，代碼少，易讀蟆豫，清晰议忽？
如果要更深入的學(xué)習(xí)RXJava可以看下面這篇文章，我看后受益匪淺十减。
Party tricks with RxJava, RxAndroid & Retrolambda
另外栈幸，這篇教程 tutorial 也幫我在RxJava路上進(jìn)階了很多。
