代码里面发送粘性事件代码如下：
-
// 发送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(); } }
