关于观察者模式的一些小的Demo
以前总是用，都是从晚上进行copy。今天自己写了一个。
分别定义两个接口。一个是观察者，一个是被观察者。
观察者
/**
* 观察者
*/
public interface ObserverDemo1 {
// 进行更新
void update();
}
进行观察被观察者，当被观察者有变化的时候，进行调用更新的方法。
被观察者
/**
* 被观察者
*/
public interface SubjectDemo1 {
/**
* 注册 observer
*/
void registerObserver(ObserverDemo1 observerDemo1);
/**
* 移除 observer
*/
void removeObserver(ObserverDemo1 observerDemo1);
/**
* 进行通知 所有的观察者
*/
void notifyObservers();
}
里面定义了三个方法
- 对观察者进行注册
- 对观察者进行移除
- 对注册过的观察者们进行注册
被观察者的实现类
实现被观察者中定义的方法。
public class SubjectDemoImpl implements SubjectDemo1 {
private List<ObserverDemo1> observers;
public SubjectDemoImpl() {
observers=new ArrayList<>();
}
@Override
public void registerObserver(ObserverDemo1 observerDemo1) {
observers.add(observerDemo1);
}
@Override
public void removeObserver(ObserverDemo1 observerDemo1) {
observers.remove(observerDemo1);
}
@Override
public void notifyObservers() {
for (ObserverDemo1 observerDemo1 : observers) {
observerDemo1.update();
}
}
}
次方法定义一个，要求所有的观察者都要来引用次方法的实例。在此方法中创建了一个所有观察者的集合类。观察者注册了都要添加到集合中去。
观察者的实现类（可以有很多个，因为观察者很多）
public class ObserverDemo1Impl implements ObserverDemo1 {
private SubjectDemoImpl subjectDemoImpl;
public ObserverDemo1Impl(SubjectDemoImpl subjectDemoImpl) {
this.subjectDemoImpl=subjectDemoImpl;
subjectDemoImpl.registerObserver(this);
}
@Override
public void update() {
System.out.println("开始响应------ObserverDemo1Impl");
}
}
构造方法中一定要引用同一个被观察者。
最后是测试方法
public static void main(String[] args) {
SubjectDemoImpl subjectDemoImpl = new SubjectDemoImpl();
ObserverDemo1Impl observerDemo1Impl = new ObserverDemo1Impl(subjectDemoImpl);
ObserverDemo2Impl observerDemo2Impl = new ObserverDemo2Impl(subjectDemoImpl);
subjectDemoImpl.notifyObservers();
}
