[关闭]
@TryLoveCatch 2021-04-08T12:08:18.000000Z 字数 35201 阅读 1127

Jetpack之Lifecycle

android Jetpack Lifecycle


基于android.arch.lifecycle的1.1.1版本

WHAT(使用,什么作用?)

简介

Lifecycle 是一个类,用于存储有关组件(如 Activity 或 Fragment)的生命周期状态的信息,并允许其他对象观察此状态。
Lifecycle 使用两种主要枚举跟踪其关联组件的生命周期状态:

  • 事件
    从框架和 Lifecycle 类分派的生命周期事件。这些事件映射到 Activity 和 Fragment 中的回调事件。
  • 状态
    由 Lifecycle 对象跟踪的组件的当前状态。

从左向右我们称之为上升,或者前进,反之称为降低或者后退。从数值上看,右侧比左侧大。(DESTROYED值最小)

注意:Support Library 26.1.0 及更高版本中的 Fragment 和 Activity 已实现 LifecycleOwner 接口。

Lifecycle 的应用场景非常广泛,我们可以利用 Lifecycle 的机制来帮助我们将一切跟生命周期有关的业务逻辑全都剥离出去,进行完全解耦。比如说:

使用

  1. package com.example.lifecycledemo1;
  2. import android.arch.lifecycle.Lifecycle;
  3. import android.arch.lifecycle.LifecycleObserver;
  4. import android.arch.lifecycle.OnLifecycleEvent;
  5. import android.support.v7.app.AppCompatActivity;
  6. import android.os.Bundle;
  7. import android.util.Log;
  8. public class MainActivity extends AppCompatActivity {
  9. private static final String TAG = "MainActivity";
  10. @Override
  11. protected void onCreate(Bundle savedInstanceState) {
  12. super.onCreate(savedInstanceState);
  13. setContentView(R.layout.activity_main);
  14. getLifecycle().addObserver(new MyObserver());//2
  15. }
  16. //1
  17. public class MyObserver implements LifecycleObserver{
  18. @OnLifecycleEvent(Lifecycle.Event.ON_RESUME)
  19. void onResume(){
  20. Log.d(TAG, "Lifecycle call onResume");
  21. }
  22. @OnLifecycleEvent(Lifecycle.Event.ON_PAUSE)
  23. void onPause(){
  24. Log.d(TAG, "Lifecycle call onPause");
  25. }
  26. }
  27. @Override
  28. protected void onResume() {
  29. super.onResume();
  30. Log.d(TAG, "onResume");
  31. }
  32. @Override
  33. protected void onPause() {
  34. super.onPause();
  35. Log.d(TAG, "onPause");
  36. }
  37. }

运行程序,打印的log如下所示:

  1. D/MainActivity: onResume
  2. D/MainActivity: Lifecycle call onResume
  3. D/MainActivity: Lifecycle call onPause
  4. D/MainActivity: onPause

只要在MainActivity的onCreate方法中添加MyObserver,那么MyObserver就可以观察到MainActivity的各个生命周期的变化。

注意:在新版本,比如说2.2.0版本,提供了DefaultLifecycleObserver,这种通过接口的方式来回调生命周期,注解的方式在以后会被逐步废弃,Google 官方也建议开发者尽量使用接口回调的形式。

  • 如果您使用Java 8 语言 ,然后使用DefaultLifecycleObserver 观察事件。 需要将"androidx.lifecycle:common-java8:" 增加到你的 build.gradle 文件中。
  • 如果你使用的Java 7 语言 ,使用的注解观察生命周期事件。

自定义LifecycleOwner

如果你的 Support 库版本号低于 26.1.0,或者你的自定义类想要实现 LifecycleOwner,你需要使用到 LifecycleRegistry,并且自己处理每个生命周期,它是Lifecycle的实现类。

  1. public class MyActivity extends Activity implements LifecycleOwner {
  2. private LifecycleRegistry lifecycleRegistry;
  3. @Override
  4. protected void onCreate(Bundle savedInstanceState) {
  5. super.onCreate(savedInstanceState);
  6. lifecycleRegistry = new LifecycleRegistry(this);
  7. lifecycleRegistry.markState(Lifecycle.State.CREATED);
  8. }
  9. @Override
  10. public void onStart() {
  11. super.onStart();
  12. lifecycleRegistry.markState(Lifecycle.State.STARTED);
  13. }
  14. @NonNull
  15. @Override
  16. public Lifecycle getLifecycle() {
  17. return lifecycleRegistry;
  18. }
  19. }

小结

  • support包中的AppCompatActivity或者Fragment
    • Support Library 26.1.0 及更高版本
      直接使用即可
    • Support Library 26.1.0以下版本
      同下
  • 普通Activity
    1. 依赖了android.arch.lifecycle:extensions,Activity只需要实现LifecycleOwner即可(为什么,下面会说明)
    2. 没有依赖,实现LifecycleOwner,并且需要自己处理生命周期,调用LifecycleRegistry相关方法
  • 普通Fragment
    1. 实现LifecycleOwner,并且需要自己处理生命周期,调用LifecycleRegistry相关方法

HOW(原理,怎么实现的?)

基于1.1.0版本

Support Library 26.1.0 及更高版本

通过使用方式,我们可以很清楚的看出来,Lifecycle组件使用的是观察者模式,注册一个观察者,当Activity/Fragment生命周期改变的时候,通知观察者。

被观察者

LifecycleOwner
  1. public interface LifecycleOwner {
  2. @NonNull
  3. Lifecycle getLifecycle();
  4. }

LifecycleOwner接口非常简单,就提供了一个方法:返回Lifecycle。
所有实现了LifecycleOwner的类,都将会作为被观察者。

Lifecycle

Lifecycle只是一个抽象类,如下:

  1. public abstract class Lifecycle {
  2. @MainThread
  3. public abstract void addObserver(@NonNull LifecycleObserver observer);
  4. @MainThread
  5. public abstract void removeObserver(@NonNull LifecycleObserver observer);
  6. @MainThread
  7. @NonNull
  8. public abstract State getCurrentState();
  9. @SuppressWarnings("WeakerAccess")
  10. public enum Event {
  11. ON_CREATE,
  12. ON_START,
  13. ON_RESUME,
  14. ON_PAUSE,
  15. ON_STOP,
  16. ON_DESTROY,
  17. ON_ANY
  18. }
  19. @SuppressWarnings("WeakerAccess")
  20. public enum State {
  21. DESTROYED,
  22. INITIALIZED,
  23. CREATED,
  24. STARTED,
  25. RESUMED;
  26. public boolean isAtLeast(@NonNull State state) {
  27. return compareTo(state) >= 0;
  28. }
  29. }
  30. }

Lifecycle内部不仅包括了添加和移除观察者的方法,还包括了此前说到的Event和State枚举。可以看到Event中的事件和Activity的生命周期几乎是对应的,除了ON_ANY,它可用于匹配所有事件。

Lifecycle使用两个枚举来跟踪其关联组件的生命周期状态,这两个枚举分别是Event和State。

ComponentActivity/SupportActivity

Support Library 26.1.0 及更高版本,我们的Activity/Fragment都是直接实现了LifecycleOwner,所以我们看一下它们里面是怎么处理的。

SupportActivity和ComponentActivity的代码区别不大,这里以ComponentActivity举例,如下所示:

  1. public class ComponentActivity extends Activity implements LifecycleOwner {
  2. private LifecycleRegistry mLifecycleRegistry = new LifecycleRegistry(this);//1
  3. ...
  4. @Override
  5. @SuppressWarnings("RestrictedApi")
  6. protected void onCreate(@Nullable Bundle savedInstanceState) {
  7. super.onCreate(savedInstanceState);
  8. ReportFragment.injectIfNeededIn(this);//2
  9. }
  10. ...
  11. @Override
  12. public Lifecycle getLifecycle() {
  13. return mLifecycleRegistry;//3
  14. }
  15. ...
  16. }

我们发现,Activity里面并没有直接通过生命周期接口进行各种通知处理,与Lifecycle相关的有三个地方:
1. new LifecycleRegistry(LifecycleOwner)
2. ReportFragment.injectIfNeededIn(this)
3. getLifecycle()

关于3,比较好理解,因为实现了LifecycleOwner,所以需要实现LifecycleOwner的唯一接口getLifecycle,返回的是LifecycleRegistry。

目前有两个问题:

ReportFragment

我们先来看在Activity里面调用的静态方法injectIfNeededIn():

  1. public static void injectIfNeededIn(Activity activity) {
  2. // ProcessLifecycleOwner should always correctly work and some activities may not extend
  3. // FragmentActivity from support lib, so we use framework fragments for activities
  4. android.app.FragmentManager manager = activity.getFragmentManager();
  5. if (manager.findFragmentByTag(REPORT_FRAGMENT_TAG) == null) {
  6. manager.beginTransaction().add(new ReportFragment(), REPORT_FRAGMENT_TAG).commit();
  7. // Hopefully, we are the first to make a transaction.
  8. manager.executePendingTransactions();
  9. }
  10. }

首先,通过tag去找对应的Fragment,如果不存在,就新建一个ReportFragment,并立即添加到Activity中去。
另外还提供了一个静态方法:

  1. static ReportFragment get(Activity activity) {
  2. return (ReportFragment) activity.getFragmentManager().findFragmentByTag(
  3. REPORT_FRAGMENT_TAG);
  4. }

用来返回ReportFragment,有可能为 null。
我们继续来看它在生命周期回调都做了什么:

  1. @Override
  2. public void onActivityCreated(Bundle savedInstanceState) {
  3. super.onActivityCreated(savedInstanceState);
  4. dispatch(Lifecycle.Event.ON_CREATE);
  5. }
  6. @Override
  7. public void onStart() {
  8. super.onStart();
  9. dispatch(Lifecycle.Event.ON_START);
  10. }
  11. @Override
  12. public void onResume() {
  13. super.onResume();
  14. dispatch(Lifecycle.Event.ON_RESUME);
  15. }
  16. @Override
  17. public void onPause() {
  18. super.onPause();
  19. dispatch(Lifecycle.Event.ON_PAUSE);
  20. }
  21. @Override
  22. public void onStop() {
  23. super.onStop();
  24. dispatch(Lifecycle.Event.ON_STOP);
  25. }
  26. @Override
  27. public void onDestroy() {
  28. super.onDestroy();
  29. dispatch(Lifecycle.Event.ON_DESTROY);
  30. }

ReportFragment在它的生命周期里面都调用来dispatch(),并且传入了Lifecycle.Event,我们来看下dispatch():

  1. private void dispatch(Lifecycle.Event event) {
  2. Activity activity = getActivity();
  3. // 已经废弃,忽略
  4. if (activity instanceof LifecycleRegistryOwner) {
  5. ((LifecycleRegistryOwner) activity).getLifecycle().handleLifecycleEvent(event);
  6. return;
  7. }
  8. // 1
  9. if (activity instanceof LifecycleOwner) {
  10. Lifecycle lifecycle = ((LifecycleOwner) activity).getLifecycle();
  11. if (lifecycle instanceof LifecycleRegistry) {
  12. ((LifecycleRegistry) lifecycle).handleLifecycleEvent(event);
  13. }
  14. }
  15. }

我们主要看注释1这里,很简单:

LifecycleRegistry

https://android.googlesource.com/platform/frameworks/support/+/a9ac247af2afd4115c3eb6d16c05bc92737d6305/lifecycle/runtime/src/main/java/androidx/lifecycle/LifecycleRegistry.java

  1. public class LifecycleRegistry extends Lifecycle {
  2. //一般一个 LifecycleRegistry 对应一个 LifecycleOwner 对象(Activity/Fragment等)
  3. //mState 就用来标记 LifecycleOwner 对象所处的当前生命周期状态
  4. private State mState;
  5. //持有对 LifecycleOwner 的弱引用,避免内存泄露
  6. private final WeakReference<LifecycleOwner> mLifecycleOwner;
  7. public LifecycleRegistry(@NonNull LifecycleOwner provider) {
  8. mLifecycleOwner = new WeakReference<>(provider);
  9. mState = INITIALIZED;
  10. }
  11. }

LifecycleRegistry,继承了Lifecycle抽象类,是整个 Lifecycle 家族内一个很重要的类,其屏蔽了生命周期持有类(Activity / Fragment 等)的具体类型,使得外部(Activity / Fragment 等)可以只负责转发生命周期事件,由 LifecycleRegistry 来实现具体的事件回调和状态管理。

我们先来看下LifecycleRegistry是如何实现Lifecycle抽象类的。

getCurrentState()
  1. /**
  2. * Current state
  3. */
  4. private State mState;
  5. public LifecycleRegistry(@NonNull LifecycleOwner provider) {
  6. mLifecycleOwner = new WeakReference<>(provider);
  7. mState = INITIALIZED;
  8. }
  9. @Override
  10. public State getCurrentState() {
  11. return mState;
  12. }

返回当前的State,会在moveToState(State)进行更新

removeObserver(LifecycleObserver)
  1. @Override
  2. public void removeObserver(@NonNull LifecycleObserver observer) {
  3. mObserverMap.remove(observer);
  4. }

删除监听,删除观察者

addObserver(LifecycleObserver)
  1. //Lifecycle 类中对 addObserver 方法添加了 @MainThread 注解,意思是该方法只能用于主线程调用
  2. //所以此处不需要考虑多线程的情况
  3. @Override
  4. public void addObserver(@NonNull LifecycleObserver observer) {
  5. State initialState = mState == DESTROYED ? DESTROYED : INITIALIZED;
  6. ObserverWithState statefulObserver = new ObserverWithState(observer, initialState);
  7. ObserverWithState previous = mObserverMap.putIfAbsent(observer, statefulObserver);
  8. if (previous != null) {
  9. //如果 observer 之前已经传进来过了,则不重复添加,直接返回
  10. return;
  11. }
  12. LifecycleOwner lifecycleOwner = mLifecycleOwner.get();
  13. if (lifecycleOwner == null) {
  14. // it is null we should be destroyed. Fallback quickly
  15. //如果 LifecycleOwner 对象已经被回收了,则直接返回
  16. return;
  17. }
  18. //如果 isReentrance 为 true,则说明此时以下两种情况至少有一个成立:
  19. //1. mAddingObserverCounter != 0。会出现这种情况,是由于开发者先添加了一个 LifecycleObserver ,当还在向其回调事件的过程中,在回调函数里又再次调用了 addObserver 方法添加了一个新的 LifecycleObserver
  20. //2.mHandlingEvent 为 true。即此时正处于向外回调 Lifecycle.Event 的状态
  21. boolean isReentrance = mAddingObserverCounter != 0 || mHandlingEvent;
  22. State targetState = calculateTargetState(observer);
  23. //递增加一,标记当前正处于向新添加的 LifecycleObserver 回调 Event 值的过程
  24. mAddingObserverCounter++;
  25. //statefulObserver.mState.compareTo(targetState) < 0 成立的话说明 当前观察者的State 小于 目标State
  26. //mObserverMap.contains(observer) 成立的话说明 observer 还没有并移除
  27. //因为有可能在遍历过程中开发者主动在回调函数里将 observer 给移除掉了,所以这里每次循环都检查下
  28. while ((statefulObserver.mState.compareTo(targetState) < 0
  29. && mObserverMap.contains(observer))) {
  30. //将 observer 已经遍历到的当前的状态值 mState 保存下来
  31. pushParentState(statefulObserver.mState);
  32. //向 observer 回调进入“statefulObserver.mState”前需要收到的 Event 值
  33. statefulObserver.dispatchEvent(lifecycleOwner, upEvent(statefulObserver.mState));
  34. //移除 mState
  35. popParentState();
  36. // mState / subling may have been changed recalculate
  37. targetState = calculateTargetState(observer);
  38. }
  39. if (!isReentrance) {
  40. // we do sync only on the top level.
  41. sync();
  42. }
  43. mAddingObserverCounter--;
  44. }

添加观察者,步骤如下:

addObserver()这里面有几个需要说的地方:

calculateTargetState(LifecycleObserver)
这个方法是用来计算targetState,怎么计算呢?

当前状态 mState、mObserverMap 中最后一个观察者的状态 、有重入情况下 parentState 的状态 这三者中的最小值就是targetState

  1. /**
  2. * 计算出的 targetState 一定是 <= mState 的
  3. */
  4. private State calculateTargetState(LifecycleObserver observer) {
  5. // 获取当前 Observer 的前一个 Observer
  6. Entry<LifecycleObserver, ObserverWithState> previous = mObserverMap.ceil(observer);
  7. State siblingState = previous != null ? previous.getValue().mState : null;
  8. // 无重入情况下可不考虑 parentState ,为 null
  9. State parentState = !mParentStates.isEmpty() ? mParentStates.get(mParentStates.size() - 1)
  10. : null;
  11. return min(min(mState, siblingState), parentState);
  12. }

为什么要取这个最小值呢?
我是这么理解的,当有新的生命周期事件时,需要将 mObserverMap 中的所有观察者都同步到新的同一状态,这个同步过程可能尚未完成,所以新加入的观察者只能先同步到最小状态。注意在 addObserver 方法的 while 循环中,新的观察者每改变一次生命周期,都会调用 calculateTargetState() 重新计算 targetState。可以确保新的观察者State一定是<=上一个观察者的State

ObserverWithState
addObserver的时候,会把传进来的LifecycleObserver包装成ObserverWithState

  1. static class ObserverWithState {
  2. State mState;
  3. GenericLifecycleObserver mLifecycleObserver;
  4. ObserverWithState(LifecycleObserver observer, State initialState) {
  5. mLifecycleObserver = Lifecycling.getCallback(observer);
  6. mState = initialState;
  7. }
  8. void dispatchEvent(LifecycleOwner owner, Event event) {
  9. State newState = getStateAfter(event);
  10. mState = min(mState, newState);
  11. mLifecycleObserver.onStateChanged(owner, event);
  12. mState = newState;
  13. }
  14. }

可以看出来,通过LifecycleObserver,得到了一个GenericLifecycleObserver,这个类是LifecycleObserver的子类,比LifecycleObserver多了一个onStateChanged(LifecycleOwner, Lifecycle.Event)。

handleLifecycleEvent(Lifecycle.Event)

上面我们看到了,ReportFragment 最终在向外传出 Lifecycle.Event 值时,调用的都是 LifecycleRegistry 对象的。 handleLifecycleEvent(Lifecycle.Event) 方法,既然需要的 Event 值已经拿到了,那再来看下 LifecycleRegistry 是如何将 Event 值转发给 LifecycleObserver 的。

  1. public void handleLifecycleEvent(@NonNull Lifecycle.Event event) {
  2. State next = getStateAfter(event);
  3. moveToState(next);
  4. }
  5. private void moveToState(State next) {
  6. if (mState == next) {
  7. return;
  8. }
  9. mState = next;
  10. if (mHandlingEvent || mAddingObserverCounter != 0) {
  11. mNewEventOccurred = true;
  12. // we will figure out what to do on upper level.
  13. return;
  14. }
  15. mHandlingEvent = true;
  16. sync();
  17. mHandlingEvent = false;
  18. }
  19. private void sync() {
  20. LifecycleOwner lifecycleOwner = mLifecycleOwner.get();
  21. if (lifecycleOwner == null) {
  22. Log.w(LOG_TAG, "LifecycleOwner is garbage collected, you shouldn't try dispatch "
  23. + "new events from it.");
  24. return;
  25. }
  26. while (!isSynced()) {
  27. mNewEventOccurred = false;
  28. // no need to check eldest for nullability, because isSynced does it for us.
  29. if (mState.compareTo(mObserverMap.eldest().getValue().mState) < 0) {
  30. backwardPass(lifecycleOwner);
  31. }
  32. Entry<LifecycleObserver, ObserverWithState> newest = mObserverMap.newest();
  33. if (!mNewEventOccurred && newest != null
  34. && mState.compareTo(newest.getValue().mState) > 0) {
  35. forwardPass(lifecycleOwner);
  36. }
  37. }
  38. mNewEventOccurred = false;
  39. }

LifecycleRegistry利用FastSafeIterableMap有序的特性,保证添加的Observer按照插入顺序,State从大到小的顺序排列。所以判断同步完成,只需要看第一个Observer和最后一个Observer的状态相等,并且等于LifecycleRegistry的状态。

  1. private void backwardPass(LifecycleOwner lifecycleOwner) {
  2. // 反向遍历的迭代器
  3. Iterator<Entry<LifecycleObserver, ObserverWithState>> descendingIterator =
  4. mObserverMap.descendingIterator();
  5. // 如果在分发过程中有新的事件,就终止分发
  6. while (descendingIterator.hasNext() && !mNewEventOccurred) {
  7. Entry<LifecycleObserver, ObserverWithState> entry = descendingIterator.next();
  8. // 内部对Observer的封装,记录Observer的状态
  9. ObserverWithState observer = entry.getValue();
  10. // 如果Observer的state比当前state大,调整state(通过分发事件)
  11. // 这里判断是否contains可能是为了兼容在分发过程中Observer被移除的情况,避免不必要的处理。比如Observer的state比当前state大两个级别,那么下面的循环将执行两次,第一次分发事件的处理中,有可能就把Observer移除了;第二次在进入循环,mObserverMap中就不会存在这个entry了。
  12. while ((observer.mState.compareTo(mState) > 0 && !mNewEventOccurred
  13. && mObserverMap.contains(entry.getKey()))) {
  14. // 获取下一个事件
  15. Event event = downEvent(observer.mState);
  16. // 兼容重入场景,入栈。这里记录的是observer的目标状态,也就是执行完event后的状态。
  17. pushParentState(getStateAfter(event));
  18. // 分发事件
  19. observer.dispatchEvent(lifecycleOwner, event);
  20. // 兼容重入场景,出栈。
  21. popParentState();
  22. }
  23. }
  24. }

不管是前进还是后退,最后都是调用了observer.dispatchEvent(),也就是ObserverWithState#dispatchEvent(LifecycleOwner owner, Event event)

pushParentState()

主要是为了解决嵌套使用的问题。
例如在观察者A的回调里面,又再次add了一个观察者B,观察者A当前的状态就是观察者B的ParentState,看名字是不是有点理解了。并且需要确保执行顺序

  1. private ArrayList<State> mParentStates = new ArrayList<>();
  2. private void popParentState() {
  3. mParentStates.remove(mParentStates.size() - 1);
  4. }
  5. private void pushParentState(State state) {
  6. mParentStates.add(state);
  7. }

我们来举例说明:

假设,onStart监听了Event的ON_START,先添加的ObserverA的onStart方法,一定比后添加的ObserverB的onStart方法先执行完成。即便是B在A的onStart方法中添加的情况下(A.onStart执行完成后,B.onStart方法才会执行)。

  1. ObserverA {
  2. @OnLifecycleEvent(Lifecycle.Event.ON_START)
  3. void onStart(){
  4. ....
  5. mRegistry.removeObserver(this);
  6. mRegistry.addObserver(ObserverB);
  7. }
  8. }

整个方法调用流程大致如下:

  1. Activity#onStart()
  2. LifecycleRegistry#handleLifecycleEvent()
  3. LifecycleRegistry#moveToState()
  4. LifecycleRegistry#sync()
  5. LifecycleRegistry#forwardPass()
  6. LifecycleRegistry#pushParentState()// push A,此时为CREATED
  7. A-ObserverWithState#dispatchEvent()
  8. A-ObserverWithState#mState// 此时取的是min(mState, newState)
  9. A-GenericLifecycleObserver#onStateChanged()
  10. A#onStart()
  11. LifecycleRegistry#removeObserver()// 删除A
  12. LifecycleRegistry#addObserver() // 添加B
  13. LifecycleRegistry#calculateTargetState() // 此时LifecycleRegistry#mState是STARTED,previousObserver为null(A被删除了),mParentState为CREATED,所以最后targetState为CREATED
  14. LifecycleRegistry#pushParentState()// push B
  15. B-ObserverWithStateB#dispatchEvent()
  16. LifecycleRegistry#popParentState()// pop B
  17. LifecycleRegistry#calculateTargetState()// B add完成
  18. A-ObserverWithState#mState// 此时取的是newState,A更新完毕为STARTED
  19. LifecycleRegistry#popParentState()// pop A
  20. // 继续对B进行通知,更新B为STARTED

这个比较难理解,咱们理一下,说一下关键点:

所以你看,如果没有mParentState,也就是没有调用pushParentState(),那么B就会先于A更新到STARTED状态

ObserverWithState
  1. static class ObserverWithState {
  2. State mState;
  3. GenericLifecycleObserver mLifecycleObserver;
  4. ObserverWithState(LifecycleObserver observer, State initialState) {
  5. mLifecycleObserver = Lifecycling.getCallback(observer);
  6. mState = initialState;
  7. }
  8. void dispatchEvent(LifecycleOwner owner, Event event) {
  9. State newState = getStateAfter(event);
  10. mState = min(mState, newState);
  11. mLifecycleObserver.onStateChanged(owner, event);
  12. mState = newState;
  13. }
  14. }

ObserverWithState很简单,主要是需要关注两个点:

小结

观察者

LifecycleObserver(观察者)

这是一个空方法,实现该接口的类,通过注解的方式,并通过Lifecycle#addObserver()注册后,LifecycleObserver便可以观察到LifecycleOwner的生命周期事件。

GenericLifecycleObserver

https://android.googlesource.com/platform/frameworks/support/+/a9ac247af2afd4115c3eb6d16c05bc92737d6305/lifecycle/common/src/main/java/androidx/lifecycle/GenericLifecycleObserver.java

  1. public interface GenericLifecycleObserver extends LifecycleObserver {
  2. /**
  3. * Called when a state transition event happens.
  4. *
  5. * @param source The source of the event
  6. * @param event The event
  7. */
  8. void onStateChanged(LifecycleOwner source, Lifecycle.Event event);
  9. }

增加了一个onStateChanged(),在addObserver的时候,把LifecycleObserver通过Lifecycling转换为了GenericLifecycleObserver,并保存了起来,后续通知时使用。

Lifecycling

https://android.googlesource.com/platform/frameworks/support/+/a9ac247af2afd4115c3eb6d16c05bc92737d6305/lifecycle/common/src/main/java/androidx/lifecycle/Lifecycling.java

https://leavesc.gitbook.io/androidguide/jetpack-yuan-ma-bi-ji/lifecycle-yuan-ma-jie-xi#3-2-sdk-less-than-29

Lifecycling被上面提到了很多次,getCallback主要以下几种情况:

  1. interface FullLifecycleObserver extends LifecycleObserver {
  2. void onCreate(LifecycleOwner owner);
  3. void onStart(LifecycleOwner owner);
  4. void onResume(LifecycleOwner owner);
  5. void onPause(LifecycleOwner owner);
  6. void onStop(LifecycleOwner owner);
  7. void onDestroy(LifecycleOwner owner);
  8. }
  9. class FullLifecycleObserverAdapter implements GenericLifecycleObserver {
  10. private final FullLifecycleObserver mObserver;
  11. FullLifecycleObserverAdapter(FullLifecycleObserver observer) {
  12. mObserver = observer;
  13. }
  14. @Override
  15. public void onStateChanged(LifecycleOwner source, Lifecycle.Event event) {
  16. switch (event) {
  17. case ON_CREATE:
  18. mObserver.onCreate(source);
  19. break;
  20. case ON_START:
  21. mObserver.onStart(source);
  22. break;
  23. case ON_RESUME:
  24. mObserver.onResume(source);
  25. break;
  26. case ON_PAUSE:
  27. mObserver.onPause(source);
  28. break;
  29. case ON_STOP:
  30. mObserver.onStop(source);
  31. break;
  32. case ON_DESTROY:
  33. mObserver.onDestroy(source);
  34. break;
  35. case ON_ANY:
  36. throw new IllegalArgumentException("ON_ANY must not been send by anybody");
  37. }
  38. }
  39. }
ClassesInfoCache

https://leavesc.gitbook.io/androidguide/jetpack-yuan-ma-bi-ji/lifecycle-yuan-ma-jie-xi#wu-lifecycling

Java 平台的反射操作是一个比较低效和耗费性能的行为,为了避免每次有需要进行事件回调时都再来对包含 OnLifecycleEvent 注解的 class 对象进行反射解析,所以 Lifecycling 内部对 Class、Method 等进行了缓存,以便后续复用。而 Lifecycling 就将这些缓存信息都封装存放在了 ClassesInfoCache 内部

需要注意的是:被注解的函数的入参类型、入参顺序、入参个数都有着严格的限制。
毕竟如果开发者为回调函数声明了一个 String 类型的入参参数的话,Lifecycle 也不知道该向其传递什么属性值

ClassesInfoCache 内部会判断指定的 class 对象是否包含使用了 OnLifecycleEvent 进行注解的函数,并将判断结果缓存在 mHasLifecycleMethods 内,缓存信息会根据 createInfo(klass, methods) 来进行获取

  1. //判断指定的 class 对象是否包含使用了 OnLifecycleEvent 进行注解的函数
  2. boolean hasLifecycleMethods(Class<?> klass) {
  3. Boolean hasLifecycleMethods = mHasLifecycleMethods.get(klass);
  4. if (hasLifecycleMethods != null) {
  5. //如果本地有缓存的话则直接返回缓存值
  6. return hasLifecycleMethods;
  7. }
  8. //本地还没有缓存值,以下逻辑就是来通过反射判断 klass 是否包含使用 OnLifecycleEvent 进行注解的函数
  9. //获取 klass 包含的所有函数
  10. Method[] methods = getDeclaredMethods(klass);
  11. for (Method method : methods) {
  12. OnLifecycleEvent annotation = method.getAnnotation(OnLifecycleEvent.class);
  13. if (annotation != null) {
  14. // Optimization for reflection, we know that this method is called
  15. // when there is no generated adapter. But there are methods with @OnLifecycleEvent
  16. // so we know that will use ReflectiveGenericLifecycleObserver,
  17. // so we createInfo in advance.
  18. // CreateInfo always initialize mHasLifecycleMethods for a class, so we don't do it
  19. // here.
  20. createInfo(klass, methods);
  21. return true;
  22. }
  23. }
  24. mHasLifecycleMethods.put(klass, false);
  25. return false;
  26. }

而正是在 createInfo函数内部对被注解函数的入参类型、入参顺序、入参个数等进行了限制,当不符合规定时则会在运行时直接抛出异常

  1. //以下三个整数值用于标记被注解的函数的入参参数的个数
  2. //不包含入参参数
  3. private static final int CALL_TYPE_NO_ARG = 0;
  4. //包含一个入参参数
  5. private static final int CALL_TYPE_PROVIDER = 1;
  6. //包含两个入参参数
  7. private static final int CALL_TYPE_PROVIDER_WITH_EVENT = 2;
  8. private CallbackInfo createInfo(Class<?> klass, @Nullable Method[] declaredMethods) {
  9. Class<?> superclass = klass.getSuperclass();
  10. Map<MethodReference, Lifecycle.Event> handlerToEvent = new HashMap<>();
  11. if (superclass != null) {
  12. CallbackInfo superInfo = getInfo(superclass);
  13. if (superInfo != null) {
  14. handlerToEvent.putAll(superInfo.mHandlerToEvent);
  15. }
  16. }
  17. Class<?>[] interfaces = klass.getInterfaces();
  18. for (Class<?> intrfc : interfaces) {
  19. for (Map.Entry<MethodReference, Lifecycle.Event> entry : getInfo(
  20. intrfc).mHandlerToEvent.entrySet()) {
  21. verifyAndPutHandler(handlerToEvent, entry.getKey(), entry.getValue(), klass);
  22. }
  23. }
  24. Method[] methods = declaredMethods != null ? declaredMethods : getDeclaredMethods(klass);
  25. boolean hasLifecycleMethods = false;
  26. for (Method method : methods) {
  27. //找到包含 OnLifecycleEvent 注解的函数
  28. OnLifecycleEvent annotation = method.getAnnotation(OnLifecycleEvent.class);
  29. if (annotation == null) {
  30. continue;
  31. }
  32. hasLifecycleMethods = true;
  33. //以下的所有逻辑是这样的:
  34. //1. 获取 method 所对应的函数的参数个数和参数类型,即 params
  35. //2. 如果参数个数为 0,则 callType = CALL_TYPE_NO_ARG,method 不包含入参参数
  36. //3. 如果参数个数大于 0,则第一个参数必须是 LifecycleOwner 类型的对象,否则抛出异常
  37. //3.1、如果参数个数为 1,则 callType = CALL_TYPE_PROVIDER
  38. //3.2、如果参数个数为 2,则注解值 annotation 必须是 Lifecycle.Event.ON_ANY
  39. // 且第二个参数必须是 Lifecycle.Event 类型的对象,否则抛出异常
  40. // 如果一切都符合条件,则 callType = CALL_TYPE_PROVIDER_WITH_EVENT
  41. //3.3、如果参数个数大于 2,则抛出异常,即要求 method 最多包含两个参数,且对参数类型和参数顺序进行了限制
  42. Class<?>[] params = method.getParameterTypes();
  43. int callType = CALL_TYPE_NO_ARG;
  44. if (params.length > 0) {
  45. callType = CALL_TYPE_PROVIDER;
  46. if (!params[0].isAssignableFrom(LifecycleOwner.class)) {
  47. throw new IllegalArgumentException(
  48. "invalid parameter type. Must be one and instanceof LifecycleOwner");
  49. }
  50. }
  51. Lifecycle.Event event = annotation.value();
  52. if (params.length > 1) {
  53. callType = CALL_TYPE_PROVIDER_WITH_EVENT;
  54. if (!params[1].isAssignableFrom(Lifecycle.Event.class)) {
  55. throw new IllegalArgumentException(
  56. "invalid parameter type. second arg must be an event");
  57. }
  58. if (event != Lifecycle.Event.ON_ANY) {
  59. throw new IllegalArgumentException(
  60. "Second arg is supported only for ON_ANY value");
  61. }
  62. }
  63. if (params.length > 2) {
  64. throw new IllegalArgumentException("cannot have more than 2 params");
  65. }
  66. MethodReference methodReference = new MethodReference(callType, method);
  67. verifyAndPutHandler(handlerToEvent, methodReference, event, klass);
  68. }
  69. CallbackInfo info = new CallbackInfo(handlerToEvent);
  70. mCallbackMap.put(klass, info);
  71. mHasLifecycleMethods.put(klass, hasLifecycleMethods);
  72. return info;
  73. }

然后最终在 MethodReference 类内部的 invokeCallback() 函数完成最终的反射调用
MethodReference 用于缓存具有 OnLifecycleEvent 注解的函数(Method)以及该函数所具有的入参个数(知道了入参个数就知道了该如何进行反射调用),通过 invokeCallback() 函数来进行 Lifecycle.Event 事件通知

  1. static class MethodReference {
  2. final int mCallType;
  3. final Method mMethod;
  4. MethodReference(int callType, Method method) {
  5. mCallType = callType;
  6. mMethod = method;
  7. mMethod.setAccessible(true);
  8. }
  9. void invokeCallback(LifecycleOwner source, Lifecycle.Event event, Object target) {
  10. //noinspection TryWithIdenticalCatches
  11. //根据入参个数来传递特定的参数并进行反射回调
  12. //因此用 OnLifecycleEvent 进行注解的函数,其入参个数、入参类型、入参声明顺序都有固定的要求
  13. //当不符合要求时会导致反射失败从而抛出异常
  14. try {
  15. switch (mCallType) {
  16. case CALL_TYPE_NO_ARG:
  17. mMethod.invoke(target);
  18. break;
  19. case CALL_TYPE_PROVIDER:
  20. mMethod.invoke(target, source);
  21. break;
  22. case CALL_TYPE_PROVIDER_WITH_EVENT:
  23. mMethod.invoke(target, source, event);
  24. break;
  25. }
  26. } catch (InvocationTargetException e) {
  27. throw new RuntimeException("Failed to call observer method", e.getCause());
  28. } catch (IllegalAccessException e) {
  29. throw new RuntimeException(e);
  30. }
  31. }
  32. //省略无关函数
  33. ····
  34. }

总结

Lifecycle 的整个事件流程都在上文大致讲述完毕了,这里再来做下总结:

普通Activity

https://github.com/leavesC/AndroidGuide/blob/gitbook/jetpack/Lifecycle%E8%A1%8D%E7%94%9F.md

普通Activity
1. 依赖了android.arch.lifecycle:extensions,Activity只需要实现LifecycleOwner即可(为什么,下面会说明)

使用的时候,我们说过,普通Activity,依赖了android.arch.lifecycle:extensions,只需要实现LifecycleOwner,我们就可以监听生命周期变化呢?

LifecycleDispatcher

LifecycleDispatcher 的主要逻辑是用于向应用内所有 Activity 注入一个 ReportFragment,通过 ReportFragment 来辅助获取 Activity 的生命周期事件。
并由外部通过调用 init(Context) 方法来进行初始化

使用 registerActivityLifecycleCallbacks来监听 Activity 的最大优势就是它的涉及范围可以囊括应用的所有自定义 Activity 和使用到的依赖库中的所有第三方 Activity,大多数情况下我们是无法也不会去直接修改第三方依赖库中的代码,通过系统提供的方法我们才可以比较简单地向其注入一些自定义逻辑

  1. class LifecycleDispatcher {
  2. private static AtomicBoolean sInitialized = new AtomicBoolean(false);
  3. static void init(Context context) {
  4. //避免重复初始化
  5. if (sInitialized.getAndSet(true)) {
  6. return;
  7. }
  8. ((Application) context.getApplicationContext())
  9. .registerActivityLifecycleCallbacks(new DispatcherActivityCallback());
  10. }
  11. @SuppressWarnings("WeakerAccess")
  12. @VisibleForTesting
  13. static class DispatcherActivityCallback extends EmptyActivityLifecycleCallbacks {
  14. @Override
  15. public void onActivityCreated(Activity activity, Bundle savedInstanceState) {
  16. //当 Activity 被创建时,向其注入一个 ReportFragment(如果需要的话)
  17. ReportFragment.injectIfNeededIn(activity);
  18. }
  19. @Override
  20. public void onActivityStopped(Activity activity) {
  21. }
  22. @Override
  23. public void onActivitySaveInstanceState(Activity activity, Bundle outState) {
  24. }
  25. }
  26. private LifecycleDispatcher() {
  27. }
  28. }

ProcessLifecycleOwner

ProcessLifecycleOwner 是 LifecycleOwner的一个 实现类,可用于监听整个应用的前后台变化,内部维护resume和start的数量来判断Application的状态。
在一些场景下(比如消息推送时的跳转、数据埋点)是比较有用的

使用

ProcessLifecycleOwner 是单例模式,获取到其唯一实例后向其添加 Observer 即可。需要注意的是,ProcessLifecycleOwner 是依靠于应用内所有 Activity 的生命周期的变化来定义生命周期事件的,所以对于那些完全无 UI 界面的应用来说使用 ProcessLifecycleOwner 是没有意义的

  1. ProcessLifecycleOwner.get().lifecycle.addObserver(object : DefaultLifecycleObserver {
  2. override fun onCreate(owner: LifecycleOwner) {
  3. Log.e("TAG", "应用被启动")
  4. }
  5. override fun onResume(owner: LifecycleOwner) {
  6. Log.e("TAG", "应用进入前台")
  7. }
  8. override fun onStop(owner: LifecycleOwner) {
  9. Log.e("TAG", "应用进入后台")
  10. }
  11. })
源码

ProcessLifecycleOwner 实现了 LifecycleOwner 接口,也用到了 LifecycleRegistry 作为其生命周期实现。其构造函数是私有的,通过静态变量来实现单例模式

  1. public class ProcessLifecycleOwner implements LifecycleOwner {
  2. private final LifecycleRegistry mRegistry = new LifecycleRegistry(this);
  3. private static final ProcessLifecycleOwner sInstance = new ProcessLifecycleOwner();
  4. /**
  5. * The LifecycleOwner for the whole application process. Note that if your application
  6. * has multiple processes, this provider does not know about other processes.
  7. *
  8. * @return {@link LifecycleOwner} for the whole application.
  9. */
  10. @NonNull
  11. public static LifecycleOwner get() {
  12. return sInstance;
  13. }
  14. @NonNull
  15. @Override
  16. public Lifecycle getLifecycle() {
  17. return mRegistry;
  18. }
  19. }

开放了 init(Context)函数来由外部进行变量初始化,该方法的主要逻辑是这样的:

  1. static void init(Context context) {
  2. sInstance.attach(context);
  3. }
  4. void attach(Context context) {
  5. mHandler = new Handler();
  6. //因为 ProcessLifecycleOwner 是针对于对整个应用的生命周期的监听
  7. //会执行到这一步的话说明应用肯定被启动了,此时就到了 Lifecycle.Event.ON_CREATE
  8. //且由于 attach 方法只会被调用一次,所以外部也只会收到一次 Lifecycle.Event.ON_CREATE 事件
  9. mRegistry.handleLifecycleEvent(Lifecycle.Event.ON_CREATE);
  10. Application app = (Application) context.getApplicationContext();
  11. app.registerActivityLifecycleCallbacks(new EmptyActivityLifecycleCallbacks() {
  12. @Override
  13. public void onActivityCreated(Activity activity, Bundle savedInstanceState) {
  14. //在 LifecycleDispatcher 中已经为每个 Activity 注入了 ReportFragment
  15. //所以此处都可以成功获取到 ReportFragment 对象并设置回调事件
  16. ReportFragment.get(activity).setProcessListener(mInitializationListener);
  17. }
  18. @Override
  19. public void onActivityPaused(Activity activity) {
  20. activityPaused();
  21. }
  22. @Override
  23. public void onActivityStopped(Activity activity) {
  24. activityStopped();
  25. }
  26. });
  27. }

在onActivityCreated的时候,设置了一个mInitializationListener,而这个mInitializationListener在ReportFragment的生命周期改变的时候,都是会回调的。

  1. void activityStarted() {
  2. mStartedCounter++;
  3. if (mStartedCounter == 1 && mStopSent) {
  4. mRegistry.handleLifecycleEvent(Lifecycle.Event.ON_START);
  5. mStopSent = false;
  6. }
  7. }
  8. void activityResumed() {
  9. mResumedCounter++;
  10. if (mResumedCounter == 1) {
  11. if (mPauseSent) {
  12. mRegistry.handleLifecycleEvent(Lifecycle.Event.ON_RESUME);
  13. mPauseSent = false;
  14. } else {
  15. mHandler.removeCallbacks(mDelayedPauseRunnable);
  16. }
  17. }
  18. }
  19. void activityPaused() {
  20. mResumedCounter--;
  21. if (mResumedCounter == 0) {
  22. mHandler.postDelayed(mDelayedPauseRunnable, TIMEOUT_MS);
  23. }
  24. }
  25. void activityStopped() {
  26. mStartedCounter--;
  27. dispatchStopIfNeeded();
  28. }
  29. private void dispatchPauseIfNeeded() {
  30. if (mResumedCounter == 0) {
  31. mPauseSent = true;
  32. mRegistry.handleLifecycleEvent(Lifecycle.Event.ON_PAUSE);
  33. }
  34. }
  35. private void dispatchStopIfNeeded() {
  36. if (mStartedCounter == 0 && mPauseSent) {
  37. mRegistry.handleLifecycleEvent(Lifecycle.Event.ON_STOP);
  38. mStopSent = true;
  39. }
  40. }

这里需要注意的是,activityPaused的时候是有一个700ms的延迟的,主要为了解决:
应用还保持在前台,但由于用户旋转了屏幕导致 Activity 处于重建中。所以为了避免由于第一种情况导致误判,此处会通过 Handler 来发送一个延迟消息,在 700 毫秒后(等待 Activity 重建完成)再来进行检查是否真的需要发布 ON_PAUSE 事件

ProcessLifecycleOwnerInitializer

LifecycleDispatcher 和 ProcessLifecycleOwner 两个类都需要外部传入 Context 对象以便进行初始化,但我们在使用时其实是不需要手动初始化的,这是为什么呢?

  • Lifecycle使用ProcessLifecycleOwnerInitializer来初始化ProcessLifecycleOwner,ProcessLifecycleOwnerInitializer继承自ContentProvider,利用ContentProvider会在Application初始时同时初始化的特点,在ProcessLifecycleOwnerInitializer的onCreate方法中,将Application对象绑定到ProcessLifecycleOwner中
  • 并且在android.arch.lifecycle:extensions的AndroidManifest.xml文件也包含了对 ProcessLifecycleOwnerInitializer 的声明,在打包时会自动将声明语句合并到主项目工程中的 AndroidManifest.xml 文件中

这样就实现了,在不修改Application的情况下进行绑定

  1. public class ProcessLifecycleOwnerInitializer extends ContentProvider {
  2. @Override
  3. public boolean onCreate() {
  4. LifecycleDispatcher.init(getContext());
  5. ProcessLifecycleOwner.init(getContext());
  6. return true;
  7. }
  8. @Nullable
  9. @Override
  10. public Cursor query(@NonNull Uri uri, String[] strings, String s, String[] strings1,
  11. String s1) {
  12. return null;
  13. }
  14. @Nullable
  15. @Override
  16. public String getType(@NonNull Uri uri) {
  17. return null;
  18. }
  19. @Nullable
  20. @Override
  21. public Uri insert(@NonNull Uri uri, ContentValues contentValues) {
  22. return null;
  23. }
  24. @Override
  25. public int delete(@NonNull Uri uri, String s, String[] strings) {
  26. return 0;
  27. }
  28. @Override
  29. public int update(@NonNull Uri uri, ContentValues contentValues, String s, String[] strings) {
  30. return 0;
  31. }
  32. }
  1. <manifest xmlns:android="http://schemas.android.com/apk/res/android"
  2. package="androidx.lifecycle.process" >
  3. <uses-sdk
  4. android:minSdkVersion="14"
  5. android:targetSdkVersion="28" />
  6. <application>
  7. <provider
  8. android:name="androidx.lifecycle.ProcessLifecycleOwnerInitializer"
  9. android:authorities="${applicationId}.lifecycle-process"
  10. android:exported="false"
  11. android:multiprocess="true" />
  12. </application>
  13. </manifest>

总结

WHY(扩展,为什么这么实现?有没有更好的方式?)

为什么不直接在SupportActivity的生命周期函数中给Lifecycle分发生命周期事件,而是要加一个Fragment呢?

  1. public static void injectIfNeededIn(Activity activity) {
  2. // ProcessLifecycleOwner should always correctly work and some activities may not extend
  3. // FragmentActivity from support lib, so we use framework fragments for activities
  4. android.app.FragmentManager manager = activity.getFragmentManager();
  5. if (manager.findFragmentByTag(REPORT_FRAGMENT_TAG) == null) {
  6. manager.beginTransaction().add(new ReportFragment(), REPORT_FRAGMENT_TAG).commit();
  7. // Hopefully, we are the first to make a transaction.
  8. manager.executePendingTransactions();
  9. }
  10. }

看注释可知:

为什么用ReportFragment分发生命周期而不直接使用Activity#ActivityLifecycleCallbacks的回调来处理Lifecycle生命周期的变化?

新版本已经使用Activity#ActivityLifecycleCallbacks,区分Android版本,如下:

  1. public class ReportFragment extends Fragment {
  2. public static void injectIfNeededIn(Activity activity) {
  3. // 如果是 Android 10 版本或者以上
  4. // 则通过 registerActivityLifecycleCallbacks 的方式来实现生命周期的回调
  5. if (Build.VERSION.SDK_INT >= 29) {
  6. // On API 29+, we can register for the correct Lifecycle callbacks directly
  7. activity.registerActivityLifecycleCallbacks(
  8. new LifecycleCallbacks());
  9. }
  10. // 往页面添加一个空的 Fragment,在 Fragment 的生命周期方法中分发事件
  11. android.app.FragmentManager manager = activity.getFragmentManager();
  12. if (manager.findFragmentByTag(REPORT_FRAGMENT_TAG) == null) {
  13. manager.beginTransaction().add(new ReportFragment(), REPORT_FRAGMENT_TAG).commit();
  14. manager.executePendingTransactions();
  15. }
  16. }
  17. }

对于 Lifecycle.Event 为啥不直接分发,而是通过 Lifecycle.State 中转?

Event-->State-->Event
Activity/Fragment-->LifecycleRegistry-->Obserever

保证一致性,需要根据Event来判断State的走向

每一个Activity都会被注入一个ReportFragment?

这个需要区分系统版本了来看:

Event和State到底什么区别?

FastSafeIterableMap

https://juejin.cn/post/6844904061519544334

保证添加的Observer按照插入顺序,State从大到小的顺序排列。
例如,o1,o2,o3顺序插入,则o1.state >= o2.state >= o3.state

参考

http://liuwangshu.cn/application/jetpack/2-lifecycle-use.html
https://juejin.cn/post/6844903977788801032
https://blog.kyleduo.com/2019/01/17/lifecycle-source-code/
https://zhich.github.io/2018/11/06/Android-Jetpack-%E4%B9%8B-LifeCycle/
https://github.com/leavesC/AndroidGuide/blob/gitbook/jetpack/Lifecycle%E6%BA%90%E7%A0%81%E8%A7%A3%E6%9E%90.md
https://juejin.cn/post/6844904061519544334

添加新批注
在作者公开此批注前,只有你和作者可见。
回复批注