模塊化解耦框架RxFluxArchitecture3-訂閱管理綁定生命週期

相關係列文章

模塊化解耦框架RxFluxArchitecture1-框架簡介

模塊化解耦框架RxFluxArchitecture2-基本功能實現

模塊化解耦框架RxFluxArchitecture3-訂閱管理綁定生命週期

模塊化解耦框架RxFluxArchitecture4-依賴庫與依賴注入

模塊化解耦框架RxFluxArchitecture5-Application多模塊共存

引言

模塊化解耦框架 RxFluxArchitecture 中訂閱管理自動綁定生命週期

• Store 實現androidx.lifecycle.LifecycleObserver，自動關聯 View 生命週期。
• View、Store 跟隨 View 生命週期自動註冊訂閱、取消訂閱。

生命週期圖

一、RxFlux接受 View 生命週期回調

1.一、RxFlux接受 Activity 生命週期回調

RxApp繼承自Application，在onCreate()方法時調用registerActivityLifecycleCallbacks(ActivityLifecycleCallbacks)方法，使RxFlux能夠接受 Activity 生命週期回調。

@Override
    public void onCreate() {
        super.onCreate();
        registerActivityLifecycleCallbacks(mRxFlux);
    }
複製代碼

1.二、RxFlux接受 Fragment 生命週期回調

RxFlux在 Activity 建立時，方法onActivityCreated(Activity,Bundle)會被回調。調用registerFragmentLifecycleCallbacks(FragmentLifecycleCallbacks,boolean)方法，使RxFlux能夠接受當前 Activity 管理的 Fragment 生命週期回調。

@Override
    public void onActivityCreated(Activity activity, Bundle bundle) {
        mActivityCounter++;
        mActivityStack.add(activity);
        if (activity instanceof FragmentActivity) {
            ((FragmentActivity) activity).getLifecycle()
                    .addObserver(new RxActivityLifecycleObserver(activity));
            ((FragmentActivity) activity).getSupportFragmentManager()
                    .registerFragmentLifecycleCallbacks(this, true);
        }
    }
複製代碼

二、Store 關聯 View 生命週期

2.一、RxActivityLifecycleObserver關聯 Activity 生命週期

RxFlux在 Activity 建立時，方法onActivityCreated(Activity,Bundle)會被回調。調用addObserver(LifecycleObserver)方法，使 Activity 生命週期訂閱類RxActivityLifecycleObserver關聯當前 Activity 生命週期。

@Override
    public void onActivityCreated(Activity activity, Bundle bundle) {
        mActivityCounter++;
        mActivityStack.add(activity);
        if (activity instanceof FragmentActivity) {
            ((FragmentActivity) activity).getLifecycle()
                    .addObserver(new RxActivityLifecycleObserver(activity));
            ((FragmentActivity) activity).getSupportFragmentManager()
                    .registerFragmentLifecycleCallbacks(this, true);
        }
    }
複製代碼

2.二、RxFragmentLifecycleObserver關聯 Fragment 生命週期

RxFlux在 Fragment 關聯當前 Activity 時，方法onFragmentAttached(FragmentManager,Fragment,Context)會被回調。 調用addObserver(LifecycleObserver)方法，使 Fragment 生命週期訂閱類RxFragmentLifecycleObserver關聯當前 Fragment 生命週期。

@Override
    public void onFragmentAttached(@NonNull FragmentManager fm, @NonNull Fragment f, @NonNull Context context) {
        super.onFragmentAttached(fm, f, context);
        f.getLifecycle().addObserver(new RxFragmentLifecycleObserver(f));
    }
複製代碼

2.三、RxActivityStore或RxFragmentStore關聯 Activity 或 Fragment 生命週期

RxActivityLifecycleObserver或RxFragmentLifecycleObserver在 Activity 或 Fragment 建立以後（建立時完成依賴注入操做），響應Lifecycle.Event.ON_CREATE事件，獲取 Activity 或 Fragment 中的 RxActivityStore或RxFragmentStore，並將其關聯到 Activity 或 Fragment 生命週期。

@OnLifecycleEvent(Lifecycle.Event.ON_CREATE)
    void onCreate() {
        if (mActivity instanceof RxFluxView) {
            ViewModel rxStore = ((RxFluxView) mActivity).getRxStore();
            if (rxStore instanceof RxActivityStore) {
                //rxStore關聯activity生命週期
                ((FragmentActivity) mActivity).getLifecycle().addObserver((RxActivityStore) rxStore);
            }
        }
    }
複製代碼

@OnLifecycleEvent(Lifecycle.Event.ON_CREATE)
    void onCreate() {
        if (mFragment instanceof RxFluxView) {
            ViewModel rxStore = ((RxFluxView) mFragment).getRxStore();
            if (rxStore instanceof RxFragmentStore) {
                //rxStore關聯Fragment生命週期
                mFragment.getLifecycle().addObserver((RxFragmentStore) rxStore);
            }
        }
    }
複製代碼

三、Store 註冊訂閱

RxActivityStore或RxFragmentStore繼承ViewModel，實現LifecycleObserver，響應Lifecycle.Event.ON_CREATE事件，註冊訂閱，能夠接收數據總線庫core-eventbus 發送的通知。

@OnLifecycleEvent(Lifecycle.Event.ON_CREATE)
    public void subscribe() {
        if (mRxDispatcher.isSubscribe(this)) {
            return;
        }
        Log.i(RxFlux.TAG, "Subscribe RxFragmentStore : " + getClass().getSimpleName());
        mRxDispatcher.subscribeRxStore(this);
    }
複製代碼

四、View 註冊訂閱

RxFlux在 Activity 或 Fragment onResume狀態時，使 Activity 或 Fragment 註冊訂閱，使其能夠接收數據總線庫core-eventbus發送的通知。

@Override
    public void onActivityResumed(Activity activity) {
        if (activity instanceof RxSubscriberView) {
            if (mRxDispatcher.isSubscribe(this)) {
                return;
            }
            Log.i(TAG, "Subscribe RxFluxActivity : " + activity.getClass().getSimpleName());
            mRxDispatcher.subscribeRxView((RxSubscriberView) activity);
        }
    }

    @Override
    public void onFragmentResumed(@NonNull FragmentManager fm, @NonNull Fragment f) {
        super.onFragmentResumed(fm, f);
        if (f instanceof RxSubscriberView) {
            if (mRxDispatcher.isSubscribe(this)) {
                return;
            }
            Log.i(TAG, "Subscribe RxFluxFragment : " + f.getClass().getSimpleName());
            mRxDispatcher.subscribeRxView((RxSubscriberView) f);
        }
    }
複製代碼

五、View 取消訂閱

RxFlux在 Activity 或 Fragment onPause狀態時，使 Activity 或 Fragment 取消訂閱，使其再也不接收數據總線庫core-eventbus發送的通知。

@Override
    public void onActivityPaused(Activity activity) {
        if (activity instanceof RxSubscriberView) {
            Log.i(TAG, "Unsubscribe RxFluxActivity : " + activity.getClass().getSimpleName());
            mRxDispatcher.unsubscribeRxView((RxSubscriberView) activity);
        }
    }

    @Override
    public void onFragmentPaused(@NonNull FragmentManager fm, @NonNull Fragment f) {
        super.onFragmentPaused(fm, f);
        if (f instanceof RxSubscriberView) {
            Log.i(TAG, "Unsubscribe RxFluxFragment : " + f.getClass().getSimpleName());
            mRxDispatcher.unsubscribeRxView((RxSubscriberView) f);
        }
    }
複製代碼

六、Store 取消訂閱

RxActivityStore或RxFragmentStore，響應Lifecycle.Event.ON_DESTROY事件，取消訂閱，再也不接收數據總線庫core-eventbus發送的通知。

@OnLifecycleEvent(Lifecycle.Event.ON_DESTROY)
    public void unsubscribe() {
        Log.i(RxFlux.TAG, "Unsubscribe RxFragmentStore : " + getClass().getSimpleName());
        mRxDispatcher.unsubscribeRxStore(this);
    }
複製代碼

源碼

開源模塊化解耦框架RxFluxArchitecture，歡迎你們點贊Fork，更歡迎點評指導。