当Android项目越来越庞大的时候,应用的各个部件之间的通信变得越来越复杂,例如:当某一条件发生时,应用中有几个部件对这个消息感兴趣,那么我们通常采用的就是观察者模式,使用观察者模式有一个弊病就是部件之间的耦合度太高,在这里将会详细介绍Android中的解耦组件EventBus的使用。
EventBus简介
Publisher-Subscriber这种设计模式在GoF中早就详细的解释。也是一种最常用不过的设计模式。而EventBus则是对于Publisher和Subscriber的一种实现,如果你还在使用JDK中的Observer,则不妨看看TW大大的一片博客《你应该更新的java知识之observer》,使用EventBus替代Observer似乎成了一种必须。
EventBus是一个Android端优化的publish/subscribe消息总线,简化了应用程序内各组件间、组件与后台线程间的通信。比如请求网络,等网络返回时通过Handler或Broadcast通知UI,两个Fragment之间需要通过Listener通信,这些需求都可以通过**EventBus**实现。
EventBus主要的元素
事件:
- Event:事件,可以是任意类型的对象
- Subscriber:事件订阅者,接收特定的事件
- Publisher:事件发布者,用于通知Subscriber有事件发生
Subscriber
- 在EventBus中,使用约定来指定事件订阅者以简化使用。
- 即所有事件订阅都都是以onEvent开头的函数,具体来说,函数的名字是onEvent,onEventMainThread,onEventBackgroundThread,onEventAsync这四个
- 这个和ThreadMode有关(见下文)
Publisher
- 可以在任意线程任意位置发送事件,直接调用EventBus的post(Object)方法
- 可以自己实例化EventBus对象,但一般使用默认的单例就好了:EventBus.getDefault()
- 根据post函数参数的类型,会自动调用订阅相应类型事件的函数
ThreadMode
Subscriber函数的名字只能是那4个,因为每个事件订阅函数都是和一个ThreadMode相关联的,ThreadMode指定了会调用的函数。
有以下四个ThreadMode:
- PostThread:事件的处理在和事件的发送在相同的进程,所以事件处理时间不应太长,不然影响事件的发送线程,而这个线程可能是UI线程。对应的函数名是onEvent。
- MainThread: 事件的处理会在UI线程中执行。事件处理时间不能太长,这个不用说的,长了会ANR的,对应的函数名是onEventMainThread。
- BackgroundThread:事件的处理会在一个后台线程中执行,对应的函数名是onEventBackgroundThread,虽然名字是BackgroundThread,事件处理是在后台线程,但事件处理时间还是不应该太长,因为如果发送事件的线程是后台线程,会直接执行事件,如果当前线程是UI线程,事件会被加到一个队列中,由一个线程依次处理这些事件,如果某个事件处理时间太长,会阻塞后面的事件的派发或处理。
- Async:事件处理会在单独的线程中执行,主要用于在后台线程中执行耗时操作,每个事件会开启一个线程(有线程池),但最好限制线程的数目。
使用EventBus的步骤
EventBus使用起来和Otto差不多,分订阅、注册、发布、取消注册等步骤:
View Code
//定义事件类型: publicclassMyEvent{} //定义事件处理方法: publicvoid onEventMainThread //注册订阅者: EventBus.getDefault().register(this) //发送事件: EventBus.getDefault().post(newMyEvent()) //实现
EventBus源码分析
- EventType:onEvent函数中的参数,表示事件的类型
- Subscriber:订阅源,即调用register注册的对象,这个对象内包含onEvent函数
- SubscribMethod:Subscriber内某一特定的onEvent方法,内部成员包含一个Method类型的method成员表示这个onEvent方法,一个ThreadMode成员threadMode表示事件的处理线程,一个Class<?>类型的eventType成员表示事件的类型EventType。
- Subscription,表示一个订阅对象,包含订阅源Subscriber,订阅源中的某一特定方法SubscribMethod,这个订阅的优先级priopity
了解了以上几个概念后就可以看`EventBus`中的几个重要成员了
View Code
// EventType -> List<Subscription>,事件到订阅对象之间的映射 privatefinalMap<Class<?>,CopyOnWriteArrayList<Subscription>> subscriptionsByEventType; // Subscriber -> List<EventType>,订阅源到它订阅的的所有事件类型的映射 privatefinalMap<Object,List<Class<?>>> typesBySubscriber; // stickEvent事件,后面会看到 privatefinalMap<Class<?>,Object> stickyEvents; // EventType -> List<? extends EventType>,事件到它的父事件列表的映射。即缓存一个类的所有父类 privatestaticfinalMap<Class<?>,List<Class<?>>> eventTypesCache =newHashMap<Class<?>,List<Class<?>>>();