通用事件监听器设计：基于观察者模式的无侵入式多类型事件统一处理

本文介绍如何在不修改现有 aevent 和 bevent 类的前提下，通过观察者模式实现对不同事件类型（如 onaeventcreate、onbeventcreate）的统一监听与协同响应，提供可扩展、低耦合的事件聚合方案。

在实际开发中，我们常遇到需要对多个异构事件类型进行统一调度或条件触发的场景——例如仅当 A 事件和 B 事件均发生后才执行某项业务逻辑。但受限于遗留代码约束（如无法修改 AEvent/BEvent 的源码），直接抽象共用接口或泛型方法往往不可行。此时，观察者模式（Observer Pattern）结合事件状态委托是一种优雅且低侵入的解决方案。

核心思路是：引入一个中间协调者 EventObserver，它不改变原有事件类的结构，而是通过“轻量级适配”方式监听各事件的生命周期变化。关键在于——将事件“发生”这一动作解耦为“状态变更 + 通知回调”两个阶段，由 EventObserver 负责聚合与决策。

以下为完整实现示例（

以 Java 为例）：

// 协调观察者：负责聚合多个事件状态并触发统一逻辑
class EventObserver {
    private final AEvent aEvent;
    private final BEvent bEvent;
    private boolean aCreated = false;
    private boolean bCreated = false;

    public EventObserver(AEvent aEvent, BEvent bEvent) {
        this.aEvent = aEvent;
        this.bEvent = bEvent;
        // 注册回调（需 AEvent/BEvent 提供 setObserver 方法）
        aEvent.setObserver(this);
        bEvent.setObserver(this);
    }

    // 供 AEvent 调用：标记 A 事件已发生
    public void notifyAEventCreated() {
        this.aCreated = true;
        checkAndTrigger();
    }

    // 供 BEvent 调用：标记 B 事件已发生
    public void notifyBEventCreated() {
        this.bCreated = true;
        checkAndTrigger();
    }

    // 统一检查与触发逻辑
    private void checkAndTrigger() {
        if (aCreated && bCreated) {
            onBothEventsCreated();
            // 可选：重置状态以支持多次触发
            // aCreated = bCreated = false;
        }
    }

    // 子类可覆盖此方法实现具体业务
    protected void onBothEventsCreated() {
        System.out.println("✅ Both AEvent and BEvent have been created.");
        // 执行统一后续操作：如发布领域事件、更新聚合根、触发工作流等
    }
}

对应地，需对原始类做最小化增强（仅添加观察者注册与通知能力，不改动原有业务方法签名）：

class AEvent {
    private EventObserver observer;

    public void setObserver(EventObserver observer) {
        this.observer = observer;
    }

    public void onAEventCreate(A event) {
        // 原有业务逻辑保持不变
        System.out.println("Processing A event: " + event);

        // 新增：通知观察者 A 事件已创建
        if (observer != null) {
            observer.notifyAEventCreated();
        }
    }
}

class BEvent {
    private EventObserver observer;

    public void setObserver(EventObserver observer) {
        this.observer = observer;
    }

    public void onBEventCreate(B event) {
        // 原有业务逻辑保持不变
        System.out.println("Processing B event: " + event);

        // 新增：通知观察者 B 事件已创建
        if (observer != null) {
            observer.notifyBEventCreated();
        }
    }
}

✅ 使用方式：

AEvent a = new AEvent();
BEvent b = new BEvent();
EventObserver coordinator = new EventObserver(a, b);

// 触发事件（顺序无关）
a.onAEventCreate(new A()); // → 触发 notifyAEventCreated()
b.onBEventCreate(new B()); // → 触发 notifyBEventCreated()
// 当二者均完成，自动执行 onBothEventsCreated()

⚠️ 注意事项：

• 此方案要求 AEvent 和 BEvent 至少能接受 setObserver() 注入，属于最小侵入式改造（远优于修改方法签名或继承体系）；
• 若无法修改任何原类（连 setObserver 都不允许），可考虑使用 代理模式 + 动态字节码增强（如 Byte Buddy） 或 事件总线（如 Google Guava EventBus、Spring Event） 进行完全解耦；
• 对于更复杂的事件组合（如“任一发生”“超时未发生”“按序发生”），建议将 EventObserver 升级为状态机驱动的 EventOrchestrator；
• 生产环境建议增加线程安全控制（如 AtomicBoolean 或 synchronized 块），避免并发下状态竞争。

该设计体现了观察者模式的本质价值：解耦事件发布者与消费者，同时保留对事件语义的精确控制力。它不是简单地“监听”，而是构建了一层可编程的事件协调层，为复杂业务规则提供了清晰、可测试、易维护的实现路径。