拆分核心代码,方便代码阅读,LogisticsCenter拆分成RouteCenter,ServiceCenter,InterceptorCenter,EventCenter

Author: wyjsonGo

GoRouter-Api/src/main/java/com/wyjson/router/GoRouter.java

@@ -24,9 +24,12 @@
 import com.wyjson.router.callback.GoCallback;
 import com.wyjson.router.callback.InterceptorCallback;
 import com.wyjson.router.core.ApplicationModuleCenter;
+import com.wyjson.router.core.EventCenter;
+import com.wyjson.router.core.InterceptorCenter;
 import com.wyjson.router.core.InterceptorServiceImpl;
-import com.wyjson.router.core.LogisticsCenter;
+import com.wyjson.router.core.RouteCenter;
 import com.wyjson.router.core.RouteModuleCenter;
+import com.wyjson.router.core.ServiceCenter;
 import com.wyjson.router.core.interfaces.IInterceptorService;
 import com.wyjson.router.exception.NoFoundRouteException;
 import com.wyjson.router.exception.RouterException;
@@ -52,8 +55,8 @@ public final class GoRouter {
     private volatile static boolean isDebug = false;
 
     private GoRouter() {
-        LogisticsCenter.clearInterceptors();
-        LogisticsCenter.addService(InterceptorServiceImpl.class);
+        InterceptorCenter.clearInterceptors();
+        ServiceCenter.addService(InterceptorServiceImpl.class);
     }
 
     private static class InstanceHolder {
@@ -156,7 +159,7 @@ public static void registerAM(Class<? extends IApplicationModule> am) {
      * @param service 实现类.class
      */
     public void addService(Class<? extends IService> service) {
-        LogisticsCenter.addService(service);
+        ServiceCenter.addService(service);
     }
 
     /**
@@ -168,7 +171,7 @@ public void addService(Class<? extends IService> service) {
      */
     @Nullable
     public <T> T getService(Class<? extends T> service) {
-        return LogisticsCenter.getService(service);
+        return ServiceCenter.getService(service);
     }
 
     /**
@@ -178,7 +181,7 @@ public <T> T getService(Class<? extends T> service) {
      * @param interceptor
      */
     public void addInterceptor(int ordinal, Class<? extends IInterceptor> interceptor) {
-        LogisticsCenter.addInterceptor(ordinal, interceptor, false);
+        InterceptorCenter.addInterceptor(ordinal, interceptor, false);
     }
 
     /**
@@ -188,14 +191,14 @@ public void addInterceptor(int ordinal, Class<? extends IInterceptor> intercepto
      * @param interceptor
      */
     public void setInterceptor(int ordinal, Class<? extends IInterceptor> interceptor) {
-        LogisticsCenter.setInterceptor(ordinal, interceptor);
+        InterceptorCenter.setInterceptor(ordinal, interceptor);
     }
 
     /**
      * 动态添加路由分组,按需加载路由
      */
     public void addRouterGroup(String group, IRouteModuleGroup routeModuleGroup) {
-        LogisticsCenter.addRouterGroup(group, routeModuleGroup);
+        RouteCenter.addRouterGroup(group, routeModuleGroup);
     }
 
     private void runInMainThread(Runnable runnable) {
@@ -224,7 +227,7 @@ public Card build(Uri uri) {
      * @param activity
      */
     public String getRawURI(Activity activity) {
-        return LogisticsCenter.getRawURI(activity);
+        return RouteCenter.getRawURI(activity);
     }
 
     /**
@@ -233,7 +236,7 @@ public String getRawURI(Activity activity) {
      * @param fragment
      */
     public String getRawURI(Fragment fragment) {
-        return LogisticsCenter.getRawURI(fragment);
+        return RouteCenter.getRawURI(fragment);
     }
 
     /**
@@ -242,7 +245,7 @@ public String getRawURI(Fragment fragment) {
      * @param activity
      */
     public String getCurrentPath(Activity activity) {
-        return LogisticsCenter.getCurrentPath(activity);
+        return RouteCenter.getCurrentPath(activity);
     }
 
     /**
@@ -251,31 +254,31 @@ public String getCurrentPath(Activity activity) {
      * @param fragment
      */
     public String getCurrentPath(Fragment fragment) {
-        return LogisticsCenter.getCurrentPath(fragment);
+        return RouteCenter.getCurrentPath(fragment);
     }
 
     public void inject(Activity activity) {
-        LogisticsCenter.inject(activity, null, null);
+        RouteCenter.inject(activity, null, null);
     }
 
     public void inject(Activity activity, Intent intent) {
-        LogisticsCenter.inject(activity, intent, null);
+        RouteCenter.inject(activity, intent, null);
     }
 
     public void inject(Activity activity, Bundle bundle) {
-        LogisticsCenter.inject(activity, null, bundle);
+        RouteCenter.inject(activity, null, bundle);
     }
 
     public void inject(Fragment fragment) {
-        LogisticsCenter.inject(fragment, null, null);
+        RouteCenter.inject(fragment, null, null);
     }
 
     public void inject(Fragment fragment, Intent intent) {
-        LogisticsCenter.inject(fragment, intent, null);
+        RouteCenter.inject(fragment, intent, null);
     }
 
     public void inject(Fragment fragment, Bundle bundle) {
-        LogisticsCenter.inject(fragment, null, bundle);
+        RouteCenter.inject(fragment, null, bundle);
     }
 
     @Nullable
@@ -296,7 +299,7 @@ public Object go(Context context, Card card, int requestCode, ActivityResultLaun
         card.setInterceptorException(null);
 
         try {
-            LogisticsCenter.assembleRouteCard(card);
+            RouteCenter.assembleRouteCard(card);
         } catch (NoFoundRouteException e) {
             logger.warning(null, e.getMessage());
 
@@ -428,39 +431,39 @@ private Object goFragment(Card card, GoCallback callback) {
     }
 
     public <T> void registerEvent(FragmentActivity activity, @NonNull Class<T> type, @NonNull Observer<T> observer) {
-        LogisticsCenter.registerEvent(activity, type, false, observer);
+        EventCenter.registerEvent(activity, type, false, observer);
     }
 
     public <T> void registerEvent(Fragment fragment, @NonNull Class<T> type, @NonNull Observer<T> observer) {
-        LogisticsCenter.registerEvent(fragment, type, false, observer);
+        EventCenter.registerEvent(fragment, type, false, observer);
     }
 
     public <T> void registerEventForever(FragmentActivity activity, @NonNull Class<T> type, @NonNull Observer<T> observer) {
-        LogisticsCenter.registerEvent(activity, type, true, observer);
+        EventCenter.registerEvent(activity, type, true, observer);
     }
 
     public <T> void registerEventForever(Fragment fragment, @NonNull Class<T> type, @NonNull Observer<T> observer) {
-        LogisticsCenter.registerEvent(fragment, type, true, observer);
+        EventCenter.registerEvent(fragment, type, true, observer);
     }
 
     public <T> void unRegisterEvent(FragmentActivity activity, @NonNull Class<T> type) {
-        LogisticsCenter.unRegisterEvent(activity, type, null);
+        EventCenter.unRegisterEvent(activity, type, null);
     }
 
     public <T> void unRegisterEvent(Fragment fragment, @NonNull Class<T> type) {
-        LogisticsCenter.unRegisterEvent(fragment, type, null);
+        EventCenter.unRegisterEvent(fragment, type, null);
     }
 
     public <T> void unRegisterEvent(FragmentActivity activity, @NonNull Class<T> type, Observer<T> observer) {
-        LogisticsCenter.unRegisterEvent(activity, type, observer);
+        EventCenter.unRegisterEvent(activity, type, observer);
     }
 
     public <T> void unRegisterEvent(Fragment fragment, @NonNull Class<T> type, Observer<T> observer) {
-        LogisticsCenter.unRegisterEvent(fragment, type, observer);
+        EventCenter.unRegisterEvent(fragment, type, observer);
     }
 
     public <T> void postEvent(@NonNull String path, @NonNull T value) {
-        LogisticsCenter.postEvent(path, value);
+        EventCenter.postEvent(path, value);
     }
 
 

GoRouter-Api/src/main/java/com/wyjson/router/core/EventCenter.java

@@ -0,0 +1,152 @@
+package com.wyjson.router.core;
+
+import static com.wyjson.router.core.Constants.ROUTER_CURRENT_PATH;
+
+import android.app.Activity;
+import android.os.Handler;
+import android.os.Looper;
+
+import androidx.annotation.NonNull;
+import androidx.fragment.app.Fragment;
+import androidx.lifecycle.Lifecycle;
+import androidx.lifecycle.LifecycleEventObserver;
+import androidx.lifecycle.LifecycleObserver;
+import androidx.lifecycle.LifecycleOwner;
+import androidx.lifecycle.MutableLiveData;
+import androidx.lifecycle.Observer;
+
+import com.wyjson.router.GoRouter;
+import com.wyjson.router.exception.RouterException;
+import com.wyjson.router.utils.TextUtils;
+
+public class EventCenter {
+
+    public static <T> void registerEvent(LifecycleOwner owner, Class<T> type, boolean isForever, @NonNull Observer<T> observer) {
+        if (!(owner instanceof Activity) && !(owner instanceof Fragment)) {
+            /**
+             * 正常通过api调用是不会走到这里,除非直接调用了此方法才有可能出现这种情况
+             * 可能是FragmentViewLifecycleOwner类型,需要导包才能直接判断,为了少导入包,就这么写判断吧.
+             */
+            throw new RouterException("The owner can only be an Activity or Fragment");
+        }
+        if (type == null) {
+            throw new RouterException("type cannot be empty!");
+        }
+
+        String path = RouteCenter.getCurrentPath(owner);
+        if (TextUtils.isEmpty(path)) {
+            GoRouter.logger.error(null, "[registerEvent] The " + ROUTER_CURRENT_PATH + " parameter was not found in the intent");
+            return;
+        }
+
+        String key = path + "$" + type.getCanonicalName();
+        MutableLiveData<T> liveData;
+        if (Warehouse.events.containsKey(key)) {
+            liveData = Warehouse.events.get(key);
+        } else {
+            liveData = new MutableLiveData<>();
+            Warehouse.events.put(key, liveData);
+            addLifecycleObserver(owner, getLifecycleObserver(key));
+        }
+        if (liveData != null) {
+            if (isForever) {
+                liveData.observeForever(observer);
+            } else {
+                liveData.observe(owner, observer);
+            }
+        } else {
+            GoRouter.logger.error(null, "[registerEvent] LiveData is empty??");
+        }
+    }
+
+    public static <T> void unRegisterEvent(LifecycleOwner owner, Class<T> type, Observer<T> observer) {
+        if (type == null) {
+            throw new RouterException("type cannot be empty!");
+        }
+
+        String path = RouteCenter.getCurrentPath(owner);
+        if (TextUtils.isEmpty(path)) {
+            GoRouter.logger.error(null, "[registerEvent] The " + ROUTER_CURRENT_PATH + " parameter was not found in the intent");
+            return;
+        }
+
+        String key = path + "$" + type.getCanonicalName();
+        if (Warehouse.events.containsKey(key)) {
+            MutableLiveData<T> liveData = Warehouse.events.get(key);
+            if (liveData != null) {
+                if (observer != null) {
+                    liveData.removeObserver(observer);
+                } else {
+                    liveData.removeObservers(owner);
+                }
+                if (!liveData.hasObservers()) {
+                    Warehouse.events.remove(key);
+                }
+            }
+        } else {
+            GoRouter.logger.warning(null, "[unRegisterEvent] No observer was found for this event");
+        }
+    }
+
+    /**
+     * 页面销毁时删除当前页面注册的事件
+     *
+     * @param key
+     * @param <T>
+     * @return
+     */
+    @NonNull
+    private static <T> LifecycleEventObserver getLifecycleObserver(String key) {
+        return new LifecycleEventObserver() {
+            @Override
+            public void onStateChanged(@NonNull LifecycleOwner owner, @NonNull Lifecycle.Event event) {
+                if (event == Lifecycle.Event.ON_DESTROY) {
+                    owner.getLifecycle().removeObserver(this);
+                    if (Warehouse.events.containsKey(key)) {
+                        MutableLiveData<T> liveData = Warehouse.events.get(key);
+                        if (liveData != null && liveData.hasObservers()) {
+                            liveData.removeObservers(owner);
+                        }
+                        Warehouse.events.remove(key);
+                    }
+                }
+            }
+        };
+    }
+
+    private static void addLifecycleObserver(final LifecycleOwner lifecycleOwner, @NonNull LifecycleObserver lifecycleObserver) {
+        if (lifecycleOwner == null)
+            return;
+        Runnable runnable = () -> lifecycleOwner.getLifecycle().addObserver(lifecycleObserver);
+        if (Looper.myLooper() == Looper.getMainLooper()) {
+            runnable.run();
+        } else {
+            new Handler(Looper.getMainLooper()).post(runnable);
+        }
+    }
+
+    public static <T> void postEvent(String path, T value) {
+        if (TextUtils.isEmpty(path)) {
+            throw new RouterException("path Parameter is invalid!");
+        }
+        if (value == null) {
+            throw new RouterException("value cannot be empty!");
+        }
+        String key = path + "$" + value.getClass().getCanonicalName();
+        if (Warehouse.events.containsKey(key)) {
+            MutableLiveData<T> liveData = Warehouse.events.get(key);
+            if (liveData != null) {
+                if (Looper.myLooper() == Looper.getMainLooper()) {
+                    liveData.setValue(value);
+                } else {
+                    liveData.postValue(value);
+                }
+            } else {
+                GoRouter.logger.error(null, "[postEvent] LiveData is empty??");
+            }
+        } else {
+            GoRouter.logger.warning(null, "[postEvent] No observer was found for this event");
+        }
+    }
+
+}

GoRouter-Api/src/main/java/com/wyjson/router/core/InterceptorCenter.java

@@ -0,0 +1,45 @@
+package com.wyjson.router.core;
+
+import com.wyjson.router.GoRouter;
+import com.wyjson.router.exception.RouterException;
+import com.wyjson.router.interfaces.IInterceptor;
+
+public class InterceptorCenter {
+
+    /**
+     * 重复添加相同序号会catch
+     *
+     * @param ordinal
+     * @param interceptor
+     * @param isForce
+     */
+    public static void addInterceptor(int ordinal, Class<? extends IInterceptor> interceptor, boolean isForce) {
+        String title = isForce ? "[setInterceptor]" : "[addInterceptor]";
+        try {
+            if (isForce) {
+                Warehouse.interceptors.remove(ordinal);
+            }
+            IInterceptor instance = interceptor.getConstructor().newInstance();
+            instance.init();
+            Warehouse.interceptors.put(ordinal, instance);
+            GoRouter.logger.debug(null, title + " size:" + Warehouse.interceptors.size() + ", ordinal:" + ordinal + " -> " + interceptor.getSimpleName());
+        } catch (Exception e) {
+            throw new RouterException(title + " " + e.getMessage());
+        }
+    }
+
+    /**
+     * 重复添加相同序号会覆盖(更新)
+     *
+     * @param ordinal
+     * @param interceptor
+     */
+    public static void setInterceptor(int ordinal, Class<? extends IInterceptor> interceptor) {
+        addInterceptor(ordinal, interceptor, true);
+    }
+
+    public static void clearInterceptors() {
+        Warehouse.interceptors.clear();
+    }
+
+}