Jetpack之Lifecyle原理分析

目录

Jetpack之Lifecyle原理分析
Jetpack之LiveData原理分析
Jetpack之ViewMdel原理分析
Jetpack之LiveData+ViewMde+Flow+Retrofit架构设计

介绍

  • Lifecycle 是一个类它唯一的实现类是LifecycleRegistry，Lifecycle用于存储和有关组件（如 Activity 或 Fragment）的生命周期状态的信息，并允许其他对象观察此状态。

  • 生命周期感知型组件可执行操作来响应另一个组件（如 Activity 和 Fragment）的生命周期状态的变化。这些组件有助于您写出更有条理且往往更精简的代码，这样的代码更易于维护。

  • 一种常见的模式是在 Activity 和 Fragment 的生命周期方法中实现依赖组件的操作。但是，这种模式会导致代码条理性很差而且会扩散错误。通过使用生命周期感知型组件，您可以将依赖组件的代码从生命周期方法移入组件本身中。

  • 当然你是可以让任何对象能够让Lifecycle感知它的生命周期，比如：Dialog它本身是不具有让Lifecycle感知它的生命周期，但是我们可以通过自定义让Dialog拥有这种能力的，后面我们将结合源码的形式去讲解这种方式，也许你会对Lifecycle的原理有大概的了解。

  • androidx.lifecycle 包提供了可用于构建生命周期感知型组件的类和接口 - 这些组件可以根据 Activity 或 Fragment 的当前生命周期状态自动调整其行为。

  • 实际上 Lifecyle是一个接口他有一个唯一实现类LifecycleRegistry，LifecycleRegistry封装了LifecycleOwner和LifecycleObserver以及处理分发生命周期。

简单使用

任何类都可以通过向其方法添加注解来监控组件的生命周期状态。然后，您可以通过调用 Lifecycle 类的 addObserver() 方法并传递观察者的实例来添加观察者，其实最终是注册到LifecycleRegistry生命周期表中

class MyObserver : LifecycleObserver {

    @OnLifecycleEvent(Lifecycle.Event.ON_RESUME)
    fun onResume() {}

    @OnLifecycleEvent(Lifecycle.Event.ON_PAUSE)
    fun onPauser() { }
}
myLifecycleOwner.getLifecycle().addObserver(MyObserver())

在上面的示例中，myLifecycleOwner 对象实现了 LifecycleOwner 接口，我们将在接下来的部分中对该接口进行说明。

LifecycleOwner

  • LifecycleOwner 是单一方法接口，表示类具有 Lifecycle。它具有一个方法（即 getLifecycle()），该方法必须由代表或具有一生命周期的类实现，如Activity和Fragment，LifecycleOwner翻译过来就是生命周期持有者或者提供者，所以LifecycleOwner代表的是一个实现LifecycleOwner的类具有生命周期，但是仅仅实现了LifecycleOwner是不够的，因为你的把LifecycleOwner注册到LifecycleRegistry，LifecycleRegistry翻译过来就是生命周期注册表，需要将LifecycleOwner注册到LifecycleRegistry中有该类对生命周期进行分发生命周期事件。如果你想尝试管理整个应用进程的生命周期，请参阅 ProcessLifecycleOwner。

  • 此接口从各个类（如 Fragment 和 AppCompatActivity）抽象化 Lifecycle 的所有权，并允许编写与这些类搭配使用的组件。任何自定义应用类均可实现 LifecycleOwner 接口。

  • 实现 LifecycleObserver的组件可与实现LifecycleOwner 的组件无缝协同工作，因为LifecycleOwner可以提供生命周期，而观察者可以注册以观察生命周期。

实现自定义 LifecycleOwner

Fragment 和 Activity 已实现 LifecycleOwner 接口。
如果我们有一个自定义类并希望使其成为 LifecycleOwner，您可以使用 LifecycleRegistry 类，但需要将事件转发到该类，比如前面说到让Dialog有用让Lifecucle感知它的生命周期，如以下代码示例中所示：。

class DialogLifeCycle(context: Context, themeResId: Int) : Dialog(context, themeResId),LifecycleOwner {
private val mDispatcher by lazy { LifecycleDispatcher(this) }
override fun getLifecycle(): Lifecycle {
    return mDispatcher.getLifecycle()
}

override fun onCreate(savedInstanceState: Bundle?) {
    mDispatcher.onDialogPreSuperOnCreate()
    super.onCreate(savedInstanceState)
}

override fun onStart() {
    mDispatcher.onDialogPreSuperOnStart()
    mDispatcher.onDialogPreSuperResume()
    super.onStart()
}

override fun onStop() {
    mDispatcher.onDialogPreSuperPause()
    mDispatcher.onDialogPreSuperOnStop()
    mDispatcher.onDialogPreSuperOnDestroy()
    super.onStop()
}

}

########LifecycleOwner帮助类

class LifecycleDispatcher(provider: LifecycleOwner) {
    private var mRegistry: LifecycleRegistry = LifecycleRegistry(provider)
    private var mHandler: Handler = Handler()
    private lateinit var mLastDispatchRunnable: DispatchRunnable

private fun postDispatchRunnable(event: Lifecycle.Event) {
    if (this::mLastDispatchRunnable.isInitialized) {
        mLastDispatchRunnable.run()
    }
    mLastDispatchRunnable = DispatchRunnable(mRegistry, event)
    mHandler.postAtFrontOfQueue(mLastDispatchRunnable)
}


fun onDialogPreSuperOnCreate() {
    postDispatchRunnable(Lifecycle.Event.ON_CREATE)
    onDialogPreSuperAny()
}


fun onDialogPreSuperOnStart() {
    postDispatchRunnable(Lifecycle.Event.ON_START)
    onDialogPreSuperAny()
}


fun onDialogPreSuperResume() {
    postDispatchRunnable(Lifecycle.Event.ON_RESUME)
    onDialogPreSuperAny()
}


fun onDialogPreSuperPause() {
    postDispatchRunnable(Lifecycle.Event.ON_PAUSE)
    onDialogPreSuperAny()
}

fun onDialogPreSuperOnDestroy() {
    postDispatchRunnable(Lifecycle.Event.ON_DESTROY)
    onDialogPreSuperAny()
}

fun onDialogPreSuperOnStop() {
    postDispatchRunnable(Lifecycle.Event.ON_STOP)
    onDialogPreSuperAny()
}

fun onDialogPreSuperAny() {
    postDispatchRunnable(Lifecycle.Event.ON_ANY)
}


fun getLifecycle(): Lifecycle {
    return mRegistry
}


class DispatchRunnable(
    private val mRegistry: LifecycleRegistry,
    private val mEvent: Lifecycle.Event,
    private var mWasExecuted: Boolean = false
) : Runnable {
    override fun run() {
        if (!mWasExecuted) {
            mRegistry.handleLifecycleEvent(mEvent)
            mWasExecuted = true
        }
    }
}
}

然后我们通过 lifecycle.addObserver(MyLifeCycle())方法将生命周期观察这注册给lifecycle也就是LifecycleRegistry，这样我们在MyLifeCycle就能感知Dialog的生命周期变化。

源码分析原理

在lifecycle.addObserver(MyLifeCycle())将生命周期观察这注册给lifecycle，那我们从这里开始：

#######MyLifeCycle

class MyLifecycleObserver  : LifecycleObserver {
@OnLifecycleEvent(Lifecycle.Event.ON_CREATE)
fun onCreate() {
    LogUtil.error("MyLifeCycle onCreate")
    }
}

我们定义的了MyLifecycleObserver 并让他实现LifecycleObserver ，最后编译期会生成代码，如下：

public class MyLifecycleObserver_LifecycleAdapter implements GeneratedAdapter {
final MyLifeCycle mReceiver;

MyLifeCycle_LifecycleAdapter(MyLifeCycle receiver) {
    this.mReceiver = receiver;
}

public void callMethods(LifecycleOwner owner, Event event, boolean onAny, MethodCallsLogger logger) {
    boolean hasLogger = logger != null;
    if (!onAny) {
        if (event == Event.ON_CREATE) {
            if (!hasLogger || logger.approveCall("onCreate", 1)) {
                this.mReceiver.onCreate();
            }

        }
    }
}
}

在生成MyLifecycleObserver_LifecycleAdapter 类的callMethods方法中会调用我们的MyLifecycle的方法 this.mReceiver.onCreate()，那么callMethods方法在哪触发呢？我么看看LifecycleRegistry .addObserver方法:

@Override
public void addObserver(@NonNull LifecycleObserver observer) {

    //1
    ObserverWithState statefulObserver = new ObserverWithState(observer, initialState);
 //2
    ObserverWithState previous = mObserverMap.putIfAbsent(observer, statefulObserver);

   //省略...........................
}

上面代码主要是将observer保存在mObserverMap中，并计算当前的状态。接下我们看看触发生命周期的方法，首先我们定义了LifecycleRegistry 并使用 LifecycleRegistry .handleLifecycleEvent(mEvent)方法对生命周期的事件进行分发，代码如下：

public void handleLifecycleEvent(@NonNull Lifecycle.Event event) {
    State next = getStateAfter(event);
    moveToState(next);
}

方法很简单，我们主要看moveToState，意思是改变状态，代码如下：

 private void moveToState(State next) {
    if (mState == next) {
        return;
    }
    mState = next;
    if (mHandlingEvent || mAddingObserverCounter != 0) {
        mNewEventOccurred = true;
        // we will figure out what to do on upper level.
        return;
    }
    mHandlingEvent = true;
    sync();
    mHandlingEvent = false;
}

这个方法比较简单，主要是对状态进行判断，接着我么来看看sync()方法，比较重要，代码如下：

private void sync() {
    LifecycleOwner lifecycleOwner = mLifecycleOwner.get();
    if (lifecycleOwner == null) {
        throw new IllegalStateException("LifecycleOwner of this LifecycleRegistry is already"
                + "garbage collected. It is too late to change lifecycle state.");
    }
    while (!isSynced()) {
        mNewEventOccurred = false;
        // no need to check eldest for nullability, because isSynced does it for us.
        if (mState.compareTo(mObserverMap.eldest().getValue().mState) < 0) {
            backwardPass(lifecycleOwner);//1
        }
        Entry<LifecycleObserver, ObserverWithState> newest = mObserverMap.newest();
        if (!mNewEventOccurred && newest != null
                && mState.compareTo(newest.getValue().mState) > 0) {
            forwardPass(lifecycleOwner);//2
        }
    }
    mNewEventOccurred = false;
}

在sync方法中我们主要看backwardPass方法的实现：

 private void backwardPass(LifecycleOwner lifecycleOwner) {
    Iterator<Entry<LifecycleObserver, ObserverWithState>> descendingIterator =
            mObserverMap.descendingIterator();
    while (descendingIterator.hasNext() && !mNewEventOccurred) {
        Entry<LifecycleObserver, ObserverWithState> entry = descendingIterator.next();
        ObserverWithState observer = entry.getValue();
        while ((observer.mState.compareTo(mState) > 0 && !mNewEventOccurred
                && mObserverMap.contains(entry.getKey()))) {
            Event event = downEvent(observer.mState);
            pushParentState(getStateAfter(event));
            observer.dispatchEvent(lifecycleOwner, event);//1
            popParentState();
        }
    }
}

在我注释1处，看到了 observer.dispatchEvent(lifecycleOwner, event)，这个方法处于ObserverWithState 类方法，多生命周期事件进行了分发，如下代码

static class ObserverWithState {
    State mState;
    LifecycleEventObserver mLifecycleObserver;

    ObserverWithState(LifecycleObserver observer, State initialState) {
        mLifecycleObserver = Lifecycling.lifecycleEventObserver(observer);
        mState = initialState;
    }

    void dispatchEvent(LifecycleOwner owner, Event event) {
        State newState = getStateAfter(event);
        mState = min(mState, newState);
        mLifecycleObserver.onStateChanged(owner, event);
        mState = newState;
    }
}

在ObserverWithState 的构造方法中我们主要看看mLifecycleObserver = Lifecycling.lifecycleEventObserver(observer)这行代码，实现如下：

@NonNull
static LifecycleEventObserver lifecycleEventObserver(Object object) {

    //....................................................

    final Class<?> klass = object.getClass();
    int type = getObserverConstructorType(klass);
    if (type == GENERATED_CALLBACK) {
        List<Constructor<? extends GeneratedAdapter>> constructors =
                sClassToAdapters.get(klass);
        if (constructors.size() == 1) {
            GeneratedAdapter generatedAdapter = createGeneratedAdapter(
                    constructors.get(0), object);
            return new SingleGeneratedAdapterObserver(generatedAdapter);
        }
        GeneratedAdapter[] adapters = new GeneratedAdapter[constructors.size()];
        for (int i = 0; i < constructors.size(); i++) {
            adapters[i] = createGeneratedAdapter(constructors.get(i), object);
        }
        return new CompositeGeneratedAdaptersObserver(adapters);
    }
    return new ReflectiveGenericLifecycleObserver(object);      
}

在lifecycleEventObserver方法中object参数就是我们定义实现了LifecycleObserver接口的MyLifecycle对象，并且通过这个对象去拿到构造方法，实际上是通过拼接_LifecycleAdapter拿到MyLifeCycle_LifecycleAdapter 对象，并创建了GeneratedAdapter对象并把MyLifecycle对象当做参数传进去。

在上MyLifecycle生成类的代码：

public class MyLifeCycle_LifecycleAdapter implements GeneratedAdapter {
final MyLifeCycle mReceiver;

MyLifeCycle_LifecycleAdapter(MyLifeCycle receiver) {
    this.mReceiver = receiver;
}

public void callMethods(LifecycleOwner owner, Event event, boolean onAny, MethodCallsLogger logger) {
    boolean hasLogger = logger != null;
    if (!onAny) {
        if (event == Event.ON_CREATE) {
            if (!hasLogger || logger.approveCall("onCreate", 1)) {
                this.mReceiver.onCreate();
            }

        }
    }
}
}

最后在ObserverWithState.dispatchEvent方法中调用了 mLifecycleObserver.onStateChanged(owner, event)方法，也就是定义的MyLifecycle类生成的MyLifeCycle_LifecycleAdapter 类的onStateChanged方法，最终会调用我们的MyLifecycle的onCreate()方法，最后在看一下具体的流程图：


lifecycle.png

Lifecycle的原理比较简单，调用过程也比较简单。但使用时需要注意以下几点：

  • Lifecycle有状态倒灌过程，也就是在任意生命周期中注册LifecycleObserver，这个LifecycleObserver会把前面的生命周期回调都执行一遍，直到和注册时的生命周期状态同步。
  • 在Activity/Fragment重写生命周期方法时，必须调用父类的相应方法，因为Lifecycle的生命周期分发在父类的相应生命周期方法中。

总结

  • 首先LifeCycle的实现类LifecycleRegistry封装了LifecycleObserver、LifecycleOwner 以及组件的生命周期的分发逻辑，以Activity为例，那么Activity生命周期是怎么分发到LifecycleRegistry的？首先在ComponentActivity的onCreate方法中会调用 ReportFragment.injectIfNeededIn(this)方法，在injectIfNeededIn中将 ComponentActivity 的生命周期回调，并将ReportFragment注册到该Activity中监听Activity的生命周期，当Activity的生命周期状态发生改变会调用ReportFragment的dispatch将生命周期分发给LifecycleRegistry.handleLifecycleEvent(event),最终会通过LifecycleRegistry将生命周期分发到LifecycleObserver中。

  • 以Activity为例，Activity实现了LifecycleOwner的getLifecycle的方法并返回的是LifeCycle 表示Activity代理生命周期的接口，而LifeCycle的实现类LifecycleRegistry分装了生命周期分发的所有逻辑 ，当Activity生命周期发生变化就会通过LifecycleRegistry.handleLifecycleEvent(event)进行分发到通过Lifecycle.addObserver添加的LifecycleObserver的监听生命周期方法上，第一种是注解生成，另一种是LifecycleEventObserver。

  • Activity虽然实现了LifecycleOwner接口，仅仅只是实现了LifecycleOwner的getLifeCycle方法，该方法返回的是LifeCycle实现类LifecycleRegistry，通过源码可知LifecycleRegistry封装了所有生命周期分发的逻辑，并在Activity的onCreate中通过添加一个ReportFragment类监听Activity生命周期，当Activity生命周期发生变化就会通过LifecycleRegistry.handleLifecycleEvent(event)进行分发到通过Lifecycle.addObserver添加的LifecycleObserver的监听生命周期方法上。

最后编辑于 ：
©著作权归作者所有,转载或内容合作请联系作者
  • 人面猴
    序言：七十年代末，一起剥皮案震惊了整个滨河市，随后出现的几起案子，更是在滨河造成了极大的恐慌，老刑警刘岩，带你破解...
    沈念sama阅读 196,165评论 5赞 462
  • 死咒
    序言：滨河连续发生了三起死亡事件，死亡现场离奇诡异，居然都是意外死亡，警方通过查阅死者的电脑和手机，发现死者居然都...
    沈念sama阅读 82,503评论 2赞 373
  • 救了他两次的神仙让他今天三更去死
    文/潘晓璐 我一进店门，熙熙楼的掌柜王于贵愁眉苦脸地迎上来，“玉大人，你说我怎么就摊上这事。” “怎么了？”我有些...
    开封第一讲书人阅读 143,295评论 0赞 325
  • 道士缉凶录：失踪的卖姜人
    文/不坏的土叔 我叫张陵，是天一观的道长。 经常有香客问我，道长，这世上最难降的妖魔是什么？ 我笑而不...
    开封第一讲书人阅读 52,589评论 1赞 267
  • 港岛之恋（遗憾婚礼）
    正文 为了忘掉前任，我火速办了婚礼，结果婚礼上，老公的妹妹穿的比我还像新娘。我一直安慰自己，他们只是感情好，可当我...
    茶点故事阅读 61,439评论 5赞 358
  • 恶毒庶女顶嫁案：这布局不是一般人想出来的
    文/花漫 我一把揭开白布。 她就那样静静地躺着，像睡着了一般。 火红的嫁衣衬着肌肤如雪。 梳的纹丝不乱的头发上，一...
    开封第一讲书人阅读 46,342评论 1赞 273
  • 城市分裂传说
    那天，我揣着相机与录音，去河边找鬼。 笑死，一个胖子当着我的面吹牛，可吹牛的内容都是我干的。 我是一名探鬼主播，决...
    沈念sama阅读 36,749评论 3赞 387
  • 双鸳鸯连环套：你想象不到人心有多黑
    文/苍兰香墨 我猛地睁开眼，长吁一口气：“原来是场噩梦啊……” “哼！你这毒妇竟也来了？” 一声冷哼从身侧响起，我...
    开封第一讲书人阅读 35,397评论 0赞 255
  • 万荣杀人案实录
    序言：老挝万荣一对情侣失踪，失踪者是张志新（化名）和其女友刘颖，没想到半个月后，有当地人在树林里发现了一具尸体，经...
    沈念sama阅读 39,700评论 1赞 295
  • 护林员之死
    正文 独居荒郊野岭守林人离奇死亡，尸身上长有42处带血的脓包…… 初始之章·张勋 以下内容为张勋视角 年9月15日...
    茶点故事阅读 34,740评论 2赞 313
  • 白月光启示录
    正文 我和宋清朗相恋三年，在试婚纱的时候发现自己被绿了。 大学时的朋友给我发了我未婚夫和他白月光在一起吃饭的照片。...
    茶点故事阅读 36,523评论 1赞 326
  • 活死人
    序言：一个原本活蹦乱跳的男人离奇死亡，死状恐怖，灵堂内的尸体忽然破棺而出，到底是诈尸还是另有隐情，我是刑警宁泽，带...
    沈念sama阅读 32,364评论 3赞 314
  • 日本核电站爆炸内幕
    正文 年R本政府宣布，位于F岛的核电站，受9级特大地震影响，放射性物质发生泄漏。R本人自食恶果不足惜，却给世界环境...
    茶点故事阅读 37,755评论 3赞 300
  • 男人毒药：我在死后第九天来索命
    文/蒙蒙 一、第九天 我趴在偏房一处隐蔽的房顶上张望。 院中可真热闹，春花似锦、人声如沸。这庄子的主人今日做“春日...
    开封第一讲书人阅读 29,024评论 0赞 19
  • 一桩弑父案，背后竟有这般阴谋
    文/苍兰香墨 我抬头看了看天上的太阳。三九已至，却和暖如春，着一层夹袄步出监牢的瞬间，已是汗流浃背。 一阵脚步声响...
    开封第一讲书人阅读 30,297评论 1赞 251
  • 情欲美人皮
    我被黑心中介骗来泰国打工， 没想到刚下飞机就差点儿被人妖公主榨干…… 1. 我叫王不留，地道东北人。 一个月前我还...
    沈念sama阅读 41,721评论 2赞 342
  • 代替公主和亲
    正文 我出身青楼，却偏偏与公主长得像，于是被迫代替她去往敌国和亲。 传闻我的和亲对象是个残疾皇子，可洞房花烛夜当晚...
    茶点故事阅读 40,918评论 2赞 336