Android开源框架如何说-EventBus3

2018-08-23 本文已影响0人 MigrationUK

概念
- Eventbus是一个专门为Android平台优化定制的事件总线函数库，事件总线，继承自观察者模式，也是基于发布订阅的机制来实现事件的发送与接收的
基本用法
- 定义一个事件类 MessageEvent
- 定义一个订阅方法，使用 @Subscribe指定订阅方法所在线程
- 注册和反注册订阅方法
- 发送事件
源码详解
- 重要成员变量
  - subscriptionsByEventType：以event事件为key，以订阅者列表为value
  - typesBySubscriber：订阅者集合，以订阅者类为key，以订阅者所有event事件列表为value
  - stickyEvents：保存的是粘性事件
  - HandlerPoster
  - BackgroundPoster
  - AsyncPoster
- @Subscribe 的注解
  - 当我们指定订阅方法的时候，会在方法上加上注解
```
@Documented //命名为 java doc 文档
@Retention(RetentionPolicy.RUNTIME) //指定在运行时有效，即在运行时能保持这个 Subscribe
@Target({ElementType.METHOD}) //指定类型为 METHOD，表名用来描述方法
public @interface Subscribe {
 //指定线程模式，可以指定在 Subscribe 中接收的 Event 所处的线程
 ThreadMode threadMode() default ThreadMode.POSTING;
 boolean sticky() default false;
 int priority() default 0;
} 
```
- 源码流程
  - Eventbus创建
    - 单例模式、建造者模式
  - Regitster注册
    - 通过反射获取到订阅者的 Class 对象
    - 通过 Class 对象找到对应的订阅者方法集合
      - 首先从缓存取出subscriberMethods，如果有则直接返回该方法列表(ConcurrentHashMap)
      - 根据是否忽略生成 index标记位(优化，EventBusAnnotationProcessor编译时期生成方法索引，默认false)
      - 忽略通过反射findUsingReflection()
        
        创建并初始化 FindState 对象(封装了所有的订阅者和订阅方法的集合)
        
        使用反射的方式获取单个类的订阅方法
        
        忽略非 public 和 static 的方法
        
        筛选只有一个参数、有 Subscribe 的注解的订阅方法
        
        检查 eventType 决定是否订阅，不能有多个eventType 相同的订阅方法
        
        将订阅方法加入SubscriberMethod
      - 不忽略通过 findUsingInfo
    - subscribe ()遍历订阅者方法集合，将订阅者和订阅者方法订阅起来
      - 判断是否订阅过事件，如果该newSubscription(封装订阅者和订阅方法信息)已经被订阅过，抛出异常
      - 按照优先级插入subscriptions(typesBySubscriber value的list)
      - 判断是否为粘性事件，是的话考虑是否继承关系
      - 发送粘性事件给 newSubscription
  - Post分发
    - 获取当前线程的 posting 状态
    - 获取当前事件队列
    - 将事件添加进当前线程的事件队列
    - postSingleEvent() 不断从队列获取事件进行分发
      - 依次遍历订阅者
      - postToSubscription()根据threadMode进行不同Poster分发
      - invokeSubscriber()最终订阅者接收到了事件，反射调用订阅方法
  - UnRegitster反注册
    - 根据typesBySubscriber逐个取消订阅者所有订阅事件

Android开源框架如何说-EventBus3

猜你喜欢

热点阅读