簡(jiǎn)介
背景
這幾年 MVP 架構(gòu)在安卓界非常流行，幾乎已經(jīng)成為主流框架，它讓業(yè)務(wù)邏輯 和 UI操作相對(duì)獨(dú)立，使得代碼結(jié)構(gòu)更清晰。
MVVM 在前端火得一塌糊涂，而在安卓這邊卻基本沒見到幾個(gè)人在用，看到介紹 MVVM 也最多是講 DataBinding 或 介紹思想的。偶爾看到幾篇提到應(yīng)用的，還是對(duì)谷歌官網(wǎng)的Architecture Components 文章的翻譯。
相信大家看別人博客或官方文檔的時(shí)候，總會(huì)碰到一些坑。要么入門教程寫得太復(fù)雜（無力吐槽，前面寫一堆原理，各種高大上的圖，然并卵，到實(shí)踐部分一筆帶過，你確定真的是入門教程嗎）。要么就是簡(jiǎn)單得就是一個(gè) hello world，然后就沒有下文了（看了想罵人）。
實(shí)在看不下去的我，決定插手你的人生。
目錄
《安卓-深入淺出MVVM教程》大致分兩部分：應(yīng)用篇、原理篇。
采用循序漸進(jìn)方式，內(nèi)容深入淺出，符合人類學(xué)習(xí)規(guī)律，希望大家用最少時(shí)間掌握 MVVM。
應(yīng)用篇：
01 Hello MVVM (快速入門)
02 Repository （數(shù)據(jù)倉庫）
03 Cache （本地緩存）
04 State Lcee （加載/空/錯(cuò)誤/內(nèi)容視圖）
05 Simple Data Source （簡(jiǎn)單的數(shù)據(jù)源）
06 Load More （加載更多）
07 DataBinding （數(shù)據(jù)與視圖綁定）
08 RxJava2
09 Dragger2
10 Abstract （抽象）
11 Demo （例子）
12-n 待定（歡迎 github 提建議）
原理篇
01 MyLiveData（最簡(jiǎn)單的LiveData）
02-n 待定（并不是解讀源碼，那樣太無聊了，打算帶你從0擼一個(gè) Architecture）
關(guān)于提問
本人水平和精力有限，如果有大佬發(fā)現(xiàn)哪里寫錯(cuò)了或有好的建議，歡迎在本教程附帶的 github倉庫 提issue。
What？為什么不在博客留言？考慮到國內(nèi)轉(zhuǎn)載基本無視版權(quán)的情況，一般來說你都不是在源出處看到這篇文章，所以留言我也一般是看不到的。
教程附帶代碼
https://github.com/ittianyu/MVVM
應(yīng)用篇放在 app 模塊下，原理篇放在 implementation 模塊下。
每一節(jié)代碼采用不同包名，相互獨(dú)立。
前言
這一節(jié)是在 04 節(jié)的基礎(chǔ)上開始的，請(qǐng)大家拷貝一份之前04的項(xiàng)目。（注意，后面幾節(jié)也是從 04 的項(xiàng)目開始，所以建議保留一份不動(dòng)）
先修要求
- 會(huì)使用 RxJava2
環(huán)境配置
加入 RxJava2 和 retrofit LiveData 的適配器庫
// RxJava2
compile 'io.reactivex.rxjava2:rxjava:2.1.5'
compile 'io.reactivex.rxjava2:rxandroid:2.0.1'
// retrofit-adapter
compile 'com.squareup.retrofit2:adapter-rxjava2:2.3.0'
// LiveData adapter rxjava2
compile "android.arch.lifecycle:reactivestreams:$rootProject.lifecycle"
retrofit-adapter-rxjava2
要適配 retrofit，只需要在 RetrofitFactory 中加入適配器
retrofit = new Retrofit.Builder()
.baseUrl(HOST)
.client(client)
.addConverterFactory(GsonConverterFactory.create())
.addCallAdapterFactory(RxJava2CallAdapterFactory.create())
.build();
retrofit api
現(xiàn)在我們把之前的 Call 改為 Observable 或者 Flowable
public interface UserApi {
@GET("/users/{username}")
Observable<User> queryUserByUsername(@Path("username") String username);
}
LiveDataReactiveStreams
官方給我們提供了 LiveData 和 RxJava 源的轉(zhuǎn)換器
實(shí)際上就是簡(jiǎn)單的兩個(gè)方法。
<T> Publisher<T> toPublisher(LifecycleOwner lifecycle, LiveData<T> liveData)
LiveData<T> fromPublisher(final Publisher<T> publisher)
有了它就可以把 Flowable<T> 轉(zhuǎn)換為 LiveData<T>。
到這里，似乎已經(jīng)講完了。
但是，你有沒有注意到，Retrofit 接口返回的是 Flowable<T>，最多能轉(zhuǎn)換成 LiveData<T>，而我們 ViewModel 需要的是 LiveData<Lcee<T>>
瞬間尷尬，怎么辦？急！在線等！
ObservableLceeLiveData
一開始我嘗試著將 LiveData<T> 轉(zhuǎn)換為 LiveData<Lcee<T>>，但很難實(shí)現(xiàn)。
然后我就點(diǎn)開了 LiveDataReactiveStreams 的代碼，發(fā)現(xiàn)竟然很簡(jiǎn)單。所以我就知道，是時(shí)候自己寫一個(gè)轉(zhuǎn)換器了。
這里我寫的是 Observable<T> 到 LiveData<Lcee<T>> 的轉(zhuǎn)換器。為什么不是 Flowable ？ 因?yàn)橛貌坏奖硥?。如果你非要用，可以參考我這個(gè)，自己寫一個(gè) Flowable 的版本。
原理其實(shí)很簡(jiǎn)單，訂閱 Observable，然后在對(duì)應(yīng)的回調(diào)方法中設(shè)置值就好
class ObservableLceeLiveData<T> extends LiveData<Lcee<T>> {
private WeakReference<Disposable> mDisposableRef;
private final Observable<T> mObservable;
private final Object mLock = new Object();
ObservableLceeLiveData(@NonNull final Observable<T> observable) {
mObservable = observable;
}
@Override
protected void onActive() {
super.onActive();
mObservable.subscribe(new Observer<T>() {
@Override
public void onSubscribe(@io.reactivex.annotations.NonNull Disposable d) {
// Don't worry about backpressure. If the stream is too noisy then
// backpressure can be handled upstream.
synchronized (mLock) {
mDisposableRef = new WeakReference<>(d);
}
postValue(Lcee.<T>loading());
}
@Override
public void onNext(@io.reactivex.annotations.NonNull T t) {
if (null == t)
postValue(Lcee.<T>empty());
else
postValue(Lcee.content(t));
}
@Override
public void onError(@io.reactivex.annotations.NonNull Throwable t) {
synchronized (mLock) {
mDisposableRef = null;
}
// Errors should be handled upstream, so propagate as a crash.
// throw new RuntimeException(t);
postValue(Lcee.<T>error(t));
}
@Override
public void onComplete() {
synchronized (mLock) {
mDisposableRef = null;
}
}
});
}
@Override
protected void onInactive() {
super.onInactive();
synchronized (mLock) {
WeakReference<Disposable> subscriptionRef = mDisposableRef;
if (subscriptionRef != null) {
Disposable subscription = subscriptionRef.get();
if (subscription != null) {
subscription.dispose();
}
mDisposableRef = null;
}
}
}
}
為了便于調(diào)用，我封裝了一個(gè)工廠類
public class LiveDataObservableAdapter {
public static <T> LiveData<Lcee<T>> fromObservableLcee(final Observable<T> observable) {
return new ObservableLceeLiveData<>(observable);
}
}
RemoteUserDataSource
因?yàn)橛辛宿D(zhuǎn)換器，下面的工作就很簡(jiǎn)單了。
之前的那么多行代碼才得到 LiveData，現(xiàn)在幾行就實(shí)現(xiàn)了。
是不是舒暢了很多。
public class RemoteUserDataSource implements UserDataSource {
private static final RemoteUserDataSource instance = new RemoteUserDataSource();
private RemoteUserDataSource() {
}
public static RemoteUserDataSource getInstance() {
return instance;
}
private UserApi userApi = RetrofitFactory.getInstance().create(UserApi.class);
@Override
public LiveData<Lcee<User>> queryUserByUsername(String username) {
return LiveDataObservableAdapter.fromObservableLcee(
userApi.queryUserByUsername(username)
.subscribeOn(Schedulers.io())
.observeOn(AndroidSchedulers.mainThread())
);
}
}
總結(jié)
接入 RxJava2，使得 RemoteUserDataSource 里面的代碼減少了，可以說大大減少了重復(fù)性代碼。
實(shí)際上外界還流傳另外一種寫法，不用 LiveData，用 RxJava 來代替，但這樣需要你在 Activity 中處理生命周期。我覺得不夠優(yōu)雅，就不講了。
