EventBus的粘性事件原理

EventBus也称事件总线,根据发送事件的类型分为普通事件和粘性事件。

粘性事件的用法:

1.订阅的时候加上sticky = true

@Subscribe(threadMode = ThreadMode.MAIN, sticky = true)
public fun onEvent() {
    
}

2.post()改为postSticky()

EventBus.getDefault().postSticky(msgEvent)

粘性事件的原理:

事件发送时,接收方还不存在,在接收方注册的时候去处理该事件。

1.调用postSticky,会把粘性事件先保存下来

public void postSticky(Object event) {
    synchronized (stickyEvents) {
        //1.保存粘性时间
        stickyEvents.put(event.getClass(), event);
    }
    //2.如果已经注册了,就会马上响应,按普通事件处理
    post(event);
}

当EventBus注册时,根据注解判断当前方法是否是sticky,如果是的,获取粘性事件,直接调用该订阅方法。

public void register(Object subscriber) {
    //...
    subscribe(subscriber, subscriberMethod);
}

private void subscribe(Object subscriber, SubscriberMethod subscriberMethod) {
    if (subscriberMethod.sticky) {
        if (eventInheritance) {
            Set<Map.Entry<Class<?>, Object>> entries = stickyEvents.entrySet();
            for (Map.Entry<Class<?>, Object> entry : entries) {
                Class<?> candidateEventType = entry.getKey();
                if (eventType.isAssignableFrom(candidateEventType)) {
                    Object stickyEvent = entry.getValue();
                    checkPostStickyEventToSubscription(newSubscription, stickyEvent);
                }
            }
        } else {
            Object stickyEvent = stickyEvents.get(eventType);
            checkPostStickyEventToSubscription(newSubscription, stickyEvent);
        }
    }
}

checkPostStickyEventToSubscription(newSubscription, stickyEvent)方法,最终会去post事件。


版权声明:本文为yinianzhijian99原创文章,遵循CC 4.0 BY-SA版权协议,转载请附上原文出处链接和本声明。