RxFluxArchitecture框架介紹2-生命週期與訂閱管理

摘要： 引言 在上一篇RxFluxArchitecture框架介紹1-基本功能實現中介紹過 Store 自動關聯 View 生命週期。 View，Store 自動註冊訂閱、取消訂閱。 這裡講下具體實現原理。 生命週期圖 ...

引言

在上一篇 RxFluxArchitecture框架介紹1-基本功能實現 中介紹過

• Store 自動關聯 View 生命週期。
• View，Store 自動註冊訂閱、取消訂閱。

這裡講下具體實現原理。

生命週期圖

原理

1. RxApp 繼承自 Application ，在 onCreate() 方法時呼叫 registerActivityLifecycleCallbacks(ActivityLifecycleCallbacks) 方法，使 RxFlux 可以接受 Activity 生命週期回撥。

@Override
public void onCreate() {
super.onCreate();
registerActivityLifecycleCallbacks(mRxFlux);
}

2. RxFlux 在 Activity 建立時，方法 onActivityCreated(Activity,Bundle) 會被呼叫。

   該方法中呼叫 addObserver(LifecycleObserver) 方法，使 Activity 生命週期訂閱類 RxActivityLifecycleObserver 關聯當前 Activity 生命週期。

   呼叫 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);
}
}

3. 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));
}

4. 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);
}
}
}

5. RxActivityStore 或 RxFragmentStore 繼承 ViewModel ，實現 LifecycleObserver ，響應 Lifecycle.Event.ON_CREATE 事件，註冊訂閱，可以接收 EventBus 傳送的通知。

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

6. RxFlux 在 Activity 或 Fragment onResume 狀態時，使 Activity 或 Fragment 註冊訂閱，使其可以接收 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);
}
}

7. RxFlux 在 Activity 或 Fragment onPause 狀態時，使 Activity 或 Fragment 取消訂閱，使其不再接收 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);
}
}

8. RxActivityStore 或 RxFragmentStore ，響應 Lifecycle.Event.ON_DESTROY 事件，取消訂閱，不再接收 EventBus 傳送的通知。

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

原始碼

在開源模組化框架 RxFluxArchitecture 中，歡迎大家指正點贊。可以提取有用的程式碼，單獨編寫！