观察者模式在Java发布订阅模型中的实现

观察者模式（Observer Pattern）是一种行为设计模式，它定义了一种一对多的依赖关系，让多个观察者对象同时监听某一个主题对象。当主题对象状态发生改变时，它的所有依赖者（观察者）都会自动收到通知并更新。这种模式在Java中可以通过接口和抽象类来实现发布订阅模型。

在Java中，我们可以使用java.util.Observable类和java.util.Observer接口来实现观察者模式。Observable类是观察者模式的主体，它维护了一个观察者列表，可以在状态改变时通知所有观察者。Observer接口是观察者的抽象表示，它定义了更新方法，用于在接收到通知时执行相应的操作。

下面是一个简单的Java发布订阅模型实现示例：

import java.util.Observable;
import java.util.Observer;

// 定义主题类，继承自Observable
class MySubject extends Observable {
    private int state;

    public void setState(int state) {
        this.state = state;
        // 通知所有观察者状态改变
        setChanged();
        notifyObservers();
    }

    public int getState() {
        return state;
    }
}

// 定义观察者接口，实现Observer接口
class MyObserver implements Observer {
    private String name;

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

    @Override
    public void update(Observable o, Object arg) {
        MySubject subject = (MySubject) o;
        System.out.println(name + " received notification, new state: " + subject.getState());
    }
}

public class ObserverPatternExample {
    public static void main(String[] args) {
        // 创建主题对象
        MySubject subject = new MySubject();

        // 创建观察者对象
        MyObserver observer1 = new MyObserver("Observer1");
        MyObserver observer2 = new MyObserver("Observer2");

        // 将观察者添加到主题对象的观察者列表中
        subject.addObserver(observer1);
        subject.addObserver(observer2);

        // 改变主题对象的状态，触发通知
        subject.setState(1);
        subject.setState(2);
    }
}

在这个示例中，我们创建了一个名为MySubject的主题类，它继承自Observable类。MySubject类有一个setState方法，用于改变主题的状态，并在状态改变时通知所有观察者。我们还创建了一个名为MyObserver的观察者类，它实现了Observer接口，并在update方法中定义了在接收到通知时执行的操作。最后，在main方法中，我们创建了一个主题对象和两个观察者对象，并将观察者添加到主题对象的观察者列表中。通过调用setState方法改变主题对象的状态，我们可以触发通知并执行观察者的操作。