通用事件监听器设计：基于观察者模式的无侵入式扩展方案

本文介绍如何在不修改现有 aevent 和 bevent 类的前提下，通过观察者模式实现统一事件处理逻辑，提供可复用、松耦合的泛型事件监听机制。

在实际开发中，我们常遇到已有类结构固定、但需新增统一行为（如事件聚合、日志记录、状态同步）的场景。此时若无法修改原始类（如 AEvent、BEvent），直接继承或重写方法不可行，而“硬编码”重复逻辑又违背开闭原则。观察者模式（Observer Pattern）正是解决此类问题的理想选择——它通过引入中介者（Observer）解耦事件源与响应逻辑，实现零侵入、高扩展的监听机制。

核心思路是：将 AEvent 和 BEvent 视为独立的被观察者（Subject），由一个统一的 EventObserver 负责接收通知并协调处理。关键在于不改动原有类定义，仅通过委托（delegation）注入回调能力。以下是推荐实现：

Lessie AI

一款定位为「People Search AI Agent」的AI搜索智能体

下载

✅ 推荐实现（最小侵入 + 类型安全）

// 1. 定义通用事件监听器接口（可选，提升可维护性）
interface EventListener {
    void onEventCreated(T event);
}

// 2. 统一观察者：支持多类型事件聚合与协同处理
class EventObserver {
    private final List> listeners = new ArrayList<>();

    // 注册任意类型事件处理器（泛型擦除下安全使用）
    public  void addListener(EventListener 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 -> 
            System.out.println("✅ Unified handler for A: " + a));
        observer.addListener((EventListener) 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 处理器
    }
}

⚠️ 注意事项与进阶建议