通用事件监听器的设计：基于观察者模式实现跨类型事件统一处理

聖光之護

发布时间：2026-01-06 21:21:02

980人浏览过

来源于php中文网

原创

通用事件监听器的设计：基于观察者模式实现跨类型事件统一处理

本文介绍如何在不修改现有 aevent 和 bevent 类的前提下，通过观察者模式构建统一事件处理器，实现对不同事件类型（如 onaeventcreate/onbeventcreate）的集中响应与协调。

在实际开发中，我们常遇到多个职责相似但接口不一致的事件处理类（如 AEvent 和 BEvent），它们各自定义了语义相同、签名相似但方法名和参数类型不同的回调逻辑（如 onAEventCreate(A) 和 onBEventCreate(B)）。若需统一调度、组合触发或执行协同操作，又不能修改原有类——此时，观察者模式（Observer Pattern）结合适配器思想是最自然、低侵入的解决方案。

核心思路是：引入一个中介观察者（EventObserver），它不直接依赖具体事件类的接口，而是通过委托+状态同步机制，将异构事件“收敛”到统一的响应入口。关键在于不对原类做结构性改造，仅通过可选的轻量扩展（如添加 setter 和状态字段）建立通信桥梁。

以下是一个生产就绪的实现示例：

// 1. 统一观察者：负责协调与响应
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.setObserver(this);
        bEvent.setObserver(this);
    }

    // 由 AEvent/BEvent 内部调用，通知状态变更
    void notifyAEventCreated() {
        this.aCreated = true;
        checkAndTrigger();
    }

    void notifyBEventCreated() {
        this.bCreated = true;
        checkAndTrigger();
    }

    // 统一响应入口：可根据业务规则灵活定制触发条件
    private void checkAndTrigger() {
        if (aCreated && bCreated) {
            onBothEventsCreated();
            // 可选：重置状态以支持多次触发
            // aCreated = bCreated = false;
        }
    }

    protected void onBothEventsCreated() {
        System.out.println("✅ Both A and B events have been created.");
        // 此处编写跨事件的业务逻辑，如发布聚合消息、启动工作流等
    }
}

对应地，需对 AEvent 和 BEvent 做最小化增强（仅新增两行代码，无逻辑侵入）：

GentleAI

GentleAI是一个高效的AI工作平台，为普通人提供智能计算、简单易用的界面和专业技术支持。让人工智能服务每一个人。

下载

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);

        // 新增：通知观察者
        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);

        // 新增：通知观察者
        if (observer != null) {
            observer.notifyBEventCreated();
        }
    }
}

✅ 优势总结：