快捷導(dǎo)航

Java設(shè)計(jì)模式之觀察者模式(Observer Pattern)詳解

更新時(shí)間：2023年07月07日 10:54:34 作者：小威要向諸佬學(xué)習(xí)呀

觀察者模式（Observer Pattern）是一種行為型設(shè)計(jì)模式，它定義了一種一對(duì)多的依賴關(guān)系，當(dāng)一個(gè)對(duì)象的狀態(tài)發(fā)生改變時(shí)，所有依賴于它的對(duì)象都能夠自動(dòng)地得到通知并進(jìn)行更新，本文將詳細(xì)的給大家介紹一下Java觀察者模式,需要的朋友可以參考下

觀察者模式概念

觀察者模式（Observer Pattern）是一種行為型設(shè)計(jì)模式，它定義了一種一對(duì)多的依賴關(guān)系，當(dāng)一個(gè)對(duì)象的狀態(tài)發(fā)生改變時(shí)，所有依賴于它的對(duì)象都能夠自動(dòng)地得到通知并進(jìn)行更新。這種模式也被稱(chēng)作是發(fā)布-訂閱（Publish/Subscribe）模式。

觀察者模式角色

觀察者模式包含以下角色：

抽象主題（Subject）：它把所有觀察者對(duì)象的引用保存在一個(gè)聚集里，并提供了增加和刪除觀察者的方法。它可以是接口或抽象類(lèi)。

具體主題（Concrete Subject）：它將有關(guān)狀態(tài)存入具體觀察者對(duì)象；當(dāng)它的狀態(tài)發(fā)生改變時(shí)，向它的各個(gè)觀察者發(fā)出通知。

抽象觀察者（Observer）：它是觀察者的抽象類(lèi)，它定義了一個(gè)更新接口，使得在得到主題通知時(shí)更新自己。

具體觀察者（Concrete Observer）：實(shí)現(xiàn)抽象觀察者所要求的更新接口，以便使本身的狀態(tài)與主題的狀態(tài)相協(xié)調(diào)。

觀察者模式代碼案例

觀察者模式的實(shí)現(xiàn)通常采取基于接口的編程方式，下面是一個(gè)使用 Java 實(shí)現(xiàn)觀察者模式的示例代碼：

// 抽象主題
public interface Subject {
    void attach(Observer observer);
    void detach(Observer observer);
    void notifyObservers();
}
// 具體主題
public class ConcreteSubject implements Subject {
    private List<Observer> observers = new ArrayList<>();
    private int state;
    public int getState() {
        return state;
    }
    public void setState(int state) {
        this.state = state;
        notifyObservers();
    }
    @Override
    public void attach(Observer observer) {
        observers.add(observer);
    }
    @Override
    public void detach(Observer observer) {
        observers.remove(observer);
    }
    @Override
    public void notifyObservers() {
        for (Observer observer : observers) {
            observer.update(this);
        }
    }
}
// 抽象觀察者
public interface Observer {
    void update(Subject subject);
}
// 具體觀察者
public class ConcreteObserver implements Observer {
    private int state;
    @Override
    public void update(Subject subject) {
        if (subject instanceof ConcreteSubject) {
            state = ((ConcreteSubject) subject).getState();
            System.out.println("State changed to " + state);
        }
    }
}
// 示例代碼
public class Example {
    public static void main(String[] args) {
        // 創(chuàng)建主題和觀察者
        ConcreteSubject subject = new ConcreteSubject();
        Observer observer1 = new ConcreteObserver();
        Observer observer2 = new ConcreteObserver();
        // 注冊(cè)觀察者
        subject.attach(observer1);
        subject.attach(observer2);
        // 改變主題狀態(tài)，觀察者將收到通知并更新自己的狀態(tài)
        subject.setState(1);
        subject.setState(2);
        // 注銷(xiāo)觀察者
        subject.detach(observer2);
        // 再次改變主題狀態(tài)，此時(shí)只有 observer1 收到通知
        subject.setState(3);
    }
}

上面的示例代碼中，ConcreteSubject 作為具體主題，繼承了 Subject 接口并實(shí)現(xiàn)了其中的方法；ConcreteObserver 作為具體觀察者，實(shí)現(xiàn)了 Observer 接口中的方法。當(dāng)主題的狀態(tài)發(fā)生改變時(shí)，會(huì)調(diào)用 notifyObservers() 方法通知所有注冊(cè)過(guò)的觀察者進(jìn)行更新。