觀察者模式在Java發(fā)布訂閱模型中的實(shí)現(xiàn)

觀察者模式（Observer Pattern）是一種行為設(shè)計(jì)模式，它定義了一種一對多的依賴關(guān)系，讓多個觀察者對象同時監(jiān)聽某一個主題對象。當(dāng)主題對象狀態(tài)發(fā)生改變時，它的所有依賴者（觀察者）都會自動收到通知并更新。這種模式在Java中可以通過接口和抽象類來實(shí)現(xiàn)發(fā)布訂閱模型。

在Java中，我們可以使用java.util.Observable類和java.util.Observer接口來實(shí)現(xiàn)觀察者模式。Observable類是觀察者模式的主體，它維護(hù)了一個觀察者列表，可以在狀態(tài)改變時通知所有觀察者。Observer接口是觀察者的抽象表示，它定義了更新方法，用于在接收到通知時執(zhí)行相應(yīng)的操作。

下面是一個簡單的Java發(fā)布訂閱模型實(shí)現(xiàn)示例：

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

// 定義主題類，繼承自O(shè)bservable
class MySubject extends Observable {
    private int state;

    public void setState(int state) {
        this.state = state;
        // 通知所有觀察者狀態(tài)改變
        setChanged();
        notifyObservers();
    }

    public int getState() {
        return state;
    }
}

// 定義觀察者接口，實(shí)現(xiàn)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) {
        // 創(chuàng)建主題對象
        MySubject subject = new MySubject();

        // 創(chuàng)建觀察者對象
        MyObserver observer1 = new MyObserver("Observer1");
        MyObserver observer2 = new MyObserver("Observer2");

        // 將觀察者添加到主題對象的觀察者列表中
        subject.addObserver(observer1);
        subject.addObserver(observer2);

        // 改變主題對象的狀態(tài)，觸發(fā)通知
        subject.setState(1);
        subject.setState(2);
    }
}

在這個示例中，我們創(chuàng)建了一個名為MySubject的主題類，它繼承自Observable類。MySubject類有一個setState方法，用于改變主題的狀態(tài)，并在狀態(tài)改變時通知所有觀察者。我們還創(chuàng)建了一個名為MyObserver的觀察者類，它實(shí)現(xiàn)了Observer接口，并在update方法中定義了在接收到通知時執(zhí)行的操作。最后，在main方法中，我們創(chuàng)建了一個主題對象和兩個觀察者對象，并將觀察者添加到主題對象的觀察者列表中。通過調(diào)用setState方法改變主題對象的狀態(tài)，我們可以觸發(fā)通知并執(zhí)行觀察者的操作。