java观察者模式

女爷i 2023-10-13 19:51 27阅读 0赞

在Java中实现观察者模式，可以通过使用Java内置的 `java.util` 包中的类来完成。下面是一个简单的示例：

首先，我们定义一个主题接口（Subject），其中包含注册观察者、移除观察者和通知观察者的方法：

import java.util.Observer;

public interface Subject \{  
void registerObserver(Observer observer);  
void removeObserver(Observer observer);  
void notifyObservers();  
\}  
然后，我们创建一个具体的主题类（ConcreteSubject），实现主题接口，并在其中实现具体的注册、移除和通知逻辑：

import java.util.ArrayList;  
import java.util.List;  
import java.util.Observable;  
import java.util.Observer;

public class ConcreteSubject extends Observable implements Subject \{

private List<Observer> observers;

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() \{  
setChanged();  
for (Observer observer : observers) \{  
observer.update(this, null);  
\}  
\}  
\}  
接下来，我们定义一个观察者接口（Observer），其中包含更新方法用于接收主题的通知：

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

public interface Observer \{  
void update(Observable o, Object arg);  
\}  
然后，我们创建一个具体的观察者类（ConcreteObserver），实现观察者接口，并在其中实现具体的更新逻辑：

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

public class ConcreteObserver implements Observer \{

@Override  
public void update(Observable o, Object arg) \{  
System.out.println("观察者收到更新通知");  
\}  
\}  
现在，我们可以使用观察者模式来实现主题和观察者之间的通信。首先，创建一个具体主题对象和一个或多个具体观察者对象，并将观察者注册到主题上。然后，通过调用主题的 `notifyObservers()` 方法来通知观察者：

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

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

subject.notifyObservers();  
\}  
\}  
输出结果：

观察者收到更新通知  
观察者收到更新通知

这个例子展示了观察者模式的实现方式。通过使用Java内置的 `Observable` 类作为主题，并使用 `Observer` 接口作为观察者，在主题上注册观察者，并通过调用 `notifyObservers()` 方法来通知观察者。观察者接收到通知后，可以执行相应的更新逻辑。