Java接口可通过默认方法+静态内部类+函数式编程实现轻量事件总线：接口定义契约，default publish()封装发布逻辑，嵌套EventBus类用ConcurrentHashMap和CopyOnWriteArrayList实现线程安全分发，支持Lambda订阅与record事件对象。
Java 接口本身不能直接“实现”事件总线，但可以通过 默认方法 + 静态内部类 + 函数式编程思想，在不依赖第三方库的前提下，快速搭建一个轻量、无反射、类型安全的事件通知机制。关键不是让接口“变成总线”，而是用接口定义契约，用默认方法封装发布逻辑，再配合简单的注册表完成分发。
用接口定义事件契约，用默认方法封装发布行为
把事件看作一种“可被触发的动作”，而不是数据载体。例如：
public interface UserEvent {
void onUserRegistered(String userId);
void onUserDeleted(String userId);
// 默认方法：统一触发入口，避免每个实现类重复写发布逻辑
default void publish() {
EventBus.getInstance().publish(this);
}
}
这样所有实现该接口的事件对象（如 UserRegisteredEvent）只需调用 publish() 就能走统一分发流程——它把“发布动作”下沉到接口层，省去模板代码。
静态内部类实现简易注册与分发核心
在同一个接口中嵌套一个轻量级总线实现（无需 Spring 或 Guava）：
立即学习“Java免费学习笔记（深入）”；
public interface UserEvent {
// ... 上述方法
// 内部总线：用 ConcurrentHashMap + 函数式监听器
class EventBus {
private static final EventBus INSTANCE = new EventBus();
private final Map<Class<?>, List<Consumer<?>>> listeners = new ConcurrentHashMap<>();
private EventBus() {}
public static EventBus getInstance() { return INSTANCE; }
public <T> void subscribe(Class<T> eventType, Consumer<T> handler) {
listeners.computeIfAbsent(eventType, k -> new CopyOnWriteArrayList<>())
.add(handler);
}
@SuppressWarnings("unchecked")
public void publish(Object event) {
listeners.getOrDefault(event.getClass(), Collections.emptyList())
.forEach(h -> ((Consumer<Object>) h).accept(event));
}
}
}
这个 EventBus 是纯 Java 实现，无外部依赖，支持泛型监听，且线程安全（用 CopyOnWriteArrayList 避免遍历时修改异常）。
监听端用 Lambda 注册，彻底告别匿名内部类
订阅时不再写冗长的实现类，直接传 Lambda：
UserEvent.EventBus.getInstance().subscribe(UserRegisteredEvent.class, e -> System.out.println("新用户：" + e.userId));- 事件对象可设计为 record（Java 14+），天然不可变、简洁：
- 发布时只需
new UserRegisteredEvent("u1001").publish();—— 接口默认方法自动调用总线
public record UserRegisteredEvent(String userId) implements UserEvent {}
注意边界：这不是替代 Spring Event 的方案
这种模式适合以下场景：
- 小型工具类、脚本、单模块应用，不想引入 Spring 或 Guava
- 事件数量少（
- 需要编译期类型检查，又不愿写大量观察者模板代码
它不支持异步、不集成 IOC、不处理循环发布，但胜在透明、可控、零配置。真正需要企业级能力时，仍应选用 Spring ApplicationEvent 或 Guava EventBus。
