一直以來對觀察者模式(Observer)一直理解為訂閱發(fā)布模式，這樣或許更好理解一些。現(xiàn)實中的博客RSS定制（在谷歌pubsubhubbub未出現(xiàn)以前，客戶端都是被動的拉數(shù)據(jù)，PULL模式），需要客戶端主動定時輪詢方可。谷歌PUBSUBHUBBUB協(xié)議的問世，是一個創(chuàng)新，RSS主動推送的協(xié)議，非常實時，發(fā)布-訂閱的最好典型。
觀察者模式的詳細(xì)定義以及相關(guān)理論，可以參見《設(shè)計模式》，里面講的很透徹。
本文將帶來一個在線版本的訂閱-發(fā)布，用戶添加一篇博文，所有訂閱者可以馬上得到通知，主動推送方式，避免了系統(tǒng)的大量無謂請求。雖有點PUBSUBHUBBUB協(xié)議的味道，但離實踐還缺少很多，是一個演示。
這個演示模擬的場景是關(guān)心特定博主的所有訂閱者可以在新的博文發(fā)表之后的瞬間得到通知。從博文的發(fā)布到通知所有的訂閱者知曉，可以以毫秒計算（比較理想的情況下，諸如服務(wù)器性能強勁，網(wǎng)絡(luò)好，算法不錯等）。但這里的訂閱者是有限制的，必須要有一個可以被內(nèi)容發(fā)布者服務(wù)器回調(diào)的URL地址，否則將不能實時通知到訂閱者。這里強調(diào)的是可以被內(nèi)容發(fā)布者服務(wù)器訪問。演示模擬的場景在一個機器上多個站點之間進(jìn)行，同一個局域網(wǎng)其它或者聯(lián)網(wǎng)的環(huán)境下在理論上也都是可以的。
需要先添加訂閱者：
若退訂，步驟相同，致死要選擇“退訂”即可。
這個表單可以放在其它訂閱者站點下面，只是FORM的URL地址要正確。
進(jìn)入站點首頁即可看到所有訂閱者的回調(diào)地址：
有了訂閱者之后，需要添加博文，測試我們的訂閱者。
點擊提交按鈕之后，在各個站點終端下即可看到：
為了演示，我們定義了兩個訂閱者站點: subscribeOne和subscribeTwo，一個顯示所獲取的數(shù)據(jù)，一個把獲取的數(shù)據(jù)持久化到磁盤中。
下面看看主站點的一些代碼，首先來一個傳統(tǒng)意義上觀察者模式。
需要觀察的對象，即目標(biāo) BlogService.java
/**
* 博文操作
* @author yongboy@gmail.com
* @date 2010-10-18
* @version 1.0
*/
public class BlogService {
private static Set<BlogObserver> obserserList;
static {
obserserList = new HashSet<BlogObserver>();
}
public void addBlog(Blog blog) {
System.out.println("保存博文一些操作......");
// 忽略具體邏輯
System.out.println("執(zhí)行通知到所有的訂閱者....");
updateObsersers(blog);
}
private void updateObsersers(Blog blog) {
for (BlogObserver server : obserserList) {
server.update(blog);
}
}
public void addObserver(BlogObserver blogObserver) {
obserserList.add(blogObserver);
}
public void removeObserver(BlogObserver blogObserver) {
obserserList.remove(blogObserver);
}
public void clearObserver() {
obserserList.clear();
}
}
可以看到內(nèi)含觀察者的一些簡單的管理操作。
還需要定義了一個觀察者，接口實現(xiàn)：
public interface BlogObserver {
void update(Blog blog);
}有兩個具體的子類觀察者，一個負(fù)責(zé)把博客的數(shù)據(jù)生成靜態(tài)的文件，但這個不是重點，所以沒有具體的代碼附加；另外一個觀察者負(fù)責(zé)把新的博文通知到所有的訂閱者。
/** * 為新建的博文生成靜態(tài)頁面
*
* @author yongboy@gmail.com
* @date 2010-10-19
* @version 1.0
*/
public class BlogGenPageObserver implements BlogObserver {
public void update(Blog blog) {
// 具體生成代碼省略
System.out.println("博文靜態(tài)頁面觀察者開始工作......");
}
}
/** * 定義一個博客信息推送觀察者
* @author yongboy@gmail.com
* @date 2010-10-18
* @version 1.0
*/
public class BlogNotifyObserver implements BlogObserver {
public void update(Blog blog) {
System.out.println("博文推送觀察者開始工作......");
// 生成單篇博客的RSS
RssService rssService = new RssService(blog);
String rssContent = rssService.ouputRss();
// 通知訂閱者，分發(fā)博客內(nèi)容
NotifyService notifyService = new NotifyService(rssContent);
notifyService.doNotice();
}
}
當(dāng)前端發(fā)布了一篇博文后，會觸發(fā)這兩個觀察者。
訂閱-發(fā)布模型，較適合于一個主端節(jié)點主動向各個訂閱者節(jié)點主動推送信息，相比被動的拉模式，更為節(jié)省網(wǎng)絡(luò)帶寬以及服務(wù)器的性能。
在一個范圍較大的局域網(wǎng)之間，彼此域之間的信息實時通知，也會是一個較好的應(yīng)用。
在范圍更大的互聯(lián)網(wǎng)環(huán)境下，一個具有相當(dāng)大的數(shù)量級訂閱者的主機將可節(jié)省珍貴的機房帶寬，經(jīng)濟(jì)收益不可小覷。
源代碼下載