Java中的事件总线与观察者模式：含示例的指南

Java中的事件总线与观察者模式

现代应用程序越来越倾向于构建在事件驱动架构之上。在Java中实现这种模型的两个关键工具是观察者模式及其演进——事件总线。在本文中，我们将分析它们的区别、如何实现每一种模式，以及哪些库可以帮助简化开发。

什么是观察者模式？

观察者模式是一种行为设计模式，其中一个对象（主题）通知多个依赖对象（观察者）其状态的变化。在Java中，这种模式常用于图形界面、日志系统和事件处理。

关键组件：

• Subject — 事件源，管理观察者列表
• Observer — 所有订阅者实现的接口
• ConcreteSubject — 主题的具体实现
• ConcreteObserver — 具体的观察者

纯Java实现示例：

// 观察者接口interface Observer {    void update(String event);}

// 主题接口interface Subject {    void attach(Observer observer);    void detach(Observer observer);    void notifyObservers(String event);}

// 具体主题class EventManager implements Subject {    private List<Observer> observers = new ArrayList<>();        @Override    public void attach(Observer observer) {        observers.add(observer);    }        @Override    public void detach(Observer observer) {        observers.remove(observer);    }        @Override    public void notifyObservers(String event) {        for (Observer observer : observers) {            observer.update(event);        }    }        public void fireEvent(String event) {        System.out.println("事件: " + event);        notifyObservers(event);    }}

// 具体观察者class LogObserver implements Observer {    @Override    public void update(String event) {        System.out.println("日志: 收到事件 - " + event);    }}

// 使用示例public class ObserverDemo {    public static void main(String[] args) {        EventManager manager = new EventManager();        manager.attach(new LogObserver());        manager.fireEvent("用户已登录系统");    }}

什么是事件总线？

事件总线是一种在应用程序组件之间进行消息交换的集中式机制。与经典的观察者模式不同（其中主题直接管理订阅者），事件总线通过一个公共总线将事件的发送者和接收者分离开来。

事件总线的优势：

• 组件之间的松散耦合
• 简化的订阅和发布
• 支持按类型过滤事件
• 异步处理（可选）

Guava EventBus库

Google Guava提供了一个强大的事件总线实现。它广泛应用于工业项目，并且易于集成。

Maven依赖：

<dependency>    <groupId>com.google.guava</groupId>    <artifactId>guava</artifactId>    <version>33.0.0-jre</version></dependency>

使用示例：

import com.google.common.eventbus.EventBus;import com.google.common.eventbus.Subscribe;

// 事件类class UserLoginEvent {    private final String username;        public UserLoginEvent(String username) {        this.username = username;    }        public String getUsername() {