在安卓组件化开发中，消息传递是必须解决的问题。在单模块的时候，handler或者通过定制接口我们可以解决不同系统组件之间的消息传递，然而，在多模块的组件化开发中，无论是handler还是定制接口，在跨模块的时候，都会造成事件发布者跟接受者，即不同模块之间的高耦合。那使用广播呢，可以做到，但是广播的主要目的是跨进程通信，通常用于系统级的事件，也比较消耗资源，并且依赖Context对象，既消耗资源也不灵活，每个地方都用广播显然是不妥的。
好在github上有现成的解决方案：事件总线EventBus。它是个轻量级的框架，无需依赖Context，只需要通过发送事件跟注解订阅，就能达到消息的传送，且支持事件的优先级，耦合性很低，并且父类的订阅可以传给子类，还可创建粘滞事件，能够保证事件不会因 Subscriber 的不在场而忽略，可以说非常灵活了。
当然我们不是看他怎么使用，具体使用很简单，github下面讲解很清楚，我们需要了解的是它的实现。好吧，下面看看它的源码，源码我做了修改，同时删除了基本功能以外的部分，我们这里只看事件收发。
大体流程其实很简单，就两部：1.订阅时保存到本地，2.发送时取出订阅者执行订阅的方法。
首先代码中根据事件类型，订阅者类型，事件，订阅者，订阅方法组成的类型有点乱，不容易理解，所以我整理出来了几个参数跟类重点注意下：
订阅的方法信息类SubscriberMethod，包含方法，工作线程，事件类型，优先级等等（粘性事件之类的部分删除了，这里只看基本）：
订阅的方法信息，包含方法，工作线程，事件类型，优先级等等
订阅信息类Subscription，存放订阅者跟订阅方法信息:
状态信息类FindState，存放于状态池FIND_STATE_POOL中，负责往上面父类查找方法
发送状态信息类PostingThreadState，存放事件队列跟各种状态标志位：
参数subscriptionsByEventType，一个Map,存放事件类型跟订阅信息的映射
OK，眼熟完这些，我们正式进入步骤分析源码：
一.订阅
注册订阅我们用的接口是register方法
我们从这个方法入手分析：
首先获取到了订阅者的类型，然后依次走findSubscriberMethods跟subscribe方法，看名字不难理解分别是寻找订阅方法跟订阅的意思，先看下findSubscriberMethods方法：
首先本地有个缓存METHOD_CACHE，这是个map，保存已经找过的方法，如果缓存里没有，就走到findUsingInfo这个方法里找，再找不到就表示这个类型没有添加Subscribe注解的方法，抛出异常。
findUsingInfo会通过状态信息类FindState类一级一级往父类，通过反射信息查找带Subscribe注解的方法，findUsingReflectionInSingleClass方法就通过反射，最后根据查找到的方法的修饰词，注解跟参数判断是否有效，这里默认设置了只有public的方法且第一个参数符合发送的事件类型的才有效。
找到带订阅注解的方法后就走到了订阅方法这一步，即subscribe方法里，看下代码逻辑
大致流程就是将订阅者跟订阅的方法封成一个Subscription信息类列表，跟时间类型组成一个映射存放在本地的subscriptionsByEventType这个map中，如果原来这个列表中就有这个订阅信息，就表示重复注册，抛出异常，没有的话，就讲订阅信息根据优先级插入列表。由此，订阅部分结束。
二.发送事件
发送事件入口是Post方法，代码如下：
PostingThreadState前面介绍过，封装了一个事件队列跟标志位，而currentPostingThreadState是一个ThreadLocal类型的成员，里面存储了PostingThreadState。事件最后添加到PostingThreadState的事件队列中，然后就执行postSingleEvent方法
这里会调用lookupAllEventTypes方法，逐级往上获取到event的父类跟接口，存在缓存中，如果缓存中有则直接从缓存中取。然后会根据获取到的这些类型通过postSingleEventForEventType方法推送，如果该方法返回flase，则表示这个类型没有订阅信息，发送空时间信息。
可以看出postSingleEventForEventType中，我们从之前存储订阅信息的本地map缓存subscriptionsByEventType中取出eventClass对应的订阅信息，如果为空，返回false返回上级发送空事件，如果不为空，则表示发送成功，取到信息，进入postToSubscription执行订阅方法
postToSubscription根据注解时标注的四种模式选择线程执行订阅的方法，invokeSubscriber这个方法直接执行方法，表示在当前线程中。若判断到目标线程不是当前线程的话，则通过自定义的handler在另一个线程执行方法。
就此，发送的事件成功被订阅者接受并响应。可以看出，跨线程的话，最后其实还是通过handler来执行，只是该框架将订阅者订阅事件订阅方法这三个元素通过映射保存在了本地，最后通过反射执行方法。
网友评论