在Java中,观察者模式是一种行为设计模式,它允许对象(称为主题或可观察者)在其状态发生变化时通知其他对象(称为观察者)。这种模式通常用于实现分布式事件处理系统、新闻订阅、状态监控等场景。
要在Java中实现观察者模式,你需要遵循以下步骤:
Observer的接口,该接口包含一个名为update的方法,用于接收主题的通知。public interface Observer {
void update(Observable o, Object arg);
}
Observable的类,该类包含一个观察者列表和一个名为notifyObservers的方法,用于向观察者发送通知。import java.util.ArrayList;
import java.util.List;
public class Observable {
private List<Observer> observers = new ArrayList<>();
public void addObserver(Observer o) {
observers.add(o);
}
public void removeObserver(Observer o) {
observers.remove(o);
}
protected void notifyObservers(Object arg) {
for (Observer observer : observers) {
observer.update(this, arg);
}
}
}
Observable类,并在状态发生变化时调用notifyObservers方法。public class ConcreteSubject extends Observable {
private String state;
public String getState() {
return state;
}
public void setState(String state) {
this.state = state;
notifyObservers(state);
}
}
Observer接口,并在update方法中处理通知。public class ConcreteObserverA implements Observer {
@Override
public void update(Observable o, Object arg) {
System.out.println("ConcreteObserverA: " + arg);
}
}
public class ConcreteObserverB implements Observer {
@Override
public void update(Observable o, Object arg) {
System.out.println("ConcreteObserverB: " + arg);
}
}
public class Main {
public static void main(String[] args) {
ConcreteSubject subject = new ConcreteSubject();
ConcreteObserverA observerA = new ConcreteObserverA();
ConcreteObserverB observerB = new ConcreteObserverB();
subject.addObserver(observerA);
subject.addObserver(observerB);
subject.setState("State 1");
subject.setState("State 2");
subject.removeObserver(observerA);
subject.setState("State 3");
}
}
当你运行主程序时,你会看到观察者A和观察者B在主题状态发生变化时收到了通知。
免责声明:本站发布的内容(图片、视频和文字)以原创、转载和分享为主,文章观点不代表本网站立场,如果涉及侵权请联系站长邮箱:is@yisu.com进行举报,并提供相关证据,一经查实,将立刻删除涉嫌侵权内容。