前言

在上一篇文章中我們學(xué)習(xí)了LiveData的基本用法， 我們知道LiveData是一個(gè)可觀察的數(shù)據(jù)持有者，他是具有組件生命周期感知的，那么它是如何觀察組件生命周期變化的呢？

LiveData和RxJava的不同的是，LiveData并不是通知所有觀察者，它只會(huì)通知處于Active狀態(tài)的觀察者； 如果一個(gè)觀察者處于DESTROYED狀態(tài)，它將不會(huì)收到通知，這一點(diǎn)又是如何做到的？還有另外一點(diǎn)，Transformations的map方法其內(nèi)部進(jìn)行了什么操作？等等問題，會(huì)在這篇文章中給大家進(jìn)行講解

1.LiveData如何觀察組件生命周期變化

通過調(diào)用LiveData的observe方法來注冊(cè)觀察者，LiveData的observe方法如下所示。

@MainThread public void observe(@NonNull LifecycleOwner owner, @NonNull Observer observer) { assertMainThread(“observe”); //如果被觀察者的當(dāng)前的狀態(tài)是DESTROYED，就return if (owner.getLifecycle().getCurrentState() == DESTROYED) {//1 return; } LifecycleBoundObserver wrapper = new LifecycleBoundObserver(owner, observer);//2 ObserverWrapper existing = mObservers.putIfAbsent(observer, wrapper);//3 if (existing != null && !existing.isAttachedTo(owner)) { throw new IllegalArgumentException(“Cannot add the same observer” + ” with different lifecycles”); } if (existing != null) { return; } owner.getLifecycle().addObserver(wrapper);//4 }

注釋1處的owner實(shí)際上就是注冊(cè)時(shí)傳進(jìn)來來組件； 比如Activity，獲取組件當(dāng)前的狀態(tài)，如果狀態(tài)為DESTROYED，那么直接return，這說明DESTROYED狀態(tài)的組件是不允許注冊(cè)的。

注釋2處新建了一個(gè)LifecycleBoundObserver包裝類，將owner和observer傳了進(jìn)去

注釋3處將observer和LifecycleBoundObserver存儲(chǔ)到SafeIterableMapmObservers中； putIfAbsent方法和put方法有區(qū)別，如果傳入key對(duì)應(yīng)的value已經(jīng)存在，就返回存在的value，不進(jìn)行替換。如果不存在，就添加key和value，返回null。 如果等于null，在注釋4處會(huì)將LifecycleBoundObserver添加到Lifecycle中完成注冊(cè)，這樣當(dāng)我們調(diào)用LiveData的observe方法時(shí)，實(shí)際上是LiveData內(nèi)部完成了Lifecycle的觀察者的添加，這樣LiveData自然也就有了觀察組件生命周期變化的能力。

2.LiveData的observe方法回調(diào)

LifecycleBoundObservers是LiveData的內(nèi)部類，代碼如下所示

class LifecycleBoundObserver extends ObserverWrapper implements GenericLifecycleObserver { @NonNull final LifecycleOwner mOwner; LifecycleBoundObserver(@NonNull LifecycleOwner owner, Observer observer) { super(observer); mOwner = owner; } @Override boolean shouldBeActive() { return mOwner.getLifecycle().getCurrentState().isAtLeast(STARTED); } @Override public void onStateChanged(LifecycleOwner source, Lifecycle.Event event) { if (mOwner.getLifecycle().getCurrentState() == DESTROYED) { removeObserver(mObserver);//1 return; } activeStateChanged(shouldBeActive());//2 } @Override boolean isAttachedTo(LifecycleOwner owner) { return mOwner == owner; } @Override void detachObserver() { mOwner.getLifecycle().removeObserver(this); } }

LifecycleBoundObserver繼承了ObserverWrapper類； 重寫了shouldBeActive方法，用于判斷當(dāng)前傳入的組件的狀態(tài)是否是Active的，Active狀態(tài)包括STARTED和RESUMED狀態(tài)

LifecycleBoundObserver實(shí)現(xiàn)了GenericLifecycleObserver接口； 當(dāng)組件狀態(tài)發(fā)生變化時(shí)，會(huì)調(diào)用onStateChanged方法，當(dāng)組件處于DESTROYED狀態(tài)時(shí)，會(huì)調(diào)用注釋1處的removeObserver方法，來移除observer。 這樣在文章開頭的疑問就解決了，為什么一個(gè)觀察者（組件）處于DESTROYED狀態(tài)時(shí)，它將不會(huì)收到通知

接著會(huì)調(diào)用注釋2處的activeStateChange方法，代碼如下所示

private abstract class ObserverWrapper { final Observer mObserver; boolean mActive; int mLastVersion = START_VERSION; ObserverWrapper(Observer observer) { mObserver = observer; } abstract boolean shouldBeActive(); boolean isAttachedTo(LifecycleOwner owner) { return false; } void detachObserver() { } void activeStateChanged(boolean newActive) { if (newActive == mActive) { return; } mActive = newActive; boolean wasInactive = LiveData.this.mActiveCount == 0; LiveData.this.mActiveCount += mActive ? 1 : -1; if (wasInactive && mActive) { onActive(); } if (LiveData.this.mActiveCount == 0 && !mActive) { onInactive(); } if (mActive) { dispatchingValue(this);//1 } } }

activeStateChanged方法定義在抽象類ObserverWrapper中； 它是Observer的包裝類，activeStateChanged方法會(huì)根據(jù)Active狀態(tài)和處于Active狀態(tài)的組件的數(shù)量，來對(duì)onActive方法和onInactive方法回調(diào)，這兩個(gè)方法用于拓展LiveData對(duì)象。注釋1處，如果是Active狀態(tài)，會(huì)調(diào)用dispatchingValue方法，并將自身傳進(jìn)去

private void dispatchingValue(@Nullable ObserverWrapper initiator) { //正在處于分發(fā)狀態(tài)中 if (mDispatchingValue) { //分發(fā)無效 mDispatchInvalidated = true;//1 return; } mDispatchingValue = true; do { //分發(fā)有效 mDispatchInvalidated = false; if (initiator != null) { considerNotify(initiator); initiator = null; } else { for (Iterator<Map.Entry> iterator = mObservers.iteratorWithAdditions(); iterator.hasNext(); ) { considerNotify(iterator.next().getValue()); if (mDispatchInvalidated) { break; } } } } while (mDispatchInvalidated); //標(biāo)記不處于分發(fā)狀態(tài) mDispatchingValue = false; }

mDispatchingValue用于標(biāo)記當(dāng)前是否處于分發(fā)狀態(tài)中； 如果處于該狀態(tài)，則在注釋1處標(biāo)記當(dāng)前分發(fā)無效，直接return；一路調(diào)用過來，ObserverWrapper是不為null的，ObserverWrapper為null的情況第3小節(jié)會(huì)講到，無論是那種情況，都會(huì)調(diào)用considerNotify方法，代碼如下所示

private void considerNotify(ObserverWrapper observer) { if (!observer.mActive) {//1 return; } if (!observer.shouldBeActive()) { observer.activeStateChanged(false);//2 return; } if (observer.mLastVersion >= mVersion) { return; } observer.mLastVersion = mVersion; //noinspection unchecked observer.mObserver.onChanged((T) mData);//3 }

considerNotify方法中做了多次的判斷； 注釋1處，如果ObserverWrapper的mActive值不為true，就直接return；注釋2處，如果當(dāng)前observer對(duì)應(yīng)組件的狀態(tài)不是Active，就會(huì)再次調(diào)用activeStateChanged方法，并傳入false，其方法內(nèi)部會(huì)再次判斷是否執(zhí)行onActive方法和onInactive方法回調(diào)

如果判斷條件都滿足會(huì)調(diào)用Observer的onChanged方法，這個(gè)方法正是使用LiveData的observe方法的回調(diào)

3.postValue/setValue方法分析

當(dāng)調(diào)用MutableLiveData的observe方法后，還需要通過postValue/setValue方法來更新數(shù)據(jù)

… private final Runnable mPostValueRunnable = new Runnable() { @Override public void run() { Object newValue; synchronized (mDataLock) { newValue = mPendingData; mPendingData = NOT_SET; } //noinspection unchecked setValue((T) newValue);//1 } }; … protected void postValue(T value) { boolean postTask; synchronized (mDataLock) { postTask = mPendingData == NOT_SET; mPendingData = value; } if (!postTask) { return; } ArchTaskExecutor.getInstance().postToMainThread(mPostValueRunnable);//2 } @MainThread //3 protected void setValue(T value) { assertMainThread(“setValue”); mVersion++; mData = value; dispatchingValue(null); }

postValue/setValue方法都定義在LiveData中； 根據(jù)注釋1和注釋2處，可以發(fā)現(xiàn)postValue方法實(shí)際上就是將setValue方法切換到主線程調(diào)用。注釋3處說明setValue方法是運(yùn)行在主線程中的，其內(nèi)部調(diào)用了dispatchingValue方法，這個(gè)方法在第2小節(jié)介紹過，也就是dispatchingValue方法的參數(shù)ObserverWrapper為null的情況

從這里我們可以知道，無論是LiveData的observe方法還是LiveData的postValue/setValue方法都會(huì)調(diào)用dispatchingValue方法

4.Transformations.map方法分析

除了以上講的常用的方法之外，還可能會(huì)使用到Transformations.map和Transformations.switchMap方法，這里以Transformations.map為例； 這個(gè)方法用來在LiveData對(duì)象分發(fā)給觀察者之前對(duì)其中存儲(chǔ)的值進(jìn)行更改， 代碼如下所示

@MainThread public static LiveData map( @NonNull LiveData source, @NonNull final Function mapFunction) { final MediatorLiveData result = new MediatorLiveData();//1 result.addSource(source, new Observer() { @Override public void onChanged(@Nullable X x) { result.setValue(mapFunction.apply(x)); } }); return result; }

Transformations.map方法運(yùn)行在主線程，注釋1處創(chuàng)建了MediatorLiveData，緊接著調(diào)用了它的addSource方法：

*/ @MainThread public void addSource(@NonNull LiveData source, @NonNull Observer onChanged) { Source e = new Source(source, onChanged);//1 Source existing = mSources.putIfAbsent(source, e); if (existing != null && existing.mObserver != onChanged) { throw new IllegalArgumentException( “This source was already added with the different observer”); } if (existing != null) { return; } if (hasActiveObservers()) { e.plug();//2 } }

注釋1處將傳進(jìn)來的LiveData和onChanged封裝到Source類中，注釋2處調(diào)用了Source的plug方法：

private static class Source implements Observer { final LiveData mLiveData; final Observer mObserver; int mVersion = START_VERSION; Source(LiveData liveData, final Observer observer) { mLiveData = liveData; mObserver = observer; } void plug() { mLiveData.observeForever(this);//1 } void unplug() { mLiveData.removeObserver(this); } @Override public void onChanged(@Nullable V v) { if (mVersion != mLiveData.getVersion()) { mVersion = mLiveData.getVersion(); mObserver.onChanged(v);//2 } } }

注釋2處可以看到，Transformations.map方法傳入的Observer的回調(diào)在這里進(jìn)行處理； 注釋1處，Source的plug方法會(huì)調(diào)用LiveData的observeForever方法，這個(gè)和第2小節(jié)所講的內(nèi)容有什么區(qū)別呢？我們?cè)偻驴?/p>

@MainThread public void observeForever(@NonNull Observer observer) { assertMainThread(“observeForever”); AlwaysActiveObserver wrapper = new AlwaysActiveObserver(observer);//1 ObserverWrapper existing = mObservers.putIfAbsent(observer, wrapper); if (existing != null && existing instanceof LiveData.LifecycleBoundObserver) { throw new IllegalArgumentException(“Cannot add the same observer” + ” with different lifecycles”); } if (existing != null) { return; } wrapper.activeStateChanged(true); }

注釋1處用AlwaysActiveObserver來對(duì)Observer進(jìn)行包裝，緊接著調(diào)用AlwaysActiveObserver的activeStateChanged方法； 其內(nèi)部實(shí)際調(diào)用的是ObserverWrapper的activeStateChanged方法，這個(gè)在第二小節(jié)已經(jīng)做了分析，就不再贅述了。來看AlwaysActiveObserver類是如何定義的

private class AlwaysActiveObserver extends ObserverWrapper { AlwaysActiveObserver(Observer observer) { super(observer); } @Override boolean shouldBeActive() { return true; } }

AlwaysActiveObserver是LiveData的內(nèi)部類； 它繼承自O(shè)bserverWrapper，AlwaysActiveObserver是LiveData的內(nèi)部類和ObserverWrapper的區(qū)別就是，它是永遠(yuǎn)處于Active狀態(tài)的

5.LiveData關(guān)聯(lián)類

其中MutableLiveData繼承自LiveData，LifecycleOwner和Observer和LiveData有關(guān)聯(lián)的關(guān)系，ObserverWrapper是Observer的包裝類，因此它們有著關(guān)聯(lián)的關(guān)系

有需要文中完整代碼的同學(xué)： 《現(xiàn)在私信發(fā)送 “底層源碼” 即可免費(fèi)獲取》

現(xiàn)在私信發(fā)送 “筆記” 還可以獲取《更多 Android 源碼解析+學(xué)習(xí)大綱+核心筆記》

最后我想說：

對(duì)于程序員來說，要學(xué)習(xí)的知識(shí)內(nèi)容、技術(shù)有太多太多，要想不被環(huán)境淘汰就只有不斷提升自己，從來都是我們?nèi)ミm應(yīng)環(huán)境，而不是環(huán)境來適應(yīng)我們

技術(shù)是無止境的，你需要對(duì)自己提交的每一行代碼、使用的每一個(gè)工具負(fù)責(zé)，不斷挖掘其底層原理，才能使自己的技術(shù)升華到更高的層面

Android 架構(gòu)師之路還很漫長(zhǎng)，與君共勉