Lifecycle 使用和源码原理解析

一、Lifecycle是什么?

JetPack.Lifecycle能够监听Activity/Fragment生命周期行为的各种变化

下面是Lifecycle的重要细节:

Lifecycle可以有效的避免内存泄漏和解决android生命周期的常见难题 
Livecycle 是一个表示android生命周期及状态的对象 
LivecycleOwner 用于连接有生命周期的对象,如activity,fragment 
LivecycleObserver 用于观察查LifecycleOwner 
Lifecycle框架使用观察者模式实现观察者监听被观察者的生命周期的变化

二、用法

1、添加依赖

(1)如果项目使用的是androidX

 dependencies {
    def lifecycle_version = "2.4.0"
    def arch_version = "2.1.0"

    // ViewModel
    implementation "androidx.lifecycle:lifecycle-viewmodel:$lifecycle_version"
    // LiveData
    implementation "androidx.lifecycle:lifecycle-livedata:$lifecycle_version"
    // 只有Lifecycles (不带 ViewModel or LiveData)
    implementation "androidx.lifecycle:lifecycle-runtime:$lifecycle_version"

    // Saved state module for ViewModel
    implementation "androidx.lifecycle:lifecycle-viewmodel-savedstate:$lifecycle_version"

    // lifecycle注解处理器
    annotationProcessor "androidx.lifecycle:lifecycle-compiler:$lifecycle_version"
    // 替换 - 如果使用Java8,就用这个替换上面的lifecycle-compiler
    implementation "androidx.lifecycle:lifecycle-common-java8:$lifecycle_version"

    //以下按需引入
    // 可选 - 帮助实现Service的LifecycleOwner
    implementation "androidx.lifecycle:lifecycle-service:$lifecycle_version"
    // 可选 - ProcessLifecycleOwner给整个 app进程 提供一个lifecycle
    implementation "androidx.lifecycle:lifecycle-process:$lifecycle_version"
    // 可选 - ReactiveStreams support for LiveData
    implementation "androidx.lifecycle:lifecycle-reactivestreams:$lifecycle_version"
    // 可选 - Test helpers for LiveData
    testImplementation "androidx.arch.core:core-testing:$arch_version"


// 这种依赖支持是 精简版本
// implementation "androidx.lifecycle:lifecycle-runtime:2.0.0" 
// implementation "androidx.lifecycle:lifecycle-extensions:2.0.0" 
// implementation "androidx.lifecycle:lifecycle-common-java8:2.0.0" 
// annotationProcessor "androidx.lifecycle:lifecycle-compiler:2.0.0"*/
}

(2)如果项目使用的是非androidX,那就需使用lifecycle android.arch.lifecycle库

 dependencies {
    def lifecycle_version = "1.1.1"

    // 包含ViewModel和LiveData
    implementation "android.arch.lifecycle:extensions:$lifecycle_version"
    // 仅仅包含ViewModel
    implementation "android.arch.lifecycle:viewmodel:$lifecycle_version"
    // 仅仅包含LiveData
    implementation "android.arch.lifecycle:livedata:$lifecycle_version"
    // 仅仅包含Lifecycles
    implementation "android.arch.lifecycle:runtime:$lifecycle_version"

    // For Kotlin use kapt instead of annotationProcessor
    // annotationProcessor "android.arch.lifecycle:compiler:$lifecycle_version" 

    // 如果用Java8, 用于替代compiler
    // implementation "android.arch.lifecycle:common-java8:$lifecycle_version" // 这个不行
    // implementation 'androidx.lifecycle:lifecycle-common-java8:2.2.0'

    // 可选,ReactiveStreams对LiveData的支持
    implementation "android.arch.lifecycle:reactivestreams:$lifecycle_version"

    // 可选,LiveData的测试
    testImplementation "android.arch.core:core-testing:$lifecycle_version"

    // 除此之外,不要忘了在build.gradle添加 "androidx.lifecycle:common-java8:<version>"
    implementation "androidx.lifecycle:common-java8:1.1.1"

    implementation "android.arch.lifecycle:extensions:1.1.1"
}

2、使用

(1)使用1: 继承LifecycleObserver接口,自定义方法,方法上添加@OnLifecycleEvent注解

override fun onCreate(savedInstanceState: Bundle?) {
    super.onCreate(savedInstanceState)
    setContentView(R.layout.activity_main)

    lifecycle.addObserver(MyLifecycleObserver())
}

// 监听activity的生命周期
class MyLifecycleObserver : LifecycleObserver {
    private val TAG = MyLifecycleObserver::class.java.simpleName

    // 方法名可以自由定义,需要添加@OnLifecycleEvent注解
    @OnLifecycleEvent(Lifecycle.Event.ON_CREATE)
    fun myCreate() = Log.e(TAG, "myCreate: ")

    @OnLifecycleEvent(Lifecycle.Event.ON_START)
    fun myStart() = Log.e(TAG, "myStart: ")

    @OnLifecycleEvent(Lifecycle.Event.ON_RESUME)
    fun myResume() = Log.e(TAG, "myResume: ")

    @OnLifecycleEvent(Lifecycle.Event.ON_PAUSE)
    fun myPause() = Log.e(TAG, "myPause: ")

    @OnLifecycleEvent(Lifecycle.Event.ON_STOP)
    fun myStop() = Log.e(TAG, "myStop: ")
}

(2)使用2: 继承DefaultLifecycleObserver接口,实现对应的方法。

    override fun onCreate(savedInstanceState: Bundle?) {
        super.onCreate(savedInstanceState)
        setContentView(R.layout.activity_main)

        lifecycle.addObserver(object : DefaultLifecycleObserver {
            override fun onCreate(owner: LifecycleOwner) {
                Log.d(TAG, "onCreate: ")
            }

            override fun onStart(owner: LifecycleOwner) {
                Log.d(TAG, "onStart: ")
            }

            override fun onResume(owner: LifecycleOwner) {
                Log.d(TAG, "onResume: ")
            }

            override fun onPause(owner: LifecycleOwner) {
                Log.d(TAG, "onPause: ")
            }

            override fun onStop(owner: LifecycleOwner) {
                Log.d(TAG, "onStop: ")
            }

            override fun onDestroy(owner: LifecycleOwner) {
                Log.d(TAG, "onDestroy: ")
            }
        })
    }

三、源码解析

AppCompatActivity继承自FragmentActivity,而FragmentActivity又继承自ComponentActivity,ComponentActivity实现了LifecycleOwner接口。

ComponentActivity.create()
--> ReportFragment.injectIfNeededIn(this);
        // 创建了一个ReportFragment,与activity的生命保持一致。以此来监听activity的生命周期
    --> android.app.FragmentManager manager = activity.getFragmentManager();
        if (manager.findFragmentByTag(REPORT_FRAGMENT_TAG) == null) {
            manager.beginTransaction().add(new ReportFragment(), REPORT_FRAGMENT_TAG).commit();
            manager.executePendingTransactions();
        }

1、首先我们需要了解到有五大状态:DESTROYED(销毁状态)、INITIALIZED(初始状态)、CREATED(创建状态)、STARTED(启动状态)、RESUMED(可见状态)
以被观察者(activity)的生命周期驱动观察者(状态)的变化,来达到观察者中保存的状态和被观察者的生命周期保持一致。

2、接下来,我们代码分析下流程。

// lifecycle是在ComponentActivity实现的。lifecycle = LifecycleRegistry()
lifecycle.addObserver(MyLifecycleObserver())@MainActivity
    // 初始化状态,如果是非销毁状态,就初始化状态为INITIALIZED
--> State initialState = mState == DESTROYED ? DESTROYED : INITIALIZED;@LifecycleRegistry
    // observer 作为参数传入ObserverWithState
    ObserverWithState statefulObserver = new ObserverWithState(observer, initialState);
        // observer 继续传
    --> mLifecycleObserver = Lifecycling.lifecycleEventObserver(observer);
            // object 就是 observer。ReflectiveGenericLifecycleObserver这个类要记住,后面要用到。。。。。。。
        --> return new ReflectiveGenericLifecycleObserver(object);
                // mWrapped 就是 observer
            --> mWrapped = wrapped;
                // 获取到observer的class。
            --> mInfo = ClassesInfoCache.sInstance.getInfo(mWrapped.getClass());
    sync();
    // 如果观察者、被观察者的状态不一致,那就去同步状态
    -->  while (!isSynced()) {
            mNewEventOccurred = false;
            // 被观察者的状态比观察者中的状态要小,说明是逆操作,往后走
            if (mState.compareTo(mObserverMap.eldest().getValue().mState) < 0) {
                backwardPass(lifecycleOwner);
                    // 再次校验,如果观察者中的状态比被观察者的要大,继续执行
                --> while ((observer.mState.compareTo(mState) > 0 && !mNewEventOccurred && mObserverMap.contains(entry.getKey()))) {
                        // 事件回流。通过观察者中的状态,获取到事件。下面再分析
                        Event event = Event.downFrom(observer.mState);
                        if (event == null) {
                            throw new IllegalStateException("no event down from " + observer.mState);
                        }
                        
                        pushParentState(event.getTargetState());
                        // 上面获取到事件后,就去分发事件
                        observer.dispatchEvent(lifecycleOwner, event);
                            // mLifecycleObserver就是上面的ReflectiveGenericLifecycleObserver
                        --> mLifecycleObserver.onStateChanged(owner, event);
                            --> mInfo.invokeCallbacks(source, event, mWrapped);
                                --> invokeMethodsForEvent(mEventToHandlers.get(event), source, event, target);
                                    invokeMethodsForEvent(mEventToHandlers.get(Lifecycle.Event.ON_ANY), source, event, target);
                                    --> handlers.get(i).invokeCallback(source, event, mWrapped);
                                            // 反射执行对应的方法
                                        --> mMethod.invoke(target);
                        popParentState();
                    }
            }
            Map.Entry<LifecycleObserver, ObserverWithState> newest = mObserverMap.newest();
            // 被观察者的状态比观察者中的状态要大,说明是正操作,往前走
            if (!mNewEventOccurred && newest != null && mState.compareTo(newest.getValue().mState) > 0) {
                forwardPass(lifecycleOwner);
                    // 再次校验,如果观察者中的状态比被观察者的要小,继续执行
                --> while ((observer.mState.compareTo(mState) < 0 && !mNewEventOccurred && mObserverMap.contains(entry.getKey()))) {
                        pushParentState(observer.mState);
                        // 事件正流。通过观察者中的状态,获取到事件。下面再分析
                        final Event event = Event.upFrom(observer.mState);
                        if (event == null) {
                            throw new IllegalStateException("no event up from " + observer.mState);
                        }
                        // 上面获取到事件后,就去分发事件。后面的逻辑与上面一样。
                        observer.dispatchEvent(lifecycleOwner, event);
                        popParentState();
                    }            
            }
        }

3、上面分析到,被观察者的状态发生变化,导致观察者的状态也发生响应的变化。继而观察者再通过比较上一次和当前的状态,获取出当前应该执行的事件。
我们来画个流程图来分析。

绿色部分是状态
红色路径是正操作
蓝色路径是反操作

状态驱动事件流程图

通过前进状态获取到事件:

public static Event upFrom(@NonNull State state) {
    switch (state) {
        case INITIALIZED:
            return ON_CREATE;
        case CREATED:
            return ON_START;
        case STARTED:
            return ON_RESUME;
        default:
            return null;
    }
}

通过后退状态获取到事件:

public static Event downFrom(@NonNull State state) {
    switch (state) {
        case CREATED:
            return ON_DESTROY;
        case STARTED:
            return ON_STOP;
        case RESUMED:
            return ON_PAUSE;
        default:
            return null;
    }
}

4、上面分析了在设置监听时,去同步状态的流程。其实当framgment的生命周期发生变化的执行,也是类似的。以onStart为例。

ReportFragment.onStart() {
--> dispatch(getActivity(), event);
    --> ((LifecycleRegistry) lifecycle).handleLifecycleEvent(event);
        --> moveToState(event.getTargetState());
                // 如果状态一致,直接return,不执行
            --> if (mState == next) {
                   return;
                }
                mState = next;
                
                mHandlingEvent = true;
                //这个代码是不是又似曾相识,跟上面的一样
                sync();
                mHandlingEvent = false;

最后编辑于
©著作权归作者所有,转载或内容合作请联系作者
  • 序言:七十年代末,一起剥皮案震惊了整个滨河市,随后出现的几起案子,更是在滨河造成了极大的恐慌,老刑警刘岩,带你破解...
    沈念sama阅读 215,463评论 6 497
  • 序言:滨河连续发生了三起死亡事件,死亡现场离奇诡异,居然都是意外死亡,警方通过查阅死者的电脑和手机,发现死者居然都...
    沈念sama阅读 91,868评论 3 391
  • 文/潘晓璐 我一进店门,熙熙楼的掌柜王于贵愁眉苦脸地迎上来,“玉大人,你说我怎么就摊上这事。” “怎么了?”我有些...
    开封第一讲书人阅读 161,213评论 0 351
  • 文/不坏的土叔 我叫张陵,是天一观的道长。 经常有香客问我,道长,这世上最难降的妖魔是什么? 我笑而不...
    开封第一讲书人阅读 57,666评论 1 290
  • 正文 为了忘掉前任,我火速办了婚礼,结果婚礼上,老公的妹妹穿的比我还像新娘。我一直安慰自己,他们只是感情好,可当我...
    茶点故事阅读 66,759评论 6 388
  • 文/花漫 我一把揭开白布。 她就那样静静地躺着,像睡着了一般。 火红的嫁衣衬着肌肤如雪。 梳的纹丝不乱的头发上,一...
    开封第一讲书人阅读 50,725评论 1 294
  • 那天,我揣着相机与录音,去河边找鬼。 笑死,一个胖子当着我的面吹牛,可吹牛的内容都是我干的。 我是一名探鬼主播,决...
    沈念sama阅读 39,716评论 3 415
  • 文/苍兰香墨 我猛地睁开眼,长吁一口气:“原来是场噩梦啊……” “哼!你这毒妇竟也来了?” 一声冷哼从身侧响起,我...
    开封第一讲书人阅读 38,484评论 0 270
  • 序言:老挝万荣一对情侣失踪,失踪者是张志新(化名)和其女友刘颖,没想到半个月后,有当地人在树林里发现了一具尸体,经...
    沈念sama阅读 44,928评论 1 307
  • 正文 独居荒郊野岭守林人离奇死亡,尸身上长有42处带血的脓包…… 初始之章·张勋 以下内容为张勋视角 年9月15日...
    茶点故事阅读 37,233评论 2 331
  • 正文 我和宋清朗相恋三年,在试婚纱的时候发现自己被绿了。 大学时的朋友给我发了我未婚夫和他白月光在一起吃饭的照片。...
    茶点故事阅读 39,393评论 1 345
  • 序言:一个原本活蹦乱跳的男人离奇死亡,死状恐怖,灵堂内的尸体忽然破棺而出,到底是诈尸还是另有隐情,我是刑警宁泽,带...
    沈念sama阅读 35,073评论 5 340
  • 正文 年R本政府宣布,位于F岛的核电站,受9级特大地震影响,放射性物质发生泄漏。R本人自食恶果不足惜,却给世界环境...
    茶点故事阅读 40,718评论 3 324
  • 文/蒙蒙 一、第九天 我趴在偏房一处隐蔽的房顶上张望。 院中可真热闹,春花似锦、人声如沸。这庄子的主人今日做“春日...
    开封第一讲书人阅读 31,308评论 0 21
  • 文/苍兰香墨 我抬头看了看天上的太阳。三九已至,却和暖如春,着一层夹袄步出监牢的瞬间,已是汗流浃背。 一阵脚步声响...
    开封第一讲书人阅读 32,538评论 1 268
  • 我被黑心中介骗来泰国打工, 没想到刚下飞机就差点儿被人妖公主榨干…… 1. 我叫王不留,地道东北人。 一个月前我还...
    沈念sama阅读 47,338评论 2 368
  • 正文 我出身青楼,却偏偏与公主长得像,于是被迫代替她去往敌国和亲。 传闻我的和亲对象是个残疾皇子,可洞房花烛夜当晚...
    茶点故事阅读 44,260评论 2 352

推荐阅读更多精彩内容