觀察者模式又叫做發(fā)布-訂閱（Publish/Subscribe）模式、模型-視圖（Model/View）模式、源-監(jiān)聽器（Source/Listener）模式或從屬者（Dependents）模式。

?

觀察者模式定義了一種一對(duì)多的依賴關(guān)系，讓多個(gè)觀察者對(duì)象同時(shí)監(jiān)聽某一個(gè)主題對(duì)象。這個(gè)主題對(duì)象在狀態(tài)上發(fā)生變化時(shí)，會(huì)通知所有觀察者對(duì)象，使它們能夠自動(dòng)更新自己。

?

一個(gè)軟件系統(tǒng)常常要求在某一個(gè)對(duì)象的狀態(tài)發(fā)生變化的時(shí)候，某些其它的對(duì)象做出相應(yīng)的改變。做到這一點(diǎn)的設(shè)計(jì)方案有很多，但是為了使系統(tǒng)能夠易于復(fù)用，應(yīng)該選擇低耦合度的設(shè)計(jì)方案。減少對(duì)象之間的耦合有利于系統(tǒng)的復(fù)用，但是同時(shí)設(shè)計(jì)師需要使這些低耦合度的對(duì)象之間能夠維持行動(dòng)的協(xié)調(diào)一致，保證高度的協(xié)作（Collaboration）。觀察者模式是滿足這一要求的各種設(shè)計(jì)方案中最重要的一種。

二，結(jié)構(gòu)

?

?

?

?

?

?

?

?

?

?

?

?

?

?

?

?

?

?

?

?

?

?

抽象主題（Subject）角色 ：主題角色把所有對(duì)觀察考對(duì)象的引用保存在一個(gè)聚集里，每個(gè)主題都可以有任何數(shù)量的觀察者。抽象主題提供一個(gè)接口，可以增加和刪除觀察者對(duì)象，主題角色又叫做抽象被觀察者（Observable）角色，一般用一個(gè)抽象類或者一個(gè)接口實(shí)現(xiàn)。

抽象觀察者（Observer）角色 ：為所有的具體觀察者定義一個(gè)接口，在得到主題的通知時(shí)更新自己。這個(gè)接口叫做更新接口。抽象觀察者角色一般用一個(gè)抽象類或者一個(gè)接口實(shí)現(xiàn)。在這個(gè)示意性的實(shí)現(xiàn)中，更新接口只包含一個(gè)方法（即Update()方法），這個(gè)方法叫做更新方法。

具體主題（ConcreteSubject）角色 ：將有關(guān)狀態(tài)存入具體現(xiàn)察者對(duì)象；在具體主題的內(nèi)部狀態(tài)改變時(shí)，給所有登記過的觀察者發(fā)出通知。具體主題角色又叫做具體被觀察者角色（Concrete Observable）。具體主題角色通常用一個(gè)具體子類實(shí)現(xiàn)。

具體觀察者（ConcreteObserver）角色 ：存儲(chǔ)與主題的狀態(tài)自恰的狀態(tài)。具體現(xiàn)察者角色實(shí)現(xiàn)抽象觀察者角色所要求的更新接口，以便使本身的狀態(tài)與主題的狀態(tài)相協(xié)調(diào)。如果需要，具體現(xiàn)察者角色可以保存一個(gè)指向具體主題對(duì)象的引用。具體觀察者角色通常用一個(gè)具體子類實(shí)現(xiàn)。

三，示例代碼

?

    import java.util.ArrayList;

/**
 * 抽象主題
 * @author Salmon
 *
 */
public abstract class Subject {
	private ArrayList<Observer> observers = new ArrayList<Observer>();

	public void attach(Observer observer) {
		observers.add(observer);
	}

	public void detach(Observer observer) {
		observers.remove(observer);
	}

	public void _notify() {
		for (Observer o : observers)
			o.update();
	}
}

/**
 * 具體主題
 * @author Salmon
 *
 */
public class ConcreteSubject extends Subject {
	private String subjectState;

	public String getSubjectState() {
		return subjectState;
	}

	public void setSubjectState(String subjectState) {
		this.subjectState = subjectState;
	}
}

/**
 * 抽象觀察者
 * @author Salmon
 *
 */
public interface Observer {
	public void update();
}

/**
 * 具體觀察者
 * @author Salmon
 *
 */
public class ConcreteObserver implements Observer {
	private String name;
	private String observerState;
	private ConcreteSubject subject;

	public ConcreteSubject getSubject() {
		return subject;
	}

	public void setSubject(ConcreteSubject subject) {
		this.subject = subject;
	}

	// Constructors
	public ConcreteObserver(ConcreteSubject subject, String name) {
		this.subject = subject;
		this.name = name;
	}

	// Methods
	public void update() {
		observerState = subject.getSubjectState();
		// Console.WriteLine( "Observer {0}'s new state is {1}",
		// name, observerState );
	}
}

/**
 * 客戶代碼
 * @author Salmon
 * 
 */
public class Client {
	public static void Main(String[] args) {
		// Configure Observer structure
		ConcreteSubject s = new ConcreteSubject();
		s.attach(new ConcreteObserver(s, "1"));
		s.attach(new ConcreteObserver(s, "2"));
		s.attach(new ConcreteObserver(s, "3"));

		// Change subject and notify observers
		s.setSubjectState("ABC");
		s._notify();
	}
}
  

?

觀察者(Observer)模式