观察者模式定义了对象之间的一对多依赖,这样一来,当一个对象改变状态时,它的所有依赖者都会受到通知并自动更新。
通俗的讲,观察者先告诉被观察者我需要观察的你的某些属性,当这些属性发生变化时就主动通知我。
栗子:不同的读者可以在书店进行订阅服务,当有新书到来时,就让书店主动通知这些订阅者。
在这个例子中,书店就属于被观察者(主题),读者就属于观察者,观察的内容为是否有新书到来。
要实现这样的一种机制,那么首先,读者需要在书店进行订阅,然后书店需要有一份订阅者的名单,然后在有新书到来时就通知读者。
我们需要在书店类中定义一个读者的集合,在读者订阅时添加,取消订阅时就移除,当有新书到来时就遍历集合通知读者。
由于读者有各种类型的人,因此就将这些读者的共同点抽象出来,他们都需要的是订阅服务并受到通知,那么我们就可以定义一个读者接口,其中定义的方法是接受书店传来的通知,不同的读者只需要实现这个接口,然后在受到书店的通知后自己再进行处理即可。
而书店方面,为了让各种类型的书店都能够有这样一种服务,我们就把书店的这种订阅服务也抽象出来定义成一个接口,其中定义方法是注册、取消注册、通知观察者。
代码:
首先是抽象出的书店的订阅服务接口
//主题接口,即书店提供的订阅服务
public interface Subject {
//注册
void register(Observer observer);
//取消注册
void unRegister(Observer observer);
//通知
void notifyObservers();
}
然后是书店的具体实现类,书店不需要管具体的读者是那种类型的,只需要知道,读者是需要订阅服务的,因此在注册时传入的是读者实现的订阅服务的接口
//书店类,实现了订阅服务具体的逻辑
public class BookStore implements Subject{
private List<Observer> observerLsit = new ArrayList<>();
@Override
public void register(Observer observer) {
if(!observerLsit.contains(observer)){
observerLsit.add(observer);
}
}
@Override
public void unRegister(Observer observer) {
if(observerLsit.contains(observer)){
observerLsit.remove(observer);
}
}
public void onNewBookArrived(){
notifyObservers();
}
@Override
public void notifyObservers() {
for(Observer o : observerLsit){
o.update();
}
}
}
然后是读者的接口:
public interface Observer {
void update();
}
最后是两个读者实现类:
public class Boy implements Observer {
private Subject subject;
public Boy(Subject subject){
this.subject = subject;
subject.register(this);
}
@Override
public void update() {
System.out.println("boy----->receive newBookArrived!");
}
}
public class Girl implements Observer {
private Subject subject;
public Girl(Subject subject){
this.subject = subject;
subject.register(this);
}
@Override
public void update() {
System.out.println("girl----->receive newBookArrived!");
}
}
读者在实现类中,需要持有一个书店(被观察者)的接口对象,用来注册和取消注册,并分别具体实现了在收到新书之后的动作。
Test:
public static void main(String[] args) {
BookStore bookStore = new BookStore();
Boy boy = new Boy(bookStore);
Girl girl = new Girl(bookStore);
bookStore.onNewBookArrived();
}
这里我为了简单起见,直接将注册的行为放在了构造方法里,不过将注册和取消注册单独作为一个方法会更好,这样会更灵活,读者可以随时进行注册或取消注册。
这种观察者模式其实是属于“推”,即在属性发生改变的情况下,被观察者主动向观察者推送消息。
还有一种是“拉”,即观察者在需要的时候,再主动获取被观察者的特定属性的状态,省的被观察者老是推送消息。
“拉”模式的实现就是在被观察者中定义需要被观察的属性的get方法,然后观察者因为持有被观察者的引用,就可以在需要时主动来获取需要的状态信息了。