EventBus源码分析一

1.Event概述

1.1EventBus是什么？

EventBus是一个使用发布-订阅模式(观察者模式)进行松耦合的Android开源库。EventBus能够通过仅仅几行代码使解耦的类进行基本的通信 - 简化代码，消除依赖和加速app开发。

1.2使用EventBus的好处?/为什么要是用它？

• 简化组件之间通信
• 分离事件的发送者和接收者
• 简化 Activities, Fragments, Threads, Services之间通信，更少的代码,更好的质量
• 避免复杂和容易出错的依赖关系和生命周期问题
• 快速，高效的
• 小（<50K的jar）
• 具有交付线程、用户优先级等高级功能

greenrobot官方对EventBus的解释

1.3EventBus中三个重要的角色

• 事件(Event)：也可理解为消息，事件可以是任意类型对象。事件类型(EventType)指事件所属的类。

事件分为一般事件和 Sticky (粘性)事件，相对于一般事件，Sticky 事件不同之处在于，当事件发布后，再有订阅者开始订阅该类型事件，依然能收到该类型事件最近一个 Sticky 事件。

• 订阅者(Subscriber)：订阅某种事件类型的对象。

当有发布者发布这类事件后，EventBus 会执行订阅者的 onEvent 函数，这个函数叫事件响应函数。订阅者通过 register 接口订阅某个事件类型，unregister 接口退订。订阅者存在优先级，优先级高的订阅者可以取消事件或者继续向优先级低的订阅者分发，默认所有订阅者优先级都为 0。

• 发布者(Publisher)：发布某事件的对象，可以通过post接口在任意线程任意位置发送事件。

1.4EventBus架构图

下面这个是greenrobot官方提供的图就很直观的说明了Event的架构：

理解：

• EventBus 负责存储Subscriber和Event，Subscriber和Publisher都只和 EventBus 关联。
• EventBus执行流程：Subscriber首先调用 EventBus 的 register 接口订阅某种类型的事件，当Publisher通过 post 接口发布该类型的事件时，EventBus 执行Subscriber的事件响应函数。

2.EventBus源码分析

2.1创建EventBus

我们就从EventBus.getDefault()入手，看看EventBus是如何初始化的：

    static volatile EventBus defaultInstance;
 /** Convenience singleton for apps using a process-wide EventBus instance. */
    public static EventBus getDefault() {
        if (defaultInstance == null) {
            synchronized (EventBus.class) {
                if (defaultInstance == null) {
                    defaultInstance = new EventBus();
                }
            }
        }
        return defaultInstance;
    }

可以看出来，EventBus是单例模式存在的，并且是进程范围内共享的。除了通过静态函数 getDefault 获取EventBus单例对象，也可以通过 EventBusBuilder (Builder模式创建复杂对象)或 构造函数创建一个 EventBus对象。

设计模式之单例模式
设计模式之Builder模式

需要注意的是：
每个新建的 EventBus 发布和订阅事件都是相互隔离的，即一个 EventBus 对象中的发布者发布事件，另一个 EventBus 对象中的订阅者不会收到该订阅。

EventBus构造方法重要代码：

    private static final EventBusBuilder DEFAULT_BUILDER = new EventBusBuilder();

    public EventBus() {
        this(DEFAULT_BUILDER);
    }

    //key:事件的class对象,value:订阅这个事件的订阅者集合
    private final Map<Class<?>, CopyOnWriteArrayList<Subscription>> subscriptionsByEventType;
    //key:订阅者对象,value:这个订阅者所订阅的事件类型集合
    private final Map<Object, List<Class<?>>> typesBySubscriber;
    //key:粘性事件的class对象, value:粘性事件对象
    private final Map<Class<?>, Object> stickyEvents;
    //事件主线程处理
    private final HandlerPoster mainThreadPoster;
    //事件 Background 处理
    private final BackgroundPoster backgroundPoster;
    //事件异步线程处理
    private final AsyncPoster asyncPoster;
    //订阅者事件响应函数信息存储和查找类
    private final SubscriberMethodFinder subscriberMethodFinder;
    //是否支持事件继承
    private final boolean eventInheritance;

    EventBus(EventBusBuilder builder) {
        subscriptionsByEventType = new HashMap<>();
        typesBySubscriber = new HashMap<>();
        stickyEvents = new ConcurrentHashMap<>();

        mainThreadPoster = new HandlerPoster(this, Looper.getMainLooper(), 10);
        backgroundPoster = new BackgroundPoster(this);
        asyncPoster = new AsyncPoster(this);
        
        subscriberMethodFinder = new SubscriberMethodFinder(builder.subscriberInfoIndexes,
                builder.strictMethodVerification, builder.ignoreGeneratedIndex);

        eventInheritance = builder.eventInheritance;

        ...

    }