【第四篇】androidEventbus源代码阅读和分析

1，分析androidEventbus的注册源代码：

我们在使用androidEventbus的第一步是注册eventbus,如下代码：

1. EventBus.getDefault().register(this);

首先获取eventbus对象，采用单利模式实现获取对象：

Eventbus.java里面

1. public static EventBus getDefault() {
           if (sDefaultBus == null) {
               synchronized (EventBus.class) {
                   if (sDefaultBus == null) {
                       sDefaultBus = new EventBus();
                   }
               }
           }
           return sDefaultBus;
       }

   


然后是：

1. public void register(Object subscriber) {
           if (subscriber == null) {
               return;
           }
           synchronized (this) {
               mMethodHunter.findSubcribeMethods(subscriber);
           }
       }

   


跟踪到mMethodHunter.findSubcribeMethods(subscriber);继续往下看：

mMethodHunter在代码头部注册：

1. /**
   * the subscriber method hunter, find all of the subscriber's methods
   * annotated with @Subcriber
   */
   SubsciberMethodHunter mMethodHunter =newSubsciberMethodHunter(mSubcriberMap);

用于查找所有使用@subcriber的注解方法

然后我们跟到findSubcribeMethods(subscriber)里面看看：

遍历

1. public void findSubcribeMethods(Object subscriber) {
           if (mSubcriberMap == null) {
               throw new NullPointerException("the mSubcriberMap is null. ");
           }
           Class<?> clazz = subscriber.getClass();
           // 查找类中符合要求的注册方法,直到Object类
           while (clazz != null && !isSystemCalss(clazz.getName())) {
               final Method[] allMethods = clazz.getDeclaredMethods();
               for (int i = 0; i < allMethods.length; i++) {
                   Method method = allMethods[i];
                   // 根据注解来解析函数
                   Subscriber annotation = method.getAnnotation(Subscriber.class);
                   if (annotation != null) {
                       // 获取方法参数
                       Class<?>[] paramsTypeClass = method.getParameterTypes();
                       // 订阅函数只支持一个参数
                       if (paramsTypeClass != null && paramsTypeClass.length == 1) {
                           Class<?> paramType = convertType(paramsTypeClass[0]);
                           EventType eventType = new EventType(paramType, annotation.tag());
                           TargetMethod subscribeMethod = new TargetMethod(method, eventType,
                                   annotation.mode());
                           subscibe(eventType, subscribeMethod, subscriber);
                       }
                   }
               } // end for
                 // 获取父类,以继续查找父类中符合要求的方法
               clazz = clazz.getSuperclass();
           }
       }

   


然后再 subscibe(eventType, subscribeMethod, subscriber);方法里面的代码：

mSubcriberMap是个map集合

 

1. /**
        * the event bus's subscriber's map
        */
       Map<EventType, CopyOnWriteArrayList<Subscription>> mSubcriberMap;

   /**
        * 按照EventType存储订阅者列表,这里的EventType就是事件类型,一个事件对应0到多个订阅者.
        * 
        * @param event 事件
        * @param method 订阅方法对象
        * @param subscriber 订阅者
        */
       private void subscibe(EventType event, TargetMethod method, Object subscriber) {
           CopyOnWriteArrayList<Subscription> subscriptionLists = mSubcriberMap.get(event);
           if (subscriptionLists == null) {
               subscriptionLists = new CopyOnWriteArrayList<Subscription>();
           }
           Subscription newSubscription = new Subscription(subscriber, method);
           if (subscriptionLists.contains(newSubscription)) {
               return;
           }
           subscriptionLists.add(newSubscription);
           // 将事件类型key和订阅者信息存储到map中
           mSubcriberMap.put(event, subscriptionLists);
       }

 

到这里就可以看到register就是遍历所有注解@Subcriber的方法，并将事件类型key和订阅者信息存储在map中去。这点很类似eventbus代码中register,只不过eventbus是以以onEvent开头的方法去进行查找，而androideventbus是以@subcriber去进行遍历检索，但最终都是将事件类型key和订阅者信息存储在map中去。