代码里面发送粘性事件代码如下：
// 发送Sticky事件 EventBus.getDefault().postSticky(new User("soyoungboy", "西安财经学院"), "soyoungboy");
然后我们进入postSticky方法里面去：
EventType 是什么？
该类是描述一个函数唯一性的对象，参数类型、tag两个条件保证了对象的唯一性.通过该类的对象来查找注册了相应类型和tag的所有订阅者{@see* Subscription}, 并且在接到消息时调用所有订阅者对应的函数.
mStickyEvents是什么？
private List<EventType> mStickyEvents = Collections .synchronizedList(new LinkedList<EventType>());
是个list集合，用于存储eventType的list集合。
/** * 发布Sticky事件,tag为EventType.DEFAULT_TAG * * @param event */ public void postSticky(Object event) { postSticky(event, EventType.DEFAULT_TAG); } /** * 发布含有tag的Sticky事件 * * @param event 事件 * @param tag 事件tag */ public void postSticky(Object event, String tag) { EventType eventType = new EventType(event.getClass(), tag); eventType.event = event; mStickyEvents.add(eventType); // 处理sticky事件 // mDispatcher.handleStickyEvent(eventType, null); }
这是发布，如何接收粘性事件，我们也看下源码来分析下：
首先要注册粘性事件的eventbus:
EventBus.getDefault().registerSticky(this);
走进registerSticky代码里面看下：
/** * 以sticky的形式注册,则会在注册成功之后迭代所有的sticky事件 * * @param subscriber */ public void registerSticky(Object subscriber) { this.register(subscriber); // 处理sticky事件 mDispatcher.dispatchStickyEvents(subscriber); }register代码不进行分析，因为前面讲过，就是将@ subscriber的订阅者对象放入map集合里面去
重点分析下 mDispatcher.dispatchStickyEvents(subscriber);
void dispatchStickyEvents(Object subscriber) { for (EventType eventType : mStickyEvents) { handleStickyEvent(eventType, subscriber); } }
在往下面走：
根据不同的ThreadMode去调用不同的handler(这里是事件分发器对象)的handleEvent方法。
ThreadMode是在代码里面通过注解传进来的。
/**
* 处理单个Sticky事件
*
* @param eventType
* @param aEvent
*/
private void handleStickyEvent(EventType eventType, Object subscriber) {
//从缓存获取eventTypes内容
List<EventType> eventTypes = getMatchedEventTypes(eventType, eventType.event);
// 事件
Object event = eventType.event;
//循环遍历eventType集合
for (EventType foundEventType : eventTypes) {
Log.e("", "### 找到的类型 : " + foundEventType.paramClass.getSimpleName()
+ ", event class : " + event.getClass().getSimpleName());
//从订阅者的map集合里面获取指定的订阅者集合的list集合，根据eventType
final List<Subscription> subscriptions = mSubcriberMap.get(foundEventType);
if (subscriptions == null) {
continue;
}
//遍历list集合
for (Subscription subItem : subscriptions) {
final ThreadMode mode = subItem.threadMode;
EventHandler eventHandler = getEventHandler(mode);
// 如果订阅者为空,那么该sticky事件分发给所有订阅者.否则只分发给该订阅者
if (isTarget(subItem, subscriber)
&& (subItem.eventType.equals(foundEventType)
|| subItem.eventType.paramClass
.isAssignableFrom(foundEventType.paramClass))) {
// 处理事件
eventHandler.handleEvent(subItem, event);
}
}
}
}
mDispatcher是个事件分发器；
EventDispatcher事件分发器中有三条个ThreadEventHandler:
UIThreadEventHandler
DefaultEventHandler
AsyncEventHandler
都实现了EventHandler事件处理接口，实现handleEvent方法：
UIThreadEventHandler中实现：
事件处理在UI线程,通过Handler将事件处理post到UI线程的消息队列，UIThreadEventHandler的handleEvent指向DefaultEventHandler的handleEvent方法;列
/** * @param subscription * @param event */ public void handleEvent(final Subscription subscription, final Object event) { mUIHandler.post(new Runnable() { @Override public void run() { mEventHandler.handleEvent(subscription, event); } }); }
AsyncEventHandler中实现：默认也是子类为DefaultEventHandler的handleEvent去实现，重点还是DefaultEventHandler中的handleEvent的实现。
/** * 将订阅的函数执行在异步线程中 * * @param subscription * @param event */ public void handleEvent(final Subscription subscription, final Object event) { mDispatcherThread.post(new Runnable() { @Override public void run() { mEventHandler.handleEvent(subscription, event); } }); }
DefaultEventHandler中实现：
重点是subscription.targetMethod.invoke(subscription.subscriber.get(), event)，代码走到最后走到这里，那么到这这里执行了什么操作呢;
执行反射操作，根据参数查找方法，进行反射调用。
/**
* handle the event
*
* @param subscription
* @param event
*/
public void handleEvent(Subscription subscription, Object event) {
if (subscription == null
|| subscription.subscriber.get() == null) {
return;
}
try {
// 执行
subscription.targetMethod.invoke(subscription.subscriber.get(), event);
} catch (IllegalArgumentException e) {
e.printStackTrace();
} catch (IllegalAccessException e) {
e.printStackTrace();
} catch (InvocationTargetException e) {
e.printStackTrace();
}
}