【EventBus】EventBus 源码解析 ( 注册订阅者总结 | 从封装的数据结构角度分析 EventBus )

文章目录

EventBus 中的重要数据类型

1、subscriptionsByEventType 集合

2、typesBySubscriber 集合

EventBus 中的重要数据类型

从几个关键的数据存储结构角度分析 EventBus 注册订阅者过程 ;

1、subscriptionsByEventType 集合

Map<Class<?>, CopyOnWriteArrayList> subscriptionsByEventType 集合

在 EventBus 中的 subscriptionsByEventType 成员变量 , 保存的是 HashMap 集合 ,

Key 是事件类型对象 ;

Value 是 Subscription 集合 , Subscription 中封装了一个订阅者对象和一个订阅方法 ;

public class EventBus {
  private final Map<Class<?>, CopyOnWriteArrayList<Subscription>> subscriptionsByEventType;
}

在 EventBus.subscribe 方法中 , 获取订阅方法参数类型就是上述 Key 键 ;

// 获取订阅方法参数类型 , 可以是任意类型 , 自定义的 MessageEvent 消息类型
        Class<?> eventType = subscriberMethod.eventType;

先封装该 订阅者 对象 与 订阅方法 到 Subscription 中 ,

// Subscription 中封装了一个订阅者对象和一个订阅方法 
        Subscription newSubscription = new Subscription(subscriber, subscriberMethod);

然后从 Map<Class<?>, CopyOnWriteArrayList<Subscription>> subscriptionsByEventType 成员变量中获取 对应 消息类型 的 Subscription 集合 ;

如果发现没有该消息类型对应的 CopyOnWriteArrayList<Subscription> 集合 , 则先创建一个集合 , 再放入到 subscriptionsByEventType 成员中 ;

然后在将新封装的 Subscription 对象 , 放到对应的 CopyOnWriteArrayList<Subscription> 集合中 , 注意放入的时候 , 查询是否有设置优先级属性 , 如果有 , 按照优先级顺序放置 ;

int size = subscriptions.size();
        for (int i = 0; i <= size; i++) {
          // 处理订阅方法优先级 , 重新进行排列  
            if (i == size || subscriberMethod.priority > subscriptions.get(i).subscriberMethod.priority) {
                subscriptions.add(i, newSubscription);
                break;
            }
        }

这样就完成了 Map<Class<?>, CopyOnWriteArrayList<Subscription>> subscriptionsByEventType 成员的封装工作 ;

该成员变量的作用很明显 , 在发布者发送消息到消息中心后 , 消息中心根据传入的消息类型 , 查找对应的 订阅者实例对象 和 订阅方法 , 可以直接调用对应的订阅方法 ;

2、typesBySubscriber 集合

Map<Object, List<Class<?>>> typesBySubscriber 集合

private final Map<Object, List<Class<?>>> typesBySubscriber; 是 EventBus 的成员变量 ;

Key : 订阅者对象 ;

Value : 订阅方法参数类型集合 ;

可以根据订阅者对象查询 该订阅者对象 中的 订阅方法 中的参数集合 , 根据参数可以到 Map<Class<?>, CopyOnWriteArrayList<Subscription>> subscriptionsByEventType 集合中查询对应的 订阅者对象 和 订阅方法 ;

该 typesBySubscriber 集合的作用很明显 , 在取消注册时 , 可以快速查询到 该订阅者对象 注册了哪些方法 , 将其从 Map<Class<?>, CopyOnWriteArrayList<Subscription>> subscriptionsByEventType 集合中移除 , 就可以达到取消订阅的目的 ;