本文介绍如何在不修改现有 aevent 和 bevent 类的前提下，通过观察者模式实现统一事件处理逻辑，提供可复用、松耦合的泛型事件监听机制。
在实际开发中，我们常遇到已有类结构固定、但需新增统一行为（如事件聚合、日志记录、状态同步）的场景。此时若无法修改原始类（如 AEvent、BEvent），直接继承或重写方法不可行，而“硬编码”重复逻辑又违背开闭原则。观察者模式（Observer Pattern）正是解决此类问题的理想选择——它通过引入中介者（Observer）解耦事件源与响应逻辑，实现零侵入、高扩展的监听机制。
核心思路是：将 AEvent 和 BEvent 视为独立的被观察者（Subject），由一个统一的 EventObserver 负责接收通知并协调处理。关键在于不改动原有类定义，仅通过委托（delegation）注入回调能力。以下是推荐实现：
Miller CSV TSV JSON 数据处理器
下载
Miller (mlr) 是一个命令行工具，用于查询、整形和重新格式化名称索引数据，如 CSV、TSV、JSON 和 JSON Lines。它将 awk、sed、cut、join 和 sort 的功能整合到一个专为结构化数据处理而构建的单一工具中。
✅ 推荐实现（最小侵入 + 类型安全）
// 1. 定义通用事件监听器接口（可选，提升可维护性）
interface EventListener<T> {
void onEventCreated(T event);
}
// 2. 统一观察者：支持多类型事件聚合与协同处理
class EventObserver {
private final List<EventListener<?>> listeners = new ArrayList<>();
// 注册任意类型事件处理器（泛型擦除下安全使用）
public <T> void addListener(EventListener<T> listener) {
listeners.add(listener);
}
// 对外暴露统一触发入口（由各事件类调用）
public void notifyEventCreated(Object event) {
listeners.forEach(listener -> {
// 运行时类型检查，确保安全调用
if (listener instanceof EventListener) {
try {
Method method = listener.getClass()
.getMethod("onEventCreated", event.getClass());
method.invoke(listener, event);
} catch (Exception ignored) {}
}
});
}
}?️ 改造 AEvent / BEvent（仅添加委托方法，不修改业务逻辑）
class AEvent {
private EventObserver observer;
// 仅新增此方法，不破坏原有 API
public void setObserver(EventObserver observer) {
this.observer = observer;
}
public void onAEventCreate(A event) {
// 原有业务逻辑保持不变
System.out.println("Handling A event: " + event);
// 通知观察者（统一入口）
if (observer != null) {
observer.notifyEventCreated(event);
}
}
}
class BEvent {
private EventObserver observer;
public void setObserver(EventObserver observer) {
this.observer = observer;
}
public void onBEventCreate(B event) {
System.out.println("Handling B event: " + event);
if (observer != null) {
observer.notifyEventCreated(event);
}
}
}? 使用示例
public class UsageExample {
public static void main(String[] args) {
EventObserver observer = new EventObserver();
// 注册统一处理器（支持不同事件类型）
observer.addListener((EventListener<A>) a ->
System.out.println("✅ Unified handler for A: " + a));
observer.addListener((EventListener<B>) b ->
System.out.println("✅ Unified handler for B: " + b));
AEvent aEvent = new AEvent();
BEvent bEvent = new BEvent();
aEvent.setObserver(observer);
bEvent.setObserver(observer);
aEvent.onAEventCreate(new A()); // → 触发 A 处理器
bEvent.onBEventCreate(new B()); // → 触发 B 处理器
}
}⚠️ 注意事项与进阶建议
- 避免强耦合：EventObserver 不应持有 AEvent/BEvent 实例引用，仅通过回调通信；
- 线程安全：若事件在多线程环境触发，notifyEventCreated() 应加锁或使用 CopyOnWriteArrayList；
- 生命周期管理：建议增加 removeListener() 方法防止内存泄漏；
-
替代方案对比：
- 策略模式：适用于行为差异大、需运行时切换，但需改造调用方；
- 访问者模式：适合复杂对象结构遍历，此处过度设计；
- 事件总线（如 EventBus）：适合大型系统，但引入第三方依赖，轻量场景不必要。
综上，观察者模式以极小改造成本实现了关注点分离——原始类专注自身职责，观察者专注聚合响应。这不仅是技术方案，更是面向演进系统的设计哲学：让变化发生于可插拔的组件之间，而非固化的类内部。
