- 正确答案：事件总线（Event Bus）是一种发布-订阅（Publish-Subscribe）模式的通信机制，用于在系统组件之间解耦地传递消息。其核心原理是允许发送者（发布者）将事件发送到一个中心化的“总线”，而无需知道哪些接收者（订阅者）会处理该事件；同时，接收者提前注册对特定类型事件的兴趣，当事件发生时自动被通知。 - 解答思路： 1. 首先理解事件总线要解决的问题：组件间通信的高耦合问题，特别是在大型应用或Android等UI框架中。 2. 分析其基本组成：事件（Event）、发布者（Publisher）、订阅者（Subscriber）、事件总线核心（EventBus Core）。 3. 理清工作流程：订阅者注册监听 → 发布者发布事件 → 总线查找匹配的订阅者 → 调用回调方法。 4. 关注底层实现的关键技术：反射、哈希表存储、线程调度、弱引用防止内存泄漏等。 - 深度知识讲解：事件总线的本质是观察者模式的增强版，结合了中介者模式的思想。它通过一个全局可访问的事件分发器来管理所有事件的注册与分发，从而实现跨组件、跨层级的通信。核心数据结构通常包括： - 一个映射表（Map, List）用于保存每个事件类型对应的订阅者列表。 - Subscription 类封装了订阅者对象、回调方法、线程模式等元信息。实现原理步骤如下： 1. 注册（register）：遍历订阅者类中的所有方法，使用反射查找带有 @Subscribe 注解的方法，提取其参数类型（即事件类型），并将该方法和对象存入映射表。 2. 发布（post）：调用 post(event) 后，根据 event.getClass() 查找所有注册过的订阅者方法，然后依次调用它们。 3. 反注册（unregister）：清除指定对象的所有订阅，避免内存泄漏和空指针异常。线程模型设计是关键优化点。常见的线程模式有： - POSTING：在发布线程直接执行（如主线程或子线程） - MAIN：确保在主线程执行（Android UI 更新必须在此） - BACKGROUND：如果发布线程不是主线程，则直接执行；否则放入后台线程队列 - ASYNC：始终异步执行内存泄漏防范：使用弱引用（WeakReference）持有订阅者对象，防止因未反注册导致的Activity/Fragment无法回收。性能优化：采用索引缓存（如 EventBus 的 Subscriber Index），避免运行时频繁反射扫描方法，提升注册速度。应用场景： - Android 中替代复杂的接口回调或广播机制 - 前端框架如 Vue 的 $emit / $on 实质也是事件总线思想 - 微服务中的事件驱动架构（EDA）虽更复杂，但理念相通 - 伪代码示例： ``` class EventBus { // 存储事件类型到订阅者的映射 Map, List> subscriptions = new HashMap<>(); // 注册订阅者 void register(Object subscriber) { Method[] methods = subscriber.getClass().getDeclaredMethods(); for (Method method : methods) { if (method.isAnnotationPresent(Subscribe.class)) { Class eventType = method.getParameterTypes()[0]; Subscription sub = new Subscription(subscriber, method); List list = subscriptions.get(eventType); if (list == null) { list = new ArrayList<>(); subscriptions.put(eventType, list); } list.add(sub); } } } // 反注册 void unregister(Object subscriber) { Iterator, List>> it = subscriptions.entrySet().iterator(); while (it.hasNext()) { List list = it.next().getValue(); list.removeIf(sub -> sub.subscriber == subscriber); } } // 发布事件 void post(Object event) { List list = subscriptions.get(event.getClass()); if (list != null) { for (Subscription sub : list) { // 根据线程模式决定执行线程 switch (sub.threadMode) { case MAIN: if (isMainThread()) { invoke(sub, event); } else { postToMainThread(() -> invoke(sub, event)); } break; case BACKGROUND: if (!isMainThread()) { invoke(sub, event); } else { postToBackgroundThread(() -> invoke(sub, event)); } break; default: invoke(sub, event); } } } } // 反射调用订阅方法 void invoke(Subscription sub, Object event) { try { sub.method.invoke(sub.subscriber, event); } catch (Exception e) { e.printStackTrace(); } } } class Subscription { Object subscriber; Method method; ThreadMode threadMode; Subscription(Object subscriber, Method method) { this.subscriber = subscriber; this.method = method; this.threadMode = method.getAnnotation(Subscribe.class).threadMode(); } } @interface Subscribe { ThreadMode threadMode() default ThreadMode.POSTING; } enum ThreadMode { POSTING, MAIN, BACKGROUND, ASYNC } ``` - 扩展知识点： 1. EventBus 在 Android 中的经典实现是 GreenRobot 的 EventBus 库，广泛应用于早期项目。 2. 现代架构中逐渐被 LiveData + ViewModel 或 Flow 替代，因其更符合生命周期感知原则。 3. 在前端 JavaScript 中，可以简单实现事件总线： const eventBus = { listeners: {}, on(type, fn) { /* 注册 */ }, emit(type, data) { /* 触发 */ } } 4. 分布式系统中的消息中间件（如 Kafka、RabbitMQ）可视为事件总线的分布式版本，支持持久化、多消费者、流量控制等高级特性。总结：事件总线通过解耦发布者与订阅者，提升了系统的模块化程度和可维护性。其核心在于利用反射+哈希表实现动态注册与分发，并通过线程模型保证安全性。尽管现代架构中有所演进，但其设计思想仍是软件工程中的重要范式。

海康前端一面

全站热榜

创作者周榜