在Java中使用觀察者模式,需要以下幾個步驟:
定義觀察者接口(Observer):該接口中定義了觀察者需要實現的方法,通常包括update()方法,用于接收被觀察者發送的通知。
定義被觀察者接口(Subject):該接口中定義了被觀察者需要實現的方法,通常包括注冊觀察者、移除觀察者、通知觀察者等方法。
實現觀察者接口(具體觀察者):針對具體的觀察者對象,實現觀察者接口中的方法,根據具體需求進行相應的操作。
實現被觀察者接口(具體被觀察者):針對具體的被觀察者對象,實現被觀察者接口中的方法,包括注冊觀察者、移除觀察者、通知觀察者等。
在被觀察者中維護觀察者列表:被觀察者需要維護一個觀察者列表,用于存儲注冊的觀察者對象。
在被觀察者的狀態變化時通知觀察者:當被觀察者的狀態發生變化時,需要遍歷觀察者列表,調用每個觀察者的update()方法,將通知發送給觀察者。
下面是一個簡單的示例代碼:
// 定義觀察者接口
interface Observer {
void update(String message);
}
// 定義被觀察者接口
interface Subject {
void registerObserver(Observer observer);
void removeObserver(Observer observer);
void notifyObservers(String message);
}
// 實現觀察者接口
class ConcreteObserver implements Observer {
private String name;
public ConcreteObserver(String name) {
this.name = name;
}
public void update(String message) {
System.out.println(name + " received message: " + message);
}
}
// 實現被觀察者接口
class ConcreteSubject implements Subject {
private List<Observer> observers = new ArrayList<>();
public void registerObserver(Observer observer) {
observers.add(observer);
}
public void removeObserver(Observer observer) {
observers.remove(observer);
}
public void notifyObservers(String message) {
for (Observer observer : observers) {
observer.update(message);
}
}
}
public class Main {
public static void main(String[] args) {
ConcreteSubject subject = new ConcreteSubject();
Observer observer1 = new ConcreteObserver("Observer1");
subject.registerObserver(observer1);
Observer observer2 = new ConcreteObserver("Observer2");
subject.registerObserver(observer2);
subject.notifyObservers("Hello, world!");
}
}
運行上述代碼,輸出結果為:
Observer1 received message: Hello, world!
Observer2 received message: Hello, world!
可以看到,當被觀察者發送通知時,觀察者接收到了相應的消息。