亲自实践：构建一个事件总线

Android

2023-11-12 02:52:19

事件总线：简化 Android 应用中组件交互的神奇工具

在现代 Android 应用开发中，组件之间的通信至关重要，例如 Activity 跳转、Fragment 交互和耗时操作的回调。传统上，组件会互相持有引用，导致代码臃肿且耦合性高。

事件总线 脱颖而出，成为一种轻量级、松散耦合的解决方案。它允许组件通过发布和订阅事件进行通信，而无需直接引用彼此，从而大大降低了代码复杂度。

事件总线的运作原理

事件总线就像一个信使，它负责在组件之间传递信息：

事件发布： 组件发布一个事件，其中包含要传递的数据。
事件订阅： 其他组件订阅该事件，并提供一个回调方法，以便在事件发生时执行。
事件分发： 当事件发布时，事件总线将事件传递给所有订阅该事件的组件。

自己动手构建事件总线

构建一个简单的事件总线并不复杂。让我们分解其核心逻辑：

public class EventBus {

    private Map<Class<?>, Set<Subscriber>> subscribersByEventType;

    public EventBus() {
        subscribersByEventType = new HashMap<>();
    }

    public <T> void subscribe(Class<T> eventType, Subscriber<T> subscriber) {
        Set<Subscriber> subscribers = subscribersByEventType.getOrDefault(eventType, new HashSet<>());
        subscribers.add(subscriber);
        subscribersByEventType.put(eventType, subscribers);
    }

    public <T> void unsubscribe(Class<T> eventType, Subscriber<T> subscriber) {
        Set<Subscriber> subscribers = subscribersByEventType.get(eventType);
        if (subscribers != null) {
            subscribers.remove(subscriber);
        }
    }

    public <T> void post(T event) {
        Class<?> eventType = event.getClass();
        Set<Subscriber> subscribers = subscribersByEventType.get(eventType);
        if (subscribers != null) {
            for (Subscriber subscriber : subscribers) {
                subscriber.onEvent(event);
            }
        }
    }

    public interface Subscriber<T> {
        void onEvent(T event);
    }
}