觀察者模式定義了對象之間的一對多依賴,這樣一來,當(dāng)一個對象改變狀態(tài)時,它的所有依賴者都會受到通知并自動更新。
通俗的講,觀察者先告訴被觀察者我需要觀察的你的某些屬性,當(dāng)這些屬性發(fā)生變化時就主動通知我。
栗子:不同的讀者可以在書店進行訂閱服務(wù),當(dāng)有新書到來時,就讓書店主動通知這些訂閱者。
在這個例子中,書店就屬于被觀察者(主題),讀者就屬于觀察者,觀察的內(nèi)容為是否有新書到來。
要實現(xiàn)這樣的一種機制,那么首先,讀者需要在書店進行訂閱,然后書店需要有一份訂閱者的名單,然后在有新書到來時就通知讀者。
我們需要在書店類中定義一個讀者的集合,在讀者訂閱時添加,取消訂閱時就移除,當(dāng)有新書到來時就遍歷集合通知讀者。
由于讀者有各種類型的人,因此就將這些讀者的共同點抽象出來,他們都需要的是訂閱服務(wù)并受到通知,那么我們就可以定義一個讀者接口,其中定義的方法是接受書店傳來的通知,不同的讀者只需要實現(xiàn)這個接口,然后在受到書店的通知后自己再進行處理即可。
而書店方面,為了讓各種類型的書店都能夠有這樣一種服務(wù),我們就把書店的這種訂閱服務(wù)也抽象出來定義成一個接口,其中定義方法是注冊、取消注冊、通知觀察者。
代碼:
首先是抽象出的書店的訂閱服務(wù)接口
//主題接口,即書店提供的訂閱服務(wù)
public interface Subject {
//注冊
void register(Observer observer);
//取消注冊
void unRegister(Observer observer);
//通知
void notifyObservers();
}
然后是書店的具體實現(xiàn)類,書店不需要管具體的讀者是那種類型的,只需要知道,讀者是需要訂閱服務(wù)的,因此在注冊時傳入的是讀者實現(xiàn)的訂閱服務(wù)的接口
//書店類,實現(xiàn)了訂閱服務(wù)具體的邏輯
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();
}
最后是兩個讀者實現(xiàn)類:
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!");
}
}
讀者在實現(xiàn)類中,需要持有一個書店(被觀察者)的接口對象,用來注冊和取消注冊,并分別具體實現(xiàn)了在收到新書之后的動作。
Test:
public static void main(String[] args) {
BookStore bookStore = new BookStore();
Boy boy = new Boy(bookStore);
Girl girl = new Girl(bookStore);
bookStore.onNewBookArrived();
}

這里我為了簡單起見,直接將注冊的行為放在了構(gòu)造方法里,不過將注冊和取消注冊單獨作為一個方法會更好,這樣會更靈活,讀者可以隨時進行注冊或取消注冊。
這種觀察者模式其實是屬于“推”,即在屬性發(fā)生改變的情況下,被觀察者主動向觀察者推送消息。
還有一種是“拉”,即觀察者在需要的時候,再主動獲取被觀察者的特定屬性的狀態(tài),省的被觀察者老是推送消息。
“拉”模式的實現(xiàn)就是在被觀察者中定義需要被觀察的屬性的get方法,然后觀察者因為持有被觀察者的引用,就可以在需要時主動來獲取需要的狀態(tài)信息了。