文章目录
一、EventBus 事件发送
二、事件发送 postSingleEvent 方法
一、EventBus 事件发送
在客户端的某个线程中 , 调用 EventBus.getDefault().post("Hello EventBus !"); 方法 , 向消息中心发送消息 ;
在 EventBus 中 , 获取 ThreadLocal 数据 PostingThreadState , 其中记录了 线程状态信息 , 其中维护了一个事件队列 List<Object> eventQueue , 将本次传入的事件 , 加入到该事件队列中 ;
然后判断发布线程是否是主线程 , 并保存发送状态 ;
// 判断是否处于主线程 postingState.isMainThread = isMainThread(); // 保存临时状态 , 放置重复调用 postingState.isPosting = true;
EventBus.post 方法源码 :
/** * EventBus是Java和Android的中央发布/订阅事件系统。 * 事件被发布（{@link#post（Object）}）到总线，总线将其传递给具有匹配处理程序的订阅者 * 事件类型的方法。 * 要接收事件，订阅者必须使用{@link#register（Object）}将自己注册到总线。 * 一旦注册，订阅服务器将接收事件，直到调用{@link#unregister（Object）}。 * 事件处理方法必须由{@link Subscribe}注释，必须是公共的，不返回任何内容（void）， * 并且只有一个参数（事件）。 */ public class EventBus { private final ThreadLocal<PostingThreadState> currentPostingThreadState = new ThreadLocal<PostingThreadState>() { @Override protected PostingThreadState initialValue() { return new PostingThreadState(); } }; /** 将给定的事件传递给事件总线 */ public void post(Object event) { // ThreadLocal 数据 // ThreadLocal<PostingThreadState> currentPostingThreadState // PostingThreadState 可以理解成一个辅助类 PostingThreadState postingState = currentPostingThreadState.get(); // 该队列用于维护事件 , 是一个事件队列 , 队列的固有属性就是 先进先出 List<Object> eventQueue = postingState.eventQueue; // 将传入事件加入到队列中 eventQueue.add(event); if (!postingState.isPosting) { // 判断是否处于主线程 postingState.isMainThread = isMainThread(); // 保存临时状态 , 放置重复调用 postingState.isPosting = true; if (postingState.canceled) { throw new EventBusException("Internal error. Abort state was not reset"); } try { while (!eventQueue.isEmpty()) { // 发送单个事件 , 该方法是核心调用方法 postSingleEvent(eventQueue.remove(0), postingState); } } finally { postingState.isPosting = false; postingState.isMainThread = false; } } } }
二、事件发送 postSingleEvent 方法
首先 , 获取发送的事件类型 ;
// 获取发送的消息事件类型 Class<?> eventClass = event.getClass();
然后通过 eventInheritance 变量 , 判断是否支持事件类型的父类查找 , 该值默认为 true ;
// 判断事件类型的父类 , 向事件的上一级类型查找
// 判断事件类型的父类 , 向事件的上一级类型查找 // 传入的是否是某个事件的父类对象 // 该值默认为 true if (eventInheritance) {
如果支持事件类型父类查找 , 则获取当前所有的事件类型集合 , 进行单个事件的发送 ;
// 获取当前所有的 事件类型 集合 List<Class<?>> eventTypes = lookupAllEventTypes(eventClass); int countTypes = eventTypes.size(); for (int h = 0; h < countTypes; h++) { Class<?> clazz = eventTypes.get(h); // 进行单个事件的发送 subscriptionFound |= postSingleEventForEventType(event, postingState, clazz); }
EventBus.postSingleEvent 方法源码 :
public class EventBus { private void postSingleEvent(Object event, PostingThreadState postingState) throws Error { // 获取发送的消息事件类型 Class<?> eventClass = event.getClass(); boolean subscriptionFound = false; // 判断事件类型的父类 , 向事件的上一级类型查找 // 传入的是否是某个事件的父类对象 // 该值默认为 true if (eventInheritance) { // 获取当前所有的 事件类型 集合 List<Class<?>> eventTypes = lookupAllEventTypes(eventClass); int countTypes = eventTypes.size(); for (int h = 0; h < countTypes; h++) { Class<?> clazz = eventTypes.get(h); // 进行单个事件的发送 subscriptionFound |= postSingleEventForEventType(event, postingState, clazz); } } else { subscriptionFound = postSingleEventForEventType(event, postingState, eventClass); } if (!subscriptionFound) { if (logNoSubscriberMessages) { logger.log(Level.FINE, "No subscribers registered for event " + eventClass); } if (sendNoSubscriberEvent && eventClass != NoSubscriberEvent.class && eventClass != SubscriberExceptionEvent.class) { post(new NoSubscriberEvent(this, event)); } } } }
