观察者模式也是一种行为型模式,它的作用是将被观察者的任何状态变化传递给观察者。观察者模式在GUI编程的双向绑定等领域都有应用。只要我们希望实现一个类似消息订阅、接收的模式,就可以使用观察者模式。
首先我们需要一个观察者接口,当被观察者发生变化的时候,需要通过该接口的方法通知观察者。
public interface Observer<T> {
void onChanged(T arg);
}
然后是被观察者,当被观察者被更改的时候,需要通过显示调用update()
方法告诉观察者,“我已经发生了更改”。
public class Observable<T> {
private List<Observer<T>> observers = new ArrayList<>();
private T content;
public Observable(T value) {
content = value;
}
public void addObserver(Observer observer) {
observers.add(observer);
}
public void removeObserver(Observer observer) {
observers.remove(observer);
}
protected void update(T value) {
content = value;
for (Observer ob : observers) {
ob.onChanged(content);
}
}
}
然后来看看观察者的实现。这个例子有一点不太好,就是观察者使用了接口,但是被观察者没有使用接口。实际类库中,一般都有被观察者接口,我们可以实现该接口来实现自己的操作。这里的观察者很简单,接受消息,然后打印到终端上。
class ObserverImpl<T> implements Observer<T> {
private String name;
public ObserverImpl(String name) {
this.name = name;
}
@Override
public void onChanged(T arg) {
System.out.println(name + " receives:" + arg);
}
}
最后来测试一下。当被观察者发生更改的时候,观察者成功的接收到了更该消息。
public void run() {
Observable<String> sender = new Observable("value1");
Observer<String> receiver1 = new ObserverImpl<>("ob1");
Observer<String> receiver2 = new ObserverImpl<>("ob2");
sender.addObserver(receiver1);
sender.addObserver(receiver2);
sender.update("value2");
sender.update("value3");
}