如何使用Java Observer模式处理事件

Observer模式是一种行为设计模式，它允许对象（称为观察者）订阅并响应另一个对象（称为主题）的事件。在Java中，Observer模式主要通过java.util.Observer接口和java.util.Observable类来实现。以下是如何使用Java Observer模式处理事件的步骤：

1. 定义观察者接口

首先，定义一个观察者接口，该接口包含一个更新方法，用于接收主题的通知。

public interface Observer {
    void update(Observable o, Object arg);
}

2. 定义主题接口

定义一个主题接口，该接口包含注册、移除和通知观察者的方法。

import java.util.Observable;

public interface Subject extends Observable {
    // 主题接口可以继承Observable类，但通常不需要额外添加方法
}

3. 实现主题类

实现主题类，该类继承Observable类，并在适当的时候调用setChanged()和notifyObservers()方法来通知观察者。

public class ConcreteSubject extends Observable implements Subject {
    private String state;

    public String getState() {
        return state;
    }

    public void setState(String state) {
        this.state = state;
        setChanged(); // 标记状态已改变
        notifyObservers(state); // 通知观察者
    }
}

4. 实现观察者类

实现观察者类，该类实现Observer接口，并在update方法中处理主题的通知。

public class ConcreteObserver implements Observer {
    private String name;

    public ConcreteObserver(String name) {
        this.name = name;
    }

    @Override
    public void update(Observable o, Object arg) {
        if (o instanceof ConcreteSubject) {
            ConcreteSubject subject = (ConcreteSubject) o;
            System.out.println(name + " received update: " + subject.getState());
        }
    }
}

5. 使用Observer模式

创建主题和观察者实例，并将观察者注册到主题中。然后，改变主题的状态，观察者将收到通知。

public class ObserverPatternDemo {
    public static void main(String[] args) {
        ConcreteSubject subject = new ConcreteSubject();

        ConcreteObserver observer1 = new ConcreteObserver("Observer 1");
        ConcreteObserver observer2 = new ConcreteObserver("Observer 2");

        subject.addObserver(observer1);
        subject.addObserver(observer2);

        subject.setState("State 1");
        subject.setState("State 2");

        subject.deleteObserver(observer1);

        subject.setState("State 3");
    }
}

输出

Observer 1 received update: State 1
Observer 2 received update: State 1
Observer 1 received update: State 2
Observer 2 received update: State 2
Observer 2 received update: State 3

注意事项

1. 线程安全：Observable和Observer类不是线程安全的。如果在多线程环境中使用，需要进行适当的同步处理。
2. 废弃的API：从Java 9开始，Observable和Observer类已被标记为废弃。推荐使用java.beans包中的PropertyChangeListener和PropertyChangeSupport类，或者使用第三方库如RxJava来实现更现代的观察者模式。

通过以上步骤，你可以在Java中使用Observer模式来处理事件。