Java Observer 如何實現消息傳遞

在Java中，觀察者模式（Observer Pattern）是一種行為設計模式，它定義了一種一對多的依賴關系，讓多個觀察者對象同時監聽某一個主題對象。當主題對象發生變化時，它會通知所有觀察者對象，使它們能夠自動更新。

要實現消息傳遞，你需要創建一個主題（Subject）類和一個或多個觀察者（Observer）類。以下是一個簡單的示例：

1. 創建一個主題接口（Subject）：

import java.util.ArrayList;
import java.util.List;

public interface Subject {
    void registerObserver(Observer observer);
    void removeObserver(Observer observer);
    void notifyObservers();
}

2. 創建一個具體的主題類（ConcreteSubject），實現主題接口：

public class ConcreteSubject implements Subject {
    private List<Observer> observers;
    private String message;

    public ConcreteSubject() {
        observers = new ArrayList<>();
    }

    @Override
    public void registerObserver(Observer observer) {
        observers.add(observer);
    }

    @Override
    public void removeObserver(Observer observer) {
        observers.remove(observer);
    }

    @Override
    public void notifyObservers() {
        for (Observer observer : observers) {
            observer.update(message);
        }
    }

    public void setMessage(String message) {
        this.message = message;
        notifyObservers();
    }
}

3. 創建一個觀察者接口（Observer）：

public interface Observer {
    void update(String message);
}

4. 創建一個具體的觀察者類（ConcreteObserver），實現觀察者接口：

public class ConcreteObserver implements Observer {
    private String name;

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

    @Override
    public void update(String message) {
        System.out.println(name + " received message: " + message);
    }
}

5. 在主類中測試觀察者模式：

public class Main {
    public static void main(String[] args) {
        ConcreteSubject subject = new ConcreteSubject();
        Observer observer1 = new ConcreteObserver("Observer 1");
        Observer observer2 = new ConcreteObserver("Observer 2");

        subject.registerObserver(observer1);
        subject.registerObserver(observer2);

        subject.setMessage("Hello, Observers!");
    }
}

運行這個程序，你將看到以下輸出：

Observer 1 received message: Hello, Observers!
Observer 2 received message: Hello, Observers!

這個示例展示了如何使用Java實現觀察者模式進行消息傳遞。當主題對象（ConcreteSubject）的狀態發生變化時，它會通知所有注冊的觀察者對象（ConcreteObserver），使它們能夠自動更新。