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 集合中移除 , 就可以达到取消订阅的目的 ;

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

【EventBus】EventBus 源码解析 ( 注册订阅者 | 注册订阅方法详细过程 )
文章目录前言一.EventBus 注册订阅者二.注册订阅方法的具体过程三.Subscription 类前言在上一篇博客 [EventBus]EventBus 源码解析 ( 注册订阅者 | ...
【EventBus】EventBus 源码解析 ( 注册订阅者 | 订阅方法 | 查找订阅方法 )
文章目录一.EventBus 注册订阅者二.订阅方法三.查找订阅方法 findSubscriberMethods 方法四.查找订阅方法 findUsingInfo 方法五.查找订阅方法 fi ...
【EventBus】EventBus 源码解析 ( 注册订阅者总结 | EventBus 注册订阅者流程梳理 )
文章目录 EventBus 注册订阅者流程梳理 EventBus 注册订阅者流程梳理 EventBus 注册订阅者流程梳理 : ① 在客户端调用 EventBus.getDefault().reg ...
【EventBus】EventBus 源码解析 ( 取消订阅 )
文章目录一.取消订阅二.取消订阅 unsubscribeByEventType 方法一.取消订阅 [EventBus]EventBus 使用示例 ( 最简单的 EventBus 示例 ) 示例中 ...
Android 源码分析之 EventBus 的源码解析
1.EventBus 的使用 1.1 EventBus 简介 EventBus 是一款用于 Android 的事件发布-订阅总线,由 GreenRobot 开发,Gihub 地址是:EventBus. ...
Android之EventBus框架源码解析上(单例模式)
转载请标明出处:[顾林海的博客] 个人开发的微信小程序,目前功能是书籍推荐,后续会完善一些新功能,希望大家多多支持! 前言 EventBus能够简化各组件间的通信,让我们的代码书写变得简单,能有效的分 ...
Dubbo源码解析 —— Zookeeper 订阅
作者:肥朝原文地址:https://www.jianshu.com/p/73224a6c07bb 友情提示:欢迎关注公众号[芋道源码].????关注后,拉你进[源码圈]微信群和[肥朝]搞基嗨皮. 友 ...
TiKV 源码解析系列文章（二）raft-rs proposal 示例情景分析
作者:屈鹏本文为 TiKV 源码解析系列的第二篇,按照计划首先将为大家介绍 TiKV 依赖的周边库 raft-rs .raft-rs 是 Raft 算法的 Rust 语言实现.Raft 是分布式领域 ...
Android之EventBus框架源码解析下（源码解析）
转载请标明出处:[顾林海的博客] 个人开发的微信小程序,目前功能是书籍推荐,后续会完善一些新功能,希望大家多多支持! 前言 EventBus是典型的发布订阅模式,多个订阅者可以订阅某个事件,发布者通过 ...

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

文章目录

EventBus 中的重要数据类型

1、subscriptionsByEventType 集合

2、typesBySubscriber 集合

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

最新文章

热门文章