观察者模式(Observer Pattern)

末蓝、 2022-03-31 07:10 234阅读 0赞

[设计模式 - 吕震宇][-]  
[.NET设计模式系列文章][.NET]  
[(薛敬明的专栏)][Link 1]

[乐在其中设计模式(C\#)][C]

[  
][C]

# [设计模式（19）－Observer Pattern][19_Observer Pattern] #

## 一、 观察者（Observer）模式 ##

观察者模式又叫做发布-订阅（Publish/Subscribe）模式、模型-视图（Model/View）模式、源-监听器（Source/Listener）模式或从属者（Dependents）模式。

观察者模式定义了一种一对多的依赖关系，让多个观察者对象同时监听某一个主题对象。这个主题对象在状态上发生变化时，会通知所有观察者对象，使它们能够自动更新自己。

一个软件系统常常要求在某一个对象的状态发生变化的时候，某些其它的对象做出相应的改变。做到这一点的设计方案有很多，但是为了使系统能够易于复用，应该选择低耦合度的设计方案。减少对象之间的耦合有利于系统的复用，但是同时设计师需要使这些低耦合度的对象之间能够维持行动的协调一致，保证高度的协作（Collaboration）。观察者模式是满足这一要求的各种设计方案中最重要的一种。

##    二、 观察者模式的结构 ##

观察者模式的类图如下：

![PicX00105.gif][]

可以看出，在这个观察者模式的实现里有下面这些角色：

*  抽象主题（Subject）角色：主题角色把所有对观察考对象的引用保存在一个聚集里，每个主题都可以有任何数量的观察者。抽象主题提供一个接口，可以增加和删除观察者对象，主题角色又叫做抽象被观察者（Observable）角色，一般用一个抽象类或者一个接口实现。
 *  抽象观察者（Observer）角色：为所有的具体观察者定义一个接口，在得到主题的通知时更新自己。这个接口叫做更新接口。抽象观察者角色一般用一个抽象类或者一个接口实现。在这个示意性的实现中，更新接口只包含一个方法（即Update()方法），这个方法叫做更新方法。
 *  具体主题（ConcreteSubject）角色：将有关状态存入具体现察者对象；在具体主题的内部状态改变时，给所有登记过的观察者发出通知。具体主题角色又叫做具体被观察者角色（Concrete Observable）。具体主题角色通常用一个具体子类实现。
 *  具体观察者（ConcreteObserver）角色：存储与主题的状态自恰的状态。具体现察者角色实现抽象观察者角色所要求的更新接口，以便使本身的状态与主题的状态相协调。如果需要，具体现察者角色可以保存一个指向具体主题对象的引用。具体观察者角色通常用一个具体子类实现。

从具体主题角色指向抽象观察者角色的合成关系，代表具体主题对象可以有任意多个对抽象观察者对象的引用。之所以使用抽象观察者而不是具体观察者，意味着主题对象不需要知道引用了哪些ConcreteObserver类型，而只知道抽象Observer类型。这就使得具体主题对象可以动态地维护一系列的对观察者对象的引用，并在需要的时候调用每一个观察者共有的Update()方法。这种做法叫做"针对抽象编程"。

##    三、 观察者模式的示意性源代码 ##

![None.gif][] //  Observer pattern -- Structural example    
![None.gif][] using  System;  
![None.gif][] using  System.Collections;  
![None.gif][]  
![None.gif][] //  "Subject"   
![None.gif][] abstract  class  Subject  
![ExpandedBlockStart.gif][] \{  
![InBlock.gif][]// Fields  
![InBlock.gif][]private ArrayList observers =new ArrayList();  
![InBlock.gif][]  
![InBlock.gif][]// Methods  
![InBlock.gif][]publicvoid Attach( Observer observer )  
![ExpandedSubBlockStart.gif][]\{  
![InBlock.gif][] observers.Add( observer );  
![ExpandedSubBlockEnd.gif][] \}  
![InBlock.gif][]  
![InBlock.gif][]publicvoid Detach( Observer observer )  
![ExpandedSubBlockStart.gif][]\{  
![InBlock.gif][] observers.Remove( observer );  
![ExpandedSubBlockEnd.gif][] \}  
![InBlock.gif][]  
![InBlock.gif][]publicvoid Notify()  
![ExpandedSubBlockStart.gif][]\{  
![InBlock.gif][]foreach( Observer o in observers )  
![InBlock.gif][] o.Update();  
![ExpandedSubBlockEnd.gif][] \}  
![ExpandedBlockEnd.gif][]\}   
![None.gif][]  
![None.gif][] //  "ConcreteSubject"   
![None.gif][] class  ConcreteSubject : Subject  
![ExpandedBlockStart.gif][] \{  
![InBlock.gif][]// Fields  
![InBlock.gif][]privatestring subjectState;  
![InBlock.gif][]  
![InBlock.gif][]// Properties  
![InBlock.gif][]publicstring SubjectState  
![ExpandedSubBlockStart.gif][]\{  
![ExpandedSubBlockStart.gif][]get\{ return subjectState; \}  
![ExpandedSubBlockStart.gif][]set\{ subjectState = value; \}  
![ExpandedSubBlockEnd.gif][] \}  
![ExpandedBlockEnd.gif][]\}   
![None.gif][]  
![None.gif][] //  "Observer"   
![None.gif][] abstract  class  Observer  
![ExpandedBlockStart.gif][] \{  
![InBlock.gif][]// Methods  
![InBlock.gif][]abstractpublicvoid Update();  
![ExpandedBlockEnd.gif][]\}   
![None.gif][]  
![None.gif][] //  "ConcreteObserver"   
![None.gif][] class  ConcreteObserver : Observer  
![ExpandedBlockStart.gif][] \{  
![InBlock.gif][]// Fields  
![InBlock.gif][]privatestring name;  
![InBlock.gif][]privatestring observerState;  
![InBlock.gif][]private ConcreteSubject subject;  
![InBlock.gif][]  
![InBlock.gif][]// Constructors  
![InBlock.gif][]public ConcreteObserver( ConcreteSubject subject,  
![InBlock.gif][]string name )  
![ExpandedSubBlockStart.gif][]\{  
![InBlock.gif][]this.subject = subject;  
![InBlock.gif][]this.name = name;  
![ExpandedSubBlockEnd.gif][] \}  
![InBlock.gif][]  
![InBlock.gif][]// Methods  
![InBlock.gif][]overridepublicvoid Update()  
![ExpandedSubBlockStart.gif][]\{  
![InBlock.gif][] observerState = subject.SubjectState;  
![InBlock.gif][] Console.WriteLine( "Observer \{0\}'s new state is \{1\}",  
![InBlock.gif][] name, observerState );  
![ExpandedSubBlockEnd.gif][] \}  
![InBlock.gif][]  
![InBlock.gif][]// Properties  
![InBlock.gif][]public ConcreteSubject Subject  
![ExpandedSubBlockStart.gif][]\{  
![ExpandedSubBlockStart.gif][]get\{ return subject; \}  
![ExpandedSubBlockStart.gif][]set\{ subject = value; \}  
![ExpandedSubBlockEnd.gif][] \}  
![ExpandedBlockEnd.gif][]\}   
![None.gif][]  
![ExpandedBlockStart.gif][] ///<summary>  
![InBlock.gif][]/// Client test  
![ExpandedBlockEnd.gif][]///</summary>  
![None.gif][] public  class  Client  
![ExpandedBlockStart.gif][] \{  
![InBlock.gif][]publicstaticvoid Main( string\[\] args )  
![ExpandedSubBlockStart.gif][]\{  
![InBlock.gif][]// Configure Observer structure  
![InBlock.gif][] ConcreteSubject s =new ConcreteSubject();  
![InBlock.gif][] s.Attach( new ConcreteObserver( s, "1" ) );  
![InBlock.gif][] s.Attach( new ConcreteObserver( s, "2" ) );  
![InBlock.gif][] s.Attach( new ConcreteObserver( s, "3" ) );  
![InBlock.gif][]  
![InBlock.gif][]// Change subject and notify observers  
![InBlock.gif][] s.SubjectState ="ABC";  
![InBlock.gif][] s.Notify();  
![ExpandedSubBlockEnd.gif][] \}  
![ExpandedBlockEnd.gif][]\}

##    四、 C\#中的Delegate与Event ##

实际上在C\#中实现Observer模式没有这么辛苦，.NET中提供了Delegate与Event机制，我们可以利用这种机制简化Observer模式。关于Delegate与Event的使用方法请参考相关文档。改进后的Observer模式实现如下：

![None.gif][] //  Observer pattern -- Structural example    
![None.gif][] using  System;  
![None.gif][]  
![None.gif][] // Delegate   
![None.gif][] delegate  void  UpdateDelegate();  
![None.gif][]  
![None.gif][] // Subject   
![None.gif][] class  Subject  
![ExpandedBlockStart.gif][] \{  
![InBlock.gif][]publicevent UpdateDelegate UpdateHandler;  
![InBlock.gif][]  
![InBlock.gif][]// Methods  
![InBlock.gif][]publicvoid Attach( UpdateDelegate ud )  
![ExpandedSubBlockStart.gif][]\{  
![InBlock.gif][] UpdateHandler \+= ud;  
![ExpandedSubBlockEnd.gif][] \}  
![InBlock.gif][]  
![InBlock.gif][]publicvoid Detach( UpdateDelegate ud )  
![ExpandedSubBlockStart.gif][]\{  
![InBlock.gif][] UpdateHandler \-= ud;  
![ExpandedSubBlockEnd.gif][] \}  
![InBlock.gif][]  
![InBlock.gif][]publicvoid Notify()  
![ExpandedSubBlockStart.gif][]\{  
![InBlock.gif][]if(UpdateHandler !=null) UpdateHandler();  
![ExpandedSubBlockEnd.gif][] \}  
![InBlock.gif][]  
![ExpandedBlockEnd.gif][]\}   
![None.gif][]  
![None.gif][] // ConcreteSubject   
![None.gif][] class  ConcreteSubject : Subject  
![ExpandedBlockStart.gif][] \{  
![InBlock.gif][]// Fields  
![InBlock.gif][]privatestring subjectState;  
![InBlock.gif][]  
![InBlock.gif][]// Properties  
![InBlock.gif][]publicstring SubjectState  
![ExpandedSubBlockStart.gif][]\{  
![ExpandedSubBlockStart.gif][]get\{ return subjectState; \}  
![ExpandedSubBlockStart.gif][]set\{ subjectState = value; \}  
![ExpandedSubBlockEnd.gif][] \}  
![ExpandedBlockEnd.gif][]\}   
![None.gif][]  
![None.gif][] //  "ConcreteObserver"   
![None.gif][] class  ConcreteObserver  
![ExpandedBlockStart.gif][] \{  
![InBlock.gif][]// Fields  
![InBlock.gif][]privatestring name;  
![InBlock.gif][]privatestring observerState;  
![InBlock.gif][]private ConcreteSubject subject;  
![InBlock.gif][]  
![InBlock.gif][]// Constructors  
![InBlock.gif][]public ConcreteObserver( ConcreteSubject subject,  
![InBlock.gif][]string name )  
![ExpandedSubBlockStart.gif][]\{  
![InBlock.gif][]this.subject = subject;  
![InBlock.gif][]this.name = name;  
![ExpandedSubBlockEnd.gif][] \}  
![InBlock.gif][]  
![InBlock.gif][]// Methods  
![InBlock.gif][]publicvoid Update()  
![ExpandedSubBlockStart.gif][]\{  
![InBlock.gif][] observerState = subject.SubjectState;  
![InBlock.gif][] Console.WriteLine( "Observer \{0\}'s new state is \{1\}",  
![InBlock.gif][] name, observerState );  
![ExpandedSubBlockEnd.gif][] \}  
![InBlock.gif][]  
![InBlock.gif][]// Properties  
![InBlock.gif][]public ConcreteSubject Subject  
![ExpandedSubBlockStart.gif][]\{  
![ExpandedSubBlockStart.gif][]get\{ return subject; \}  
![ExpandedSubBlockStart.gif][]set\{ subject = value; \}  
![ExpandedSubBlockEnd.gif][] \}  
![ExpandedBlockEnd.gif][]\}   
![None.gif][]  
![None.gif][] //  "ConcreteObserver"   
![None.gif][] class  AnotherObserver  
![ExpandedBlockStart.gif][] \{  
![InBlock.gif][]// Methods  
![InBlock.gif][]publicvoid Show()  
![ExpandedSubBlockStart.gif][]\{  
![InBlock.gif][] Console.WriteLine("AnotherObserver got an Notification!");  
![ExpandedSubBlockEnd.gif][] \}  
![ExpandedBlockEnd.gif][]\}   
![None.gif][]  
![None.gif][] public  class  Client  
![ExpandedBlockStart.gif][] \{  
![InBlock.gif][]publicstaticvoid Main(string\[\] args)  
![ExpandedSubBlockStart.gif][]\{  
![InBlock.gif][] ConcreteSubject s =new ConcreteSubject();  
![InBlock.gif][] ConcreteObserver o1 =new ConcreteObserver(s, "1");  
![InBlock.gif][] ConcreteObserver o2 =new ConcreteObserver(s, "2");  
![InBlock.gif][] AnotherObserver o3 =new AnotherObserver();  
![InBlock.gif][]  
![InBlock.gif][] s.Attach(new UpdateDelegate(o1.Update));  
![InBlock.gif][] s.Attach(new UpdateDelegate(o2.Update));  
![InBlock.gif][] s.Attach(new UpdateDelegate(o3.Show));  
![InBlock.gif][]  
![InBlock.gif][] s.SubjectState ="ABC";  
![InBlock.gif][] s.Notify();  
![InBlock.gif][]  
![InBlock.gif][] Console.WriteLine("\--------------------------");  
![InBlock.gif][] s.Detach(new UpdateDelegate(o1.Update));  
![InBlock.gif][]  
![InBlock.gif][] s.SubjectState ="DEF";  
![InBlock.gif][] s.Notify();  
![ExpandedSubBlockEnd.gif][] \}  
![ExpandedBlockEnd.gif][]\}

其中，关键的代码如下：

![None.gif][] delegate  void  UpdateDelegate();

定义一个Delegate，用来规范函数结构。不管是ConcreteObserver类的Update方法还是AnotherObserver类的Show方法都符合该Delegate。这不象用Observer接口来规范必须使用Update方法那么严格。只要符合Delegate所指定的方法结构的方法都可以在后面被事件所处理。

![None.gif][] public  event  UpdateDelegate UpdateHandler;

定义一个事件，一旦触发，可以调用一组符合UpdateDelegate规范的方法。

![None.gif][]  public  void  Attach( UpdateDelegate ud )  
![ExpandedBlockStart.gif][] \{  
![InBlock.gif][] UpdateHandler \+= ud;  
![ExpandedBlockEnd.gif][] \}

订阅事件。只要是一个满足UpdateDelegate的方法，就可以进行订阅操作（如下所示）。

![None.gif][]  s.Attach( new  UpdateDelegate(o1.Update));  
![None.gif][] s.Attach( new  UpdateDelegate(o2.Update));  
![None.gif][] s.Attach( new  UpdateDelegate(o3.Show));

在Notify方法中：

![None.gif][]  public  void  Notify()  
![ExpandedBlockStart.gif][] \{  
![InBlock.gif][]if(UpdateHandler !=null) UpdateHandler();  
![ExpandedBlockEnd.gif][] \}

只要UpdateHandler != null（表示有订阅者），就可以触发事件（UpdateHandler()），所有的订阅者便会接到通知。

##    五、 一个实际应用观察者模式的例子 ##

该例子演示了注册的投资者在股票市场发生变化时，可以自动得到通知。该例子仍然使用的是传统的Observer处理手段，至于如何转换成Delegate与Event留给读者自己考虑。

![None.gif][] //  Observer pattern -- Real World example    
![None.gif][] using  System;  
![None.gif][] using  System.Collections;  
![None.gif][]  
![None.gif][] //  "Subject"   
![None.gif][] abstract  class  Stock  
![ExpandedBlockStart.gif][] \{  
![InBlock.gif][]// Fields  
![InBlock.gif][]protectedstring symbol;  
![InBlock.gif][]protecteddouble price;  
![InBlock.gif][]private ArrayList investors =new ArrayList();  
![InBlock.gif][]  
![InBlock.gif][]// Constructor  
![InBlock.gif][]public Stock( string symbol, double price )  
![ExpandedSubBlockStart.gif][]\{  
![InBlock.gif][]this.symbol = symbol;  
![InBlock.gif][]this.price = price;  
![ExpandedSubBlockEnd.gif][] \}  
![InBlock.gif][]  
![InBlock.gif][]// Methods  
![InBlock.gif][]publicvoid Attach( Investor investor )  
![ExpandedSubBlockStart.gif][]\{  
![InBlock.gif][] investors.Add( investor );  
![ExpandedSubBlockEnd.gif][] \}  
![InBlock.gif][]  
![InBlock.gif][]publicvoid Detach( Investor investor )  
![ExpandedSubBlockStart.gif][]\{  
![InBlock.gif][] investors.Remove( investor );  
![ExpandedSubBlockEnd.gif][] \}  
![InBlock.gif][]  
![InBlock.gif][]publicvoid Notify()  
![ExpandedSubBlockStart.gif][]\{  
![InBlock.gif][]foreach( Investor i in investors )  
![InBlock.gif][] i.Update( this );  
![ExpandedSubBlockEnd.gif][] \}  
![InBlock.gif][]  
![InBlock.gif][]// Properties  
![InBlock.gif][]publicdouble Price  
![ExpandedSubBlockStart.gif][]\{  
![ExpandedSubBlockStart.gif][]get\{ return price; \}  
![InBlock.gif][]set  
![ExpandedSubBlockStart.gif][]\{  
![InBlock.gif][] price = value;  
![InBlock.gif][] Notify();  
![ExpandedSubBlockEnd.gif][] \}  
![ExpandedSubBlockEnd.gif][] \}  
![InBlock.gif][]  
![InBlock.gif][]publicstring Symbol  
![ExpandedSubBlockStart.gif][]\{  
![ExpandedSubBlockStart.gif][]get\{ return symbol; \}  
![ExpandedSubBlockStart.gif][]set\{ symbol = value; \}  
![ExpandedSubBlockEnd.gif][] \}  
![ExpandedBlockEnd.gif][]\}   
![None.gif][]  
![None.gif][] //  "ConcreteSubject"   
![None.gif][] class  IBM : Stock  
![ExpandedBlockStart.gif][] \{  
![InBlock.gif][]// Constructor  
![InBlock.gif][]public IBM( string symbol, double price )  
![ExpandedSubBlockStart.gif][] : base( symbol, price ) \{\}  
![ExpandedBlockEnd.gif][]\}   
![None.gif][]  
![None.gif][] //  "Observer"   
![None.gif][] interface  IInvestor  
![ExpandedBlockStart.gif][] \{  
![InBlock.gif][]// Methods  
![InBlock.gif][]void Update( Stock stock );  
![ExpandedBlockEnd.gif][]\}   
![None.gif][]  
![None.gif][] //  "ConcreteObserver"   
![None.gif][] class  Investor : IInvestor  
![ExpandedBlockStart.gif][] \{  
![InBlock.gif][]// Fields  
![InBlock.gif][]privatestring name;  
![InBlock.gif][]privatestring observerState;  
![InBlock.gif][]private Stock stock;  
![InBlock.gif][]  
![InBlock.gif][]// Constructors  
![InBlock.gif][]public Investor( string name )  
![ExpandedSubBlockStart.gif][]\{  
![InBlock.gif][]this.name = name;  
![ExpandedSubBlockEnd.gif][] \}  
![InBlock.gif][]  
![InBlock.gif][]// Methods  
![InBlock.gif][]publicvoid Update( Stock stock )  
![ExpandedSubBlockStart.gif][]\{  
![InBlock.gif][] Console.WriteLine( "Notified investor \{0\} of \{1\}'s change to \{2:C\}",  
![InBlock.gif][] name, stock.Symbol, stock.Price );  
![ExpandedSubBlockEnd.gif][] \}  
![InBlock.gif][]  
![InBlock.gif][]// Properties  
![InBlock.gif][]public Stock Stock  
![ExpandedSubBlockStart.gif][]\{  
![ExpandedSubBlockStart.gif][]get\{ return stock; \}  
![ExpandedSubBlockStart.gif][]set\{ stock = value; \}  
![ExpandedSubBlockEnd.gif][] \}  
![ExpandedBlockEnd.gif][]\}   
![None.gif][]  
![ExpandedBlockStart.gif][] ///<summary>  
![InBlock.gif][]/// ObserverApp test  
![ExpandedBlockEnd.gif][]///</summary>  
![None.gif][] public  class  ObserverApp  
![ExpandedBlockStart.gif][] \{  
![InBlock.gif][]publicstaticvoid Main( string\[\] args )  
![ExpandedSubBlockStart.gif][]\{  
![InBlock.gif][]// Create investors  
![InBlock.gif][] Investor s =new Investor( "Sorros" );  
![InBlock.gif][] Investor b =new Investor( "Berkshire" );  
![InBlock.gif][]  
![InBlock.gif][]// Create IBM stock and attach investors  
![InBlock.gif][] IBM ibm =new IBM( "IBM", 120.00 );  
![InBlock.gif][] ibm.Attach( s );  
![InBlock.gif][] ibm.Attach( b );  
![InBlock.gif][]  
![InBlock.gif][]// Change price, which notifies investors  
![InBlock.gif][] ibm.Price =120.10;  
![InBlock.gif][] ibm.Price =121.00;  
![InBlock.gif][] ibm.Price =120.50;  
![InBlock.gif][] ibm.Price =120.75;  
![ExpandedSubBlockEnd.gif][] \}  
![ExpandedBlockEnd.gif][]\}

##    六、 观察者模式的优缺点 ##

Observer模式的优点是实现了表示层和数据逻辑层的分离，并定义了稳定的更新消息传递机制，类别清晰，并抽象了更新接口，使得可以有各种各样不同的表示层（观察者）。

但是其缺点是每个外观对象必须继承这个抽像出来的接口类，这样就造成了一些不方便，比如有一个别人写的外观对象，并没有继承该抽象类，或者接口不对，我们又希望不修改该类直接使用它。虽然可以再应用Adapter模式来一定程度上解决这个问题，但是会造成更加复杂烦琐的设计，增加出错几率。

观察者模式的效果有以下几个优点：

（1）观察者模式在被观察者和观察者之间建立一个抽象的耦合。被观察者角色所知道的只是一个具体现察者聚集，每一个具体现察者都符合一个抽象观察者的接口。被观察者并不认识任何一个具体观察者，它只知道它们都有一个共同的接口。由于被观察者和观察者没有紧密地耦合在一起，因此它们可以属于不同的抽象化层次。

（2）观察者模式支持广播通信。被观察者会向所有的登记过的观察者发出通知。

观察者模式有下面的一些缺点：

（1）如果一个被观察者对象有很多直接和间接的观察者的话，将所有的观察者都通知到会花费很多时间。

（2）如果在被观察者之间有循环依赖的话，被观察者会触发它们之间进行循环调用，导致系统崩溃。在使用观察考模式时要特别注意这一点。

（3）如果对观察者的通知是通过另外的线程进行异步投递的话，系统必须保证投递是以自恰的方式进行的。

（4）虽然观察者模式可以随时使观察者知道所观察的对象发生了变化，但是观察者模式没有相应的机制使观察者知道所观察的对象是怎么发生变化的。

--------------------

参考文献：  
阎宏，《Java与模式》，电子工业出版社  
\[美\]James W. Cooper，《C\#设计模式》，电子工业出版社  
\[美\]Alan Shalloway James R. Trott，《Design Patterns Explained》，中国电力出版社  
\[美\]Robert C. Martin，《敏捷软件开发－原则、模式与实践》，清华大学出版社  
\[美\]Don Box, Chris Sells，《.NET本质论 第1卷：公共语言运行库》，中国电力出版社

# [.NET设计模式（19）：观察者模式（Observer Pattern）][.NET_19_Observer Pattern] #

**概述**

在软件构建过程中，我们需要为某些对象建立一种“通知依赖关系” ——一个对象（目标对象）的状态发生改变，所有的依赖对象（观察者对象）都将得到通知。如果这样的依赖关系过于紧密，将使软件不能很好地抵御变化。使用面向对象技术，可以将这种依赖关系弱化，并形成一种稳定的依赖关系。从而实现软件体系结构的松耦合。

**意图**

定义对象间的一种一对多的依赖关系,当一个对象的状态发生改变时, 所有依赖于它的对象都得到通知并被自动更新。\[GOF 《设计模式》\]

**结构图**

![Observer_02.gif][]

图1 Observer模式结构图

**生活中的例子**

观察者定义了对象间一对多的关系，当一个对象的状态变化时，所有依赖它的对象都得到通知并且自动地更新。拍卖演示了这种模式。每个投标人都有一个标有数字的牌子用于出价。拍卖师开始拍卖时，他观察是否有牌子举起出价。每次接受一个新的出价都改变了拍卖的当前价格，并且广播给所有的投标人进行新的出价。

![Observer_01.gif][]  
图2 使用拍卖例子的观察者模式

**Observer模式解说**

下面通过一个例子来说明Observer模式。监控某一个公司的股票价格变化，可以有多种方式，通知的对象可以是投资者，或者是发送到移动设备，还有电子邮件等。一开始我们先不考虑Observer模式，通过一步步地重构，最终重构为Observer模式。现在有这样两个类：Microsoft和Investor，如下图所示：

![Observer_03.gif][]

图3 UML静态图示例

它们的实现如下：

![None.gif][] public  class  Microsoft  
![None.gif][]  
![ExpandedBlockStart.gif][] \{  
![InBlock.gif][]private Investor \_investor;  
![InBlock.gif][]  
![InBlock.gif][]private String \_symbol;  
![InBlock.gif][]  
![InBlock.gif][]privatedouble \_price;  
![InBlock.gif][]  
![InBlock.gif][]  
![InBlock.gif][]publicvoid Update()  
![InBlock.gif][]  
![ExpandedSubBlockStart.gif][]\{  
![InBlock.gif][] \_investor.SendData(this);  
![ExpandedSubBlockEnd.gif][] \}  
![InBlock.gif][]  
![InBlock.gif][]public Investor Investor  
![InBlock.gif][]  
![ExpandedSubBlockStart.gif][]\{  
![ExpandedSubBlockStart.gif][]get\{ return \_investor; \}  
![InBlock.gif][]  
![ExpandedSubBlockStart.gif][]set\{ \_investor = value; \}  
![ExpandedSubBlockEnd.gif][] \}  
![InBlock.gif][]  
![InBlock.gif][]public String Symbol  
![InBlock.gif][]  
![ExpandedSubBlockStart.gif][]\{  
![ExpandedSubBlockStart.gif][]get\{ return \_symbol; \}  
![InBlock.gif][]  
![ExpandedSubBlockStart.gif][]set\{ \_symbol = value; \}  
![ExpandedSubBlockEnd.gif][] \}  
![InBlock.gif][]  
![InBlock.gif][]publicdouble Price  
![ExpandedSubBlockStart.gif][]\{  
![ExpandedSubBlockStart.gif][]get\{ return \_price; \}  
![InBlock.gif][]  
![ExpandedSubBlockStart.gif][]set\{ \_price = value; \}  
![ExpandedSubBlockEnd.gif][] \}  
![ExpandedBlockEnd.gif][]\}   
![None.gif][]  
![None.gif][]  
![None.gif][] public  class  Investor  
![None.gif][]  
![ExpandedBlockStart.gif][] \{  
![InBlock.gif][]privatestring \_name;  
![InBlock.gif][]  
![InBlock.gif][]public Investor(string name)  
![InBlock.gif][]  
![ExpandedSubBlockStart.gif][]\{  
![InBlock.gif][]this.\_name = name;  
![ExpandedSubBlockEnd.gif][] \}  
![InBlock.gif][]  
![InBlock.gif][]publicvoid SendData(Microsoft ms)  
![InBlock.gif][]  
![ExpandedSubBlockStart.gif][]\{  
![InBlock.gif][] Console.WriteLine("Notified \{0\} of \{1\}'s "\+"change to \{2:C\}", \_name, ms.Symbol,ms.Price);  
![InBlock.gif][]  
![ExpandedSubBlockEnd.gif][] \}  
![InBlock.gif][]  
![ExpandedBlockEnd.gif][]\}   
![None.gif][]

简单的客户端实现：

![None.gif][] class  Program  
![None.gif][]  
![ExpandedBlockStart.gif][] \{  
![InBlock.gif][]  
![InBlock.gif][]staticvoid Main(string\[\] args)  
![InBlock.gif][]  
![ExpandedSubBlockStart.gif][]\{  
![InBlock.gif][]  
![InBlock.gif][] Investor investor =new Investor("Jom");  
![InBlock.gif][]  
![InBlock.gif][] Microsoft ms =new Microsoft();  
![InBlock.gif][]  
![InBlock.gif][] ms.Investor = investor;  
![InBlock.gif][]  
![InBlock.gif][] ms.Symbol ="Microsoft";  
![InBlock.gif][]  
![InBlock.gif][] ms.Price =120.00;  
![InBlock.gif][]  
![InBlock.gif][]  
![InBlock.gif][] ms.Update();  
![InBlock.gif][]  
![InBlock.gif][] Console.ReadLine();  
![InBlock.gif][]  
![ExpandedSubBlockEnd.gif][] \}  
![InBlock.gif][]  
![ExpandedBlockEnd.gif][]\}

运行后结果如下：

Notified Jom of Microsoft's change to ￥120

可以看到，这段代码运行并没有问题，也确实实现了我们最初的设想的功能，把Microsoft的股票价格变化通知到了Jom投资者那儿。但是这里面出现了如下几个问题：

1．Microsoft和Investor之间形成了一种双向的依赖关系，即Microsoft调用了Investor的方法，而Investor调用了Microsoft类的属性。如果有其中一个类变化，有可能会引起另一个的变化。

2．当出现一种的通知对象，比如说是移动设备Mobile：

![None.gif][] public  class  Mobile  
![None.gif][]  
![ExpandedBlockStart.gif][] \{  
![InBlock.gif][]privatestring \_no;  
![InBlock.gif][]  
![InBlock.gif][]public Mobile(string No)  
![InBlock.gif][]  
![ExpandedSubBlockStart.gif][]\{  
![InBlock.gif][]this.\_no = No;  
![ExpandedSubBlockEnd.gif][] \}  
![InBlock.gif][]  
![InBlock.gif][]publicvoid SendData(Microsoft ms)  
![InBlock.gif][]  
![ExpandedSubBlockStart.gif][]\{  
![InBlock.gif][] Console.WriteLine("Notified \{0\} of \{1\}'s "\+"change to \{2:C\}", \_no, ms.Symbol, ms.Price);  
![InBlock.gif][]  
![ExpandedSubBlockEnd.gif][] \}  
![InBlock.gif][]  
![ExpandedBlockEnd.gif][]\}   
![None.gif][]

这时候对应的Microsoft的类就应该改变为如下代码，在Microsot类中增加Mobile，同时修改Update()方法使其可以通知到移动设备：

![None.gif][] public  class  Microsoft  
![None.gif][]  
![ExpandedBlockStart.gif][] \{  
![InBlock.gif][]private Investor \_investor;  
![InBlock.gif][]  
![InBlock.gif][]private Mobile \_mobile;  
![InBlock.gif][]  
![InBlock.gif][]private String \_symbol;  
![InBlock.gif][]  
![InBlock.gif][]privatedouble \_price;  
![InBlock.gif][]  
![InBlock.gif][]  
![InBlock.gif][]publicvoid Update()  
![InBlock.gif][]  
![ExpandedSubBlockStart.gif][]\{  
![InBlock.gif][] \_investor.SendData(this);  
![InBlock.gif][]  
![InBlock.gif][] \_mobile.SendData(this);  
![ExpandedSubBlockEnd.gif][] \}  
![InBlock.gif][]  
![InBlock.gif][]  
![InBlock.gif][]  
![InBlock.gif][]public Mobile Mobile  
![InBlock.gif][]  
![ExpandedSubBlockStart.gif][]\{  
![ExpandedSubBlockStart.gif][]get\{ return \_mobile; \}  
![InBlock.gif][]  
![ExpandedSubBlockStart.gif][]set\{ \_mobile = value; \}  
![ExpandedSubBlockEnd.gif][] \}  
![InBlock.gif][]  
![InBlock.gif][]public Investor Investor  
![InBlock.gif][]  
![ExpandedSubBlockStart.gif][]\{  
![ExpandedSubBlockStart.gif][]get\{ return \_investor; \}  
![InBlock.gif][]  
![ExpandedSubBlockStart.gif][]set\{ \_investor = value; \}  
![ExpandedSubBlockEnd.gif][] \}  
![InBlock.gif][]  
![InBlock.gif][]public String Symbol  
![InBlock.gif][]  
![ExpandedSubBlockStart.gif][]\{  
![ExpandedSubBlockStart.gif][]get\{ return \_symbol; \}  
![InBlock.gif][]  
![ExpandedSubBlockStart.gif][]set\{ \_symbol = value; \}  
![ExpandedSubBlockEnd.gif][] \}  
![InBlock.gif][]  
![InBlock.gif][]publicdouble Price  
![InBlock.gif][]  
![ExpandedSubBlockStart.gif][]\{  
![ExpandedSubBlockStart.gif][]get\{ return \_price; \}  
![InBlock.gif][]  
![ExpandedSubBlockStart.gif][]set\{ \_price = value; \}  
![ExpandedSubBlockEnd.gif][] \}  
![InBlock.gif][]  
![ExpandedBlockEnd.gif][]\}

显然这样的设计极大的违背了“开放-封闭”原则，这不是我们所想要的，仅仅是新增加了一种通知对象，就需要对原有的Microsoft类进行修改，这样的设计是很糟糕的。对此做进一步的抽象，既然出现了多个通知对象，我们就为这些对象之间抽象出一个接口，用它来取消Microsoft和具体的通知对象之间依赖。

![Observer_04.gif][]

图4 静态UML图示例

实现代码如下：

![None.gif][] public  interface  IObserver  
![None.gif][]  
![ExpandedBlockStart.gif][] \{  
![InBlock.gif][]void SendData(Microsoft ms);  
![ExpandedBlockEnd.gif][]\}   
![None.gif][]  
![None.gif][]  
![None.gif][]  
![None.gif][] public  class  Investor : IObserver  
![None.gif][]  
![ExpandedBlockStart.gif][] \{  
![InBlock.gif][]privatestring \_name;  
![InBlock.gif][]  
![InBlock.gif][]public Investor(string name)  
![InBlock.gif][]  
![ExpandedSubBlockStart.gif][]\{  
![InBlock.gif][]this.\_name = name;  
![ExpandedSubBlockEnd.gif][] \}  
![InBlock.gif][]  
![InBlock.gif][]publicvoid SendData(Microsoft ms)  
![InBlock.gif][]  
![ExpandedSubBlockStart.gif][]\{  
![InBlock.gif][] Console.WriteLine("Notified \{0\} of \{1\}'s "\+"change to \{2:C\}", \_name, ms.Symbol,ms.Price);  
![InBlock.gif][]  
![ExpandedSubBlockEnd.gif][] \}  
![ExpandedBlockEnd.gif][]\}   
![None.gif][]  
![None.gif][] public  class  Microsoft  
![None.gif][]  
![ExpandedBlockStart.gif][] \{  
![InBlock.gif][]private IObserver \_investor;  
![InBlock.gif][]  
![InBlock.gif][]  
![InBlock.gif][]private String \_symbol;  
![InBlock.gif][]  
![InBlock.gif][]privatedouble \_price;  
![InBlock.gif][]  
![InBlock.gif][]  
![InBlock.gif][]publicvoid Update()  
![InBlock.gif][]  
![ExpandedSubBlockStart.gif][]\{  
![InBlock.gif][] \_investor.SendData(this);  
![ExpandedSubBlockEnd.gif][] \}  
![InBlock.gif][]  
![InBlock.gif][]  
![InBlock.gif][]  
![InBlock.gif][]public String Symbol  
![InBlock.gif][]  
![ExpandedSubBlockStart.gif][]\{  
![ExpandedSubBlockStart.gif][]get\{ return \_symbol; \}  
![InBlock.gif][]  
![ExpandedSubBlockStart.gif][]set\{ \_symbol = value; \}  
![ExpandedSubBlockEnd.gif][] \}  
![InBlock.gif][]  
![InBlock.gif][]  
![InBlock.gif][]publicdouble Price  
![InBlock.gif][]  
![ExpandedSubBlockStart.gif][]\{  
![ExpandedSubBlockStart.gif][]get\{ return \_price; \}  
![InBlock.gif][]  
![ExpandedSubBlockStart.gif][]set\{ \_price = value; \}  
![ExpandedSubBlockEnd.gif][] \}  
![InBlock.gif][]  
![InBlock.gif][]  
![InBlock.gif][]public IObserver Investor  
![InBlock.gif][]  
![ExpandedSubBlockStart.gif][]\{  
![ExpandedSubBlockStart.gif][]get\{ return \_investor; \}  
![InBlock.gif][]  
![ExpandedSubBlockStart.gif][]set\{ \_investor = value; \}  
![ExpandedSubBlockEnd.gif][] \}  
![InBlock.gif][]  
![ExpandedBlockEnd.gif][]\}

做到这一步，可以看到，我们在降低两者的依赖性上已经迈进了一小步，正在朝着弱依赖性这个方向变化。在Microsoft类中已经不再依赖于具体的Investor，而是依赖于接口IObserver。

但同时我们看到，再新出现一个移动设备这样的通知对象，Microsoft类仍然需要改变，对此我们再做如下重构，在Microsoft中维护一个IObserver列表，同时提供相应的维护方法。

![Observer_05.gif][]

图5 静态UML示例图

Microsoft类的实现代码如下：

![None.gif][] public  class  Microsoft  
![None.gif][]  
![ExpandedBlockStart.gif][] \{  
![InBlock.gif][]private List<IObserver> observers =new List<IObserver>();  
![InBlock.gif][]  
![InBlock.gif][]private String \_symbol;  
![InBlock.gif][]  
![InBlock.gif][]privatedouble \_price;  
![InBlock.gif][]  
![InBlock.gif][]publicvoid Update()  
![InBlock.gif][]  
![ExpandedSubBlockStart.gif][]\{  
![InBlock.gif][]foreach (IObserver ob in observers)  
![ExpandedSubBlockStart.gif][]\{  
![InBlock.gif][] ob.SendData(this);  
![ExpandedSubBlockEnd.gif][] \}  
![InBlock.gif][]  
![ExpandedSubBlockEnd.gif][] \}  
![InBlock.gif][]  
![InBlock.gif][]publicvoid AddObserver(IObserver observer)  
![InBlock.gif][]  
![ExpandedSubBlockStart.gif][]\{  
![InBlock.gif][] observers.Add(observer);  
![ExpandedSubBlockEnd.gif][] \}  
![InBlock.gif][]  
![InBlock.gif][]publicvoid RemoveObserver(IObserver observer)  
![InBlock.gif][]  
![ExpandedSubBlockStart.gif][]\{  
![InBlock.gif][] observers.Remove(observer);  
![ExpandedSubBlockEnd.gif][] \}  
![InBlock.gif][]  
![InBlock.gif][]public String Symbol  
![InBlock.gif][]  
![ExpandedSubBlockStart.gif][]\{  
![ExpandedSubBlockStart.gif][]get\{ return \_symbol; \}  
![InBlock.gif][]  
![ExpandedSubBlockStart.gif][]set\{ \_symbol = value; \}  
![ExpandedSubBlockEnd.gif][] \}  
![InBlock.gif][]  
![InBlock.gif][]publicdouble Price  
![InBlock.gif][]  
![ExpandedSubBlockStart.gif][]\{  
![ExpandedSubBlockStart.gif][]get\{ return \_price; \}  
![InBlock.gif][]  
![ExpandedSubBlockStart.gif][]set\{ \_price = value; \}  
![ExpandedSubBlockEnd.gif][] \}  
![InBlock.gif][]  
![ExpandedBlockEnd.gif][]\}   
![None.gif][]

此时客户端的调用代码：

![None.gif][] class  Program  
![None.gif][]  
![ExpandedBlockStart.gif][] \{  
![InBlock.gif][]staticvoid Main(string\[\] args)  
![InBlock.gif][]  
![ExpandedSubBlockStart.gif][]\{  
![InBlock.gif][] IObserver investor1 =new Investor("Jom");  
![InBlock.gif][]  
![InBlock.gif][] IObserver investor2 =new Investor("TerryLee");  
![InBlock.gif][]  
![InBlock.gif][] Microsoft ms =new Microsoft();  
![InBlock.gif][]  
![InBlock.gif][] ms.Symbol ="Microsoft";  
![InBlock.gif][]  
![InBlock.gif][] ms.Price =120.00;  
![InBlock.gif][]  
![InBlock.gif][] ms.AddObserver(investor1);  
![InBlock.gif][]  
![InBlock.gif][] ms.AddObserver(investor2);  
![InBlock.gif][]  
![InBlock.gif][] ms.Update();  
![InBlock.gif][]  
![InBlock.gif][] Console.ReadLine();  
![ExpandedSubBlockEnd.gif][] \}  
![ExpandedBlockEnd.gif][]\}

走到这一步，已经有了Observer模式的影子了，Microsoft类不再依赖于具体的Investor，而是依赖于抽象的IOberver。存在着的一个问题是Investor仍然依赖于具体的公司Microsoft，况且公司还会有很多IBM，Google等，解决这样的问题很简单，只需要再对Microsoft类做一次抽象。如下图所示：

![Observer_06.gif][]

图6 静态UML示例图

实现代码如下：

![None.gif][] public  abstract  class  Stock  
![None.gif][]  
![ExpandedBlockStart.gif][] \{  
![InBlock.gif][]private List<IObserver> observers =new List<IObserver>();  
![InBlock.gif][]  
![InBlock.gif][]private String \_symbol;  
![InBlock.gif][]  
![InBlock.gif][]privatedouble \_price;  
![InBlock.gif][]  
![InBlock.gif][]public Stock(String symbol, double price)  
![InBlock.gif][]  
![ExpandedSubBlockStart.gif][]\{  
![InBlock.gif][]this.\_symbol = symbol;  
![InBlock.gif][]  
![InBlock.gif][]this.\_price = price;  
![ExpandedSubBlockEnd.gif][] \}  
![InBlock.gif][]  
![InBlock.gif][]publicvoid Update()  
![InBlock.gif][]  
![ExpandedSubBlockStart.gif][]\{  
![InBlock.gif][]foreach (IObserver ob in observers)  
![InBlock.gif][]  
![ExpandedSubBlockStart.gif][]\{  
![InBlock.gif][] ob.SendData(this);  
![ExpandedSubBlockEnd.gif][] \}  
![InBlock.gif][]  
![ExpandedSubBlockEnd.gif][] \}  
![InBlock.gif][]  
![InBlock.gif][]publicvoid AddObserver(IObserver observer)  
![InBlock.gif][]  
![ExpandedSubBlockStart.gif][]\{  
![InBlock.gif][] observers.Add(observer);  
![ExpandedSubBlockEnd.gif][] \}  
![InBlock.gif][]  
![InBlock.gif][]publicvoid RemoveObserver(IObserver observer)  
![InBlock.gif][]  
![ExpandedSubBlockStart.gif][]\{  
![InBlock.gif][] observers.Remove(observer);  
![ExpandedSubBlockEnd.gif][] \}  
![InBlock.gif][]  
![InBlock.gif][]public String Symbol  
![InBlock.gif][]  
![ExpandedSubBlockStart.gif][]\{  
![ExpandedSubBlockStart.gif][]get\{ return \_symbol; \}  
![ExpandedSubBlockEnd.gif][] \}  
![InBlock.gif][]  
![InBlock.gif][]publicdouble Price  
![InBlock.gif][]  
![ExpandedSubBlockStart.gif][]\{  
![ExpandedSubBlockStart.gif][]get\{ return \_price; \}  
![ExpandedSubBlockEnd.gif][] \}  
![ExpandedBlockEnd.gif][]\}   
![None.gif][]  
![None.gif][] public  class  Microsoft : Stock  
![None.gif][]  
![ExpandedBlockStart.gif][] \{  
![InBlock.gif][]  
![InBlock.gif][]public Microsoft(String symbol, double price)  
![InBlock.gif][]  
![InBlock.gif][] : base(symbol, price)  
![InBlock.gif][]  
![ExpandedSubBlockStart.gif][]\{ \}  
![ExpandedBlockEnd.gif][]\}   
![None.gif][]  
![None.gif][] public  interface  IObserver  
![None.gif][]  
![ExpandedBlockStart.gif][] \{  
![InBlock.gif][]void SendData(Stock stock);  
![ExpandedBlockEnd.gif][]\}   
![None.gif][]  
![None.gif][] public  class  Investor : IObserver  
![None.gif][]  
![ExpandedBlockStart.gif][] \{  
![InBlock.gif][]privatestring \_name;  
![InBlock.gif][]  
![InBlock.gif][]public Investor(string name)  
![InBlock.gif][]  
![ExpandedSubBlockStart.gif][]\{  
![InBlock.gif][]this.\_name = name;  
![ExpandedSubBlockEnd.gif][] \}  
![InBlock.gif][]  
![InBlock.gif][]publicvoid SendData(Stock stock)  
![InBlock.gif][]  
![ExpandedSubBlockStart.gif][]\{  
![InBlock.gif][] Console.WriteLine("Notified \{0\} of \{1\}'s "\+"change to \{2:C\}", \_name, stock.Symbol,stock.Price);  
![InBlock.gif][]  
![ExpandedSubBlockEnd.gif][] \}  
![InBlock.gif][]  
![ExpandedBlockEnd.gif][]\}   
![None.gif][]

客户端程序代码如下：

![None.gif][] class  Program  
![None.gif][]  
![ExpandedBlockStart.gif][] \{  
![InBlock.gif][]staticvoid Main(string\[\] args)  
![InBlock.gif][]  
![ExpandedSubBlockStart.gif][]\{  
![InBlock.gif][] Stock ms =new Microsoft("Microsoft",120.00);  
![InBlock.gif][]  
![InBlock.gif][] ms.AddObserver(new Investor("Jom"));  
![InBlock.gif][]  
![InBlock.gif][] ms.AddObserver(new Investor("TerryLee"));  
![InBlock.gif][]  
![InBlock.gif][] ms.Update();  
![InBlock.gif][]  
![InBlock.gif][] Console.ReadLine();  
![ExpandedSubBlockEnd.gif][] \}  
![InBlock.gif][]  
![ExpandedBlockEnd.gif][]\}

到这里我们可以看到，通过不断的重构，不断地抽象，我们由一开始的很糟糕的设计，逐渐重构为使用Observer模式的这样一个方案。在这个例子里面，IOberser充当了观察者的角色，而Stock则扮演了主题对象角色，在任何时候，只要调用了Stock的Update()方法，它就会通知它的所有观察者对象。同时可以看到，通过Observer模式，取消了直接依赖，变为间接依赖，这样大大提供了系统的可维护性和可扩展性。

**推模式与拉模式**

对于发布-订阅模型，大家都很容易能想到推模式与拉模式，用SQL Server做过数据库复制的朋友对这一点很清楚。在Observer模式中同样区分推模式和拉模式，我先简单的解释一下两者的区别：推模式是当有消息时，把消息信息以参数的形式传递（推）给所有观察者，而拉模式是当有消息时，通知消息的方法本身并不带任何的参数，是由观察者自己到主体对象那儿取回（拉）消息。知道了这一点，大家可能很容易发现上面我所举的例子其实是一种推模式的Observer模式。我们先看看这种模式带来了什么好处：当有消息时，所有的观察者都会直接得到全部的消息，并进行相应的处理程序，与主体对象没什么关系，两者之间的关系是一种松散耦合。但是它也有缺陷，第一是所有的观察者得到的消息是一样的，也许有些信息对某个观察者来说根本就用不上，也就是观察者不能“按需所取”；第二，当通知消息的参数有变化时，所有的观察者对象都要变化。鉴于以上问题，拉模式就应运而生了，它是由观察者自己主动去取消息，需要什么信息，就可以取什么，不会像推模式那样得到所有的消息参数。OK，说到这儿，你是否对于推模式和拉模式有了一点了解呢？我把前面的例子修改为了拉模式，供大家参考，可以看到通知方法是没有任何参数的：

![None.gif][] public  abstract  class  Stock  
![None.gif][]  
![ExpandedBlockStart.gif][] \{  
![InBlock.gif][]private List<IObserver> observers =new List<IObserver>();  
![InBlock.gif][]  
![InBlock.gif][]private String \_symbol;  
![InBlock.gif][]  
![InBlock.gif][]privatedouble \_price;  
![InBlock.gif][]  
![InBlock.gif][]public Stock(String symbol, double price)  
![InBlock.gif][]  
![ExpandedSubBlockStart.gif][]\{  
![InBlock.gif][]this.\_symbol = symbol;  
![InBlock.gif][]  
![InBlock.gif][]this.\_price = price;  
![ExpandedSubBlockEnd.gif][] \}  
![InBlock.gif][]  
![InBlock.gif][]publicvoid Update()  
![InBlock.gif][]  
![ExpandedSubBlockStart.gif][]\{  
![InBlock.gif][]foreach (IObserver ob in observers)  
![InBlock.gif][]  
![ExpandedSubBlockStart.gif][]\{  
![InBlock.gif][] ob.SendData();  
![ExpandedSubBlockEnd.gif][] \}  
![ExpandedSubBlockEnd.gif][] \}  
![InBlock.gif][]  
![InBlock.gif][]publicvoid AddObserver(IObserver observer)  
![InBlock.gif][]  
![ExpandedSubBlockStart.gif][]\{  
![InBlock.gif][] observers.Add(observer);  
![ExpandedSubBlockEnd.gif][] \}  
![InBlock.gif][]  
![InBlock.gif][]publicvoid RemoveObserver(IObserver observer)  
![InBlock.gif][]  
![ExpandedSubBlockStart.gif][]\{  
![InBlock.gif][] observers.Remove(observer);  
![ExpandedSubBlockEnd.gif][] \}  
![InBlock.gif][]  
![InBlock.gif][]public String Symbol  
![InBlock.gif][]  
![ExpandedSubBlockStart.gif][]\{  
![ExpandedSubBlockStart.gif][]get\{ return \_symbol; \}  
![ExpandedSubBlockEnd.gif][] \}  
![InBlock.gif][]  
![InBlock.gif][]publicdouble Price  
![InBlock.gif][]  
![ExpandedSubBlockStart.gif][]\{  
![ExpandedSubBlockStart.gif][]get\{ return \_price; \}  
![ExpandedSubBlockEnd.gif][] \}  
![ExpandedBlockEnd.gif][]\}   
![None.gif][]  
![None.gif][] public  class  Microsoft : Stock  
![None.gif][]  
![ExpandedBlockStart.gif][] \{  
![InBlock.gif][]public Microsoft(String symbol, double price)  
![InBlock.gif][]  
![InBlock.gif][] : base(symbol, price)  
![ExpandedSubBlockStart.gif][]\{ \}  
![ExpandedBlockEnd.gif][]\}   
![None.gif][]  
![None.gif][] public  interface  IObserver  
![None.gif][]  
![ExpandedBlockStart.gif][] \{  
![InBlock.gif][]void SendData();  
![ExpandedBlockEnd.gif][]\}   
![None.gif][]  
![None.gif][] public  class  Investor : IObserver  
![None.gif][]  
![ExpandedBlockStart.gif][] \{  
![InBlock.gif][]privatestring \_name;  
![InBlock.gif][]  
![InBlock.gif][]private Stock \_stock;  
![InBlock.gif][]  
![InBlock.gif][]public Investor(string name,Stock stock)  
![InBlock.gif][]  
![ExpandedSubBlockStart.gif][]\{  
![InBlock.gif][]this.\_name = name;  
![InBlock.gif][]  
![InBlock.gif][]this.\_stock = stock;  
![ExpandedSubBlockEnd.gif][] \}  
![InBlock.gif][]  
![InBlock.gif][]publicvoid SendData()  
![InBlock.gif][]  
![ExpandedSubBlockStart.gif][]\{  
![InBlock.gif][] Console.WriteLine("Notified \{0\} of \{1\}'s "\+"change to \{2:C\}", \_name, \_stock.Symbol, \_stock.Price);  
![InBlock.gif][]  
![ExpandedSubBlockEnd.gif][] \}  
![ExpandedBlockEnd.gif][]\}   
![None.gif][]  
![None.gif][]  
![None.gif][] class  Program  
![None.gif][]  
![ExpandedBlockStart.gif][] \{  
![InBlock.gif][]staticvoid Main(string\[\] args)  
![InBlock.gif][]  
![ExpandedSubBlockStart.gif][]\{  
![InBlock.gif][] Stock ms =new Microsoft("Microsoft", 120.00);  
![InBlock.gif][]  
![InBlock.gif][] ms.AddObserver(new Investor("Jom",ms));  
![InBlock.gif][]  
![InBlock.gif][] ms.AddObserver(new Investor("TerryLee",ms));  
![InBlock.gif][]  
![InBlock.gif][] ms.Update();  
![InBlock.gif][]  
![InBlock.gif][] Console.ReadLine();  
![ExpandedSubBlockEnd.gif][] \}  
![InBlock.gif][]  
![ExpandedBlockEnd.gif][]\}

当然拉模式也是有一些缺点的，主体对象和观察者之间的耦合加强了，但是这可以通过抽象的手段使这种耦合关系减到最小。\[感谢[idior][]的意见\]

**.NET中的Observer模式**

在.NET中，相信大家对于事件和委托都已经不陌生了，这里就不具体多说了。利用事件和委托来实现Observer模式我认为更加的简单和优雅，也是一种更好的解决方案。因为在上面的示例中我们可以看到，虽然取消了直接耦合，但是又引入了不必要的约束（暂且这么说吧）。即那些子类必须都继承于主题父类，还有观察者接口等。网上有很多这方面的例子，上面的例子简单的用事件和委托实现如下，仅供大家参考：

![None.gif][] class  Program  
![ExpandedBlockStart.gif][] \{  
![InBlock.gif][]staticvoid Main(string\[\] args)  
![ExpandedSubBlockStart.gif][]\{  
![InBlock.gif][] Stock stock =new Stock("Microsoft", 120.00);  
![InBlock.gif][]  
![InBlock.gif][] Investor investor =new Investor("Jom");  
![InBlock.gif][]  
![InBlock.gif][] stock.NotifyEvent \+=new NotifyEventHandler(investor.SendData);  
![InBlock.gif][]  
![InBlock.gif][] stock.Update();  
![InBlock.gif][]  
![InBlock.gif][] Console.ReadLine();  
![ExpandedSubBlockEnd.gif][] \}  
![ExpandedBlockEnd.gif][]\}   
![None.gif][]  
![None.gif][] public  delegate  void  NotifyEventHandler( object  sender);  
![None.gif][]  
![None.gif][]  
![None.gif][] public  class  Stock  
![None.gif][]  
![ExpandedBlockStart.gif][] \{  
![InBlock.gif][]public NotifyEventHandler NotifyEvent;  
![InBlock.gif][]  
![InBlock.gif][]private String \_symbol;  
![InBlock.gif][]  
![InBlock.gif][]privatedouble \_price;  
![InBlock.gif][]  
![InBlock.gif][]public Stock(String symbol, double price)  
![InBlock.gif][]  
![ExpandedSubBlockStart.gif][]\{  
![InBlock.gif][]this.\_symbol = symbol;  
![InBlock.gif][]  
![InBlock.gif][]this.\_price = price;  
![ExpandedSubBlockEnd.gif][] \}  
![InBlock.gif][]  
![InBlock.gif][]publicvoid Update()  
![InBlock.gif][]  
![ExpandedSubBlockStart.gif][]\{  
![InBlock.gif][] OnNotifyChange();  
![ExpandedSubBlockEnd.gif][] \}  
![InBlock.gif][]  
![InBlock.gif][]publicvoid OnNotifyChange()  
![InBlock.gif][]  
![ExpandedSubBlockStart.gif][]\{  
![InBlock.gif][]if (NotifyEvent !=null)  
![InBlock.gif][]  
![ExpandedSubBlockStart.gif][]\{  
![InBlock.gif][] NotifyEvent(this);  
![ExpandedSubBlockEnd.gif][] \}  
![InBlock.gif][]  
![ExpandedSubBlockEnd.gif][] \}  
![InBlock.gif][]  
![InBlock.gif][]public String Symbol  
![InBlock.gif][]  
![ExpandedSubBlockStart.gif][]\{  
![ExpandedSubBlockStart.gif][]get\{ return \_symbol; \}  
![ExpandedSubBlockEnd.gif][] \}  
![InBlock.gif][]  
![InBlock.gif][]publicdouble Price  
![InBlock.gif][]  
![ExpandedSubBlockStart.gif][]\{  
![ExpandedSubBlockStart.gif][]get\{ return \_price; \}  
![ExpandedSubBlockEnd.gif][] \}  
![ExpandedBlockEnd.gif][]\}   
![None.gif][]  
![None.gif][]  
![None.gif][]  
![None.gif][] public  class  Investor  
![None.gif][]  
![ExpandedBlockStart.gif][] \{  
![InBlock.gif][]privatestring \_name;  
![InBlock.gif][]  
![InBlock.gif][]public Investor(string name)  
![InBlock.gif][]  
![ExpandedSubBlockStart.gif][]\{  
![InBlock.gif][]this.\_name = name;  
![ExpandedSubBlockEnd.gif][] \}  
![InBlock.gif][]  
![InBlock.gif][]publicvoid SendData(object obj)  
![InBlock.gif][]  
![ExpandedSubBlockStart.gif][]\{  
![InBlock.gif][]if (obj is Stock)  
![InBlock.gif][]  
![ExpandedSubBlockStart.gif][]\{  
![InBlock.gif][] Stock stock = (Stock)obj;  
![InBlock.gif][]  
![InBlock.gif][] Console.WriteLine("Notified \{0\} of \{1\}'s "\+"change to \{2:C\}", \_name, stock.Symbol, stock.Price);  
![ExpandedSubBlockEnd.gif][] \}  
![InBlock.gif][]  
![ExpandedSubBlockEnd.gif][] \}  
![InBlock.gif][]  
![ExpandedBlockEnd.gif][]\}   
![None.gif][]

**效果及实现要点**

1．使用面向对象的抽象，Observer模式使得我们可以独立地改变目标与观察者，从而使二者之间的依赖关系达到松耦合。

2．目标发送通知时，无需指定观察者，通知（可以携带通知信息作为参数）会自动传播。观察者自己决定是否需要订阅通知。目标对象对此一无所知。

3．在C\#中的Event。委托充当了抽象的Observer接口，而提供事件的对象充当了目标对象，委托是比抽象Observer接口更为松耦合的设计。

**适用性**

1．当一个抽象模型有两个方面, 其中一个方面依赖于另一方面。将这二者封装在独立的对象中以使它们可以各自独立地改变和复用。

2．当对一个对象的改变需要同时改变其它对象, 而不知道具体有多少对象有待改变。

3．当一个对象必须通知其它对象，而它又不能假定其它对象是谁。换言之, 你不希望这些对象是紧密耦合的。

**总结**

通过Observer模式，把一对多对象之间的通知依赖关系的变得更为松散，大大地提高了程序的可维护性和可扩展性，也很好的符合了开放-封闭原则。

**参考资料**

Erich Gamma等，《设计模式：可复用面向对象软件的基础》，机械工业出版社

Robert C.Martin，《敏捷软件开发：原则、模式与实践》，清华大学出版社

阎宏，《Java与模式》，电子工业出版社

Alan Shalloway James R. Trott，《Design Patterns Explained》，中国电力出版社

MSDN WebCast 《C\#面向对象设计模式纵横谈(19)：Observer 观察者模式(行为型模式)》

更多设计模式文章请访问[.NET设计模式系列][.NET 1]

作者： [TerryLee][]  
出处： [http://terrylee.cnblogs.com][TerryLee]  
本文版权归作者和博客园共有，欢迎转载，但未经作者同意必须保留此段声明，且在文章页面明显位置给出原文连接，否则保留追究法律责任的权利。

# [设计模式17：Observer Pattern (观察者模式)][17_Observer Pattern] #

Define:Define a one-to-many dependency between objects so that when one object changes state, all its dependents are notified and updated automatically.

## 一、 观察者（Observer）模式 ##

观察者模式又叫做发布-订阅（Publish/Subscribe）模式、模型-视图（Model/View）模式、源-监听器（Source/Listener）模式或从属者（Dependents）模式。

##    二、 观察者模式的结构 ##

观察者模式的类图如下：

![PicX00105.gif][]

可以看出，在这个观察者模式的实现里有下面这些角色：

##    三、 观察者模式的示意性源代码 ##

## **\[c-sharp\]** [ view plain][view plain] [copy][view plain]  using System;  using System.Collections.Generic;  using System.Collections;  using System.Linq;  using System.Text;  namespace Observer\_Pattern  \{  // "Subject"  abstract class Subject  \{  // Fields  private ArrayList observers = new ArrayList();  // Methods  public void Attach(Observer observer)  \{  observers.Add(observer);  \}  public void Detach(Observer observer)  \{  observers.Remove(observer);  \}  public void Notify()  \{  foreach (Observer o in observers)  o.Update();  \}  \}  // "ConcreteSubject"  class ConcreteSubject : Subject  \{  // Fields  private string subjectState;  // Properties  public string SubjectState  \{  get \{ return subjectState; \}  set \{ subjectState = value; \}  \}  \}  // "Observer"  abstract class Observer  \{  // Methods  abstract public void Update();  \}  // "ConcreteObserver"  class ConcreteObserver : Observer  \{  // Fields  private string name;  private string observerState;  private ConcreteSubject subject;  // Constructors  public ConcreteObserver(ConcreteSubject subject,  string name)  \{  this.subject = subject;  this.name = name;  \}  // Methods  override public void Update()  \{  observerState = subject.SubjectState;  Console.WriteLine("Observer \{0\}'s new state is \{1\}",  name, observerState);  \}  // Properties  public ConcreteSubject Subject  \{  get \{ return subject; \}  set \{ subject = value; \}  \}  \}  /\*\*/  /// <summary>  /// Client test  /// </summary>  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.SubjectState = "ABC";  s.Notify();  Console.Read();  \}  \}  \}     四、 C\#中的Delegate与Event ##

**\[c-sharp\]** [ view plain][view plain] [copy][view plain]

1.  using System;
2.  using System.Collections.Generic;
3.  using System.Collections;
4.  using System.Linq;
5.  using System.Text;
6.  
7.  namespace Observer\_Pattern
8.  \{
9.  delegate void UpdateDelegate();
10. 
11. //Subject
12. class Subject
13. \{
14. public event UpdateDelegate UpdateHandler;
15. 
16. // Methods
17. public void Attach(UpdateDelegate ud)
18. \{
19. UpdateHandler += ud;
20. \}
21. 
22. public void Detach(UpdateDelegate ud)
23. \{
24. UpdateHandler -= ud;
25. \}
26. 
27. public void Notify()
28. \{
29. if (UpdateHandler != null) UpdateHandler();
30. \}
31. 
32. \}
33. 
34. //ConcreteSubject
35. class ConcreteSubject : Subject
36. \{
37. // Fields
38. private string subjectState;
39. 
40. // Properties
41. public string SubjectState
42. \{
43. get \{ return subjectState; \}
44. set \{ subjectState = value; \}
45. \}
46. \}
47. 
48. // "ConcreteObserver"
49. class ConcreteObserver
50. \{
51. // Fields
52. private string name;
53. private string observerState;
54. private ConcreteSubject subject;
55. 
56. // Constructors
57. public ConcreteObserver(ConcreteSubject subject,
58. string name)
59. \{
60. this.subject = subject;
61. this.name = name;
62. \}
63. 
64. // Methods
65. public void Update()
66. \{
67. observerState = subject.SubjectState;
68. Console.WriteLine("Observer \{0\}'s new state is \{1\}",
69. name, observerState);
70. \}
71. 
72. // Properties
73. public ConcreteSubject Subject
74. \{
75. get \{ return subject; \}
76. set \{ subject = value; \}
77. \}
78. \}
79. 
80. // "ConcreteObserver"
81. class AnotherObserver
82. \{
83. // Methods
84. public void Show()
85. \{
86. Console.WriteLine("AnotherObserver got an Notification!");
87. \}
88. \}
89. 
90. public class Client
91. \{
92. public static void Main(string\[\] args)
93. \{
94. ConcreteSubject s = new ConcreteSubject();
95. ConcreteObserver o1 = new ConcreteObserver(s, "1");
96. ConcreteObserver o2 = new ConcreteObserver(s, "2");
97. AnotherObserver o3 = new AnotherObserver();
98. 
99. s.Attach(new UpdateDelegate(o1.Update));
100. s.Attach(new UpdateDelegate(o2.Update));
101. s.Attach(new UpdateDelegate(o3.Show));
102. 
103. s.SubjectState = "ABC";
104. s.Notify();
105. 
106. Console.WriteLine("--------------------------");
107. s.Detach(new UpdateDelegate(o1.Update));
108. 
109. s.SubjectState = "DEF";
110. s.Notify();
111. 
112. Console.Read();
113. \}
114. \}
115. \}

其中，关键的代码如下：

delegate  void  UpdateDelegate();

public  event  UpdateDelegate UpdateHandler;

定义一个事件，一旦触发，可以调用一组符合UpdateDelegate规范的方法。

public  void  Attach( UpdateDelegate ud )  
 \{  
UpdateHandler \+= ud;  
\}

订阅事件。只要是一个满足UpdateDelegate的方法，就可以进行订阅操作（如下所示）。

s.Attach( new  UpdateDelegate(o1.Update));  
s.Attach( new  UpdateDelegate(o2.Update));  
s.Attach( new  UpdateDelegate(o3.Show));

在Notify方法中：

public  void  Notify()  
 \{  
if(UpdateHandler !=null) UpdateHandler();  
\}

只要UpdateHandler != null（表示有订阅者），就可以触发事件（UpdateHandler()），所有的订阅者便会接到通知。

##    五、 一个实际应用观察者模式的例子 ##

## **\[c-sharp\]** [ view plain][view plain] [copy][view plain]  using System;  using System.Collections.Generic;  using System.Collections;  using System.Linq;  using System.Text;  namespace Observer\_Pattern  \{  abstract class Stock  \{  // Fields  protected string symbol;  protected double price;  private ArrayList investors = new ArrayList();  // Constructor  public Stock(string symbol, double price)  \{  this.symbol = symbol;  this.price = price;  \}  // Methods  public void Attach(Investor investor)  \{  investors.Add(investor);  \}  public void Detach(Investor investor)  \{  investors.Remove(investor);  \}  public void Notify()  \{  foreach (Investor i in investors)  i.Update(this);  \}  // Properties  public double Price  \{  get \{ return price; \}  set  \{  price = value;  Notify();  \}  \}  public string Symbol  \{  get \{ return symbol; \}  set \{ symbol = value; \}  \}  \}  // "ConcreteSubject"  class IBM : Stock  \{  // Constructor  public IBM(string symbol, double price)  : base(symbol, price) \{ \}  \}  // "Observer"  interface IInvestor  \{  // Methods  void Update(Stock stock);  \}  // "ConcreteObserver"  class Investor : IInvestor  \{  // Fields  private string name;  private string observerState;  private Stock stock;  // Constructors  public Investor(string name)  \{  this.name = name;  \}  // Methods  public void Update(Stock stock)  \{  Console.WriteLine("Notified investor \{0\} of \{1\}'s change to \{2:C\}",  name, stock.Symbol, stock.Price);  \}  // Properties  public Stock Stock  \{  get \{ return stock; \}  set \{ stock = value; \}  \}  \}  /\*\*/  /// <summary>  /// ObserverApp test  /// </summary>  public class ObserverApp  \{  public static void Main(string\[\] args)  \{  // Create investors  Investor s = new Investor("Sorros");  Investor b = new Investor("Berkshire");  // Create IBM stock and attach investors  IBM ibm = new IBM("IBM", 120.00);  ibm.Attach(s);  ibm.Attach(b);  // Change price, which notifies investors  ibm.Price = 120.10;  ibm.Price = 121.00;  ibm.Price = 120.50;  ibm.Price = 120.75;  Console.Read();  \}  \}  \}     六、 观察者模式的优缺点 ##

观察者模式的效果有以下几个优点：

（2）观察者模式支持广播通信。被观察者会向所有的登记过的观察者发出通知。

观察者模式有下面的一些缺点：

（1）如果一个被观察者对象有很多直接和间接的观察者的话，将所有的观察者都通知到会花费很多时间。

（2）如果在被观察者之间有循环依赖的话，被观察者会触发它们之间进行循环调用，导致系统崩溃。在使用观察考模式时要特别注意这一点。

（3）如果对观察者的通知是通过另外的线程进行异步投递的话，系统必须保证投递是以自恰的方式进行的。

（4）虽然观察者模式可以随时使观察者知道所观察的对象发生了变化，但是观察者模式没有相应的机制使观察者知道所观察的对象是怎么发生变化的。

# [乐在其中设计模式(C\#) - 观察者模式(Observer Pattern)][C_ - _Observer Pattern] #

乐在其中设计模式(C\#) - 观察者模式(Observer Pattern)

作者： [webabcd][]  
  
  
介绍  
定义对象间的一种一对多的依赖关系,以便当一个对象的状态发生改变时,所有依赖于它的对象都得到通知并自动刷新。  
  
  
示例  
有一个Message实体类，某些对象对它的操作有Insert()方法，当发生某些改变的时候，通知所有这些对象并执行Insert()方法。  
![o_Observer.png][]  
  
  
MessageModel

IMessage

SqlMessage

XmlMessage

AbstractMessageSubject

![None.gif][] using  System;  
![None.gif][] using  System.Collections.Generic;  
![None.gif][] using  System.Text;  
![None.gif][]  
![None.gif][] namespace  Pattern.Observer  
![ExpandedBlockStart.gif][] \{  
![ExpandedSubBlockStart.gif][]///<summary>  
![InBlock.gif][]/// 抽象Message主题（Subject）  
![ExpandedSubBlockEnd.gif][]///</summary>  
![InBlock.gif][]publicabstractclass AbstractMessageSubject  
![ExpandedSubBlockStart.gif][]\{  
![InBlock.gif][]private MessageModel \_messageModel;  
![InBlock.gif][]private List<IMessage> list =new List<IMessage>();  
![InBlock.gif][]  
![ExpandedSubBlockStart.gif][]///<summary>  
![InBlock.gif][]/// 构造函数  
![InBlock.gif][]///</summary>  
![ExpandedSubBlockEnd.gif][]///<param name="mm">Message实体对象</param>  
![InBlock.gif][]public AbstractMessageSubject(MessageModel mm)  
![ExpandedSubBlockStart.gif][]\{  
![InBlock.gif][]this.\_messageModel = mm;  
![ExpandedSubBlockEnd.gif][] \}  
![InBlock.gif][]  
![ExpandedSubBlockStart.gif][]///<summary>  
![InBlock.gif][]/// 添加一个实现IMessage接口的对象  
![InBlock.gif][]///</summary>  
![ExpandedSubBlockEnd.gif][]///<param name="m">实现IMessage接口的对象</param>  
![InBlock.gif][]publicvoid Attach(IMessage m)  
![ExpandedSubBlockStart.gif][]\{  
![InBlock.gif][] list.Add(m);  
![ExpandedSubBlockEnd.gif][] \}  
![InBlock.gif][]  
![ExpandedSubBlockStart.gif][]///<summary>  
![InBlock.gif][]/// 移除一个实现IMessage接口的对象  
![InBlock.gif][]///</summary>  
![ExpandedSubBlockEnd.gif][]///<param name="m">实现IMessage接口的对象</param>  
![InBlock.gif][]publicvoid Detach(IMessage m)  
![ExpandedSubBlockStart.gif][]\{  
![InBlock.gif][] list.Remove(m);  
![ExpandedSubBlockEnd.gif][] \}  
![InBlock.gif][]  
![ExpandedSubBlockStart.gif][]///<summary>  
![InBlock.gif][]/// 通知所有观察者  
![InBlock.gif][]///</summary>  
![ExpandedSubBlockEnd.gif][]///<returns></returns>  
![InBlock.gif][]publicstring Notify()  
![ExpandedSubBlockStart.gif][]\{  
![InBlock.gif][]string s ="";  
![InBlock.gif][]foreach (IMessage i in list)  
![ExpandedSubBlockStart.gif][]\{  
![InBlock.gif][] s \+= i.Insert(\_messageModel);  
![InBlock.gif][] s \+="<br />";  
![ExpandedSubBlockEnd.gif][] \}  
![InBlock.gif][]  
![InBlock.gif][]return s;  
![ExpandedSubBlockEnd.gif][] \}  
![InBlock.gif][]  
![ExpandedSubBlockStart.gif][]///<summary>  
![InBlock.gif][]/// Message发布时间  
![ExpandedSubBlockEnd.gif][]///</summary>  
![InBlock.gif][]public DateTime PublishTime  
![ExpandedSubBlockStart.gif][]\{  
![ExpandedSubBlockStart.gif][]get\{ return \_messageModel.PublishTime; \}  
![InBlock.gif][]set  
![ExpandedSubBlockStart.gif][]\{  
![InBlock.gif][] \_messageModel.PublishTime = value;  
![InBlock.gif][] Notify();  
![ExpandedSubBlockEnd.gif][] \}  
![ExpandedSubBlockEnd.gif][] \}  
![ExpandedSubBlockEnd.gif][] \}  
![ExpandedBlockEnd.gif][]\}   
![None.gif][]

MessageSubject

Test

![None.gif][] using  System;  
![None.gif][] using  System.Data;  
![None.gif][] using  System.Configuration;  
![None.gif][] using  System.Collections;  
![None.gif][] using  System.Web;  
![None.gif][] using  System.Web.Security;  
![None.gif][] using  System.Web.UI;  
![None.gif][] using  System.Web.UI.WebControls;  
![None.gif][] using  System.Web.UI.WebControls.WebParts;  
![None.gif][] using  System.Web.UI.HtmlControls;  
![None.gif][]  
![None.gif][] using  Pattern.Observer;  
![None.gif][]  
![None.gif][] public  partial  class  Observer : System.Web.UI.Page  
![ExpandedBlockStart.gif][] \{  
![InBlock.gif][]protectedvoid Page\_Load(object sender, EventArgs e)  
![ExpandedSubBlockStart.gif][]\{  
![InBlock.gif][] MessageSubject m =new MessageSubject(new MessageModel("插入Message", DateTime.Now));  
![InBlock.gif][]  
![InBlock.gif][] SqlMessage sqlMessage =new SqlMessage();  
![InBlock.gif][] XmlMessage xmlMessage =new XmlMessage();  
![InBlock.gif][]  
![InBlock.gif][] m.Attach(sqlMessage);  
![InBlock.gif][] m.Attach(xmlMessage);  
![InBlock.gif][]  
![InBlock.gif][]// System.Threading.Thread.Sleep(1000);  
![InBlock.gif][]// 修改了PublishTime就会通知所有观察者  
![InBlock.gif][]// m.PublishTime = DateTime.Now;  
![InBlock.gif][]  
![InBlock.gif][] Response.Write(m.Notify());  
![ExpandedSubBlockEnd.gif][] \}  
![ExpandedBlockEnd.gif][]\}   
![None.gif][]

运行结果  
sql方式：插入Message 2007-5-26 9:38:18  
xml方式：插入Message 2007-5-26 9:38:18  
  
  
参考  
[http://www.dofactory.com/Patterns/PatternObserver.aspx][http_www.dofactory.com_Patterns_PatternObserver.aspx]  
  
  
OK  
[\[源码下载\]][Link 2]

[-]: http://www.cnblogs.com/zhenyulu/category/6930.html
[.NET]: http://www.cnblogs.com/Terrylee/archive/2006/07/17/334911.html
[Link 1]: http://blog.csdn.net/rocket5725/article/category/559017
[C]: http://www.cnblogs.com/webabcd/category/82668.html
[19_Observer Pattern]: http://www.cnblogs.com/zhenyulu/articles/73723.html
[PicX00105.gif]: /images/20220331/1af1a3a9d1b34821bdca03fdf4545959.png
[None.gif]: /images/20220331/7f87ae60d22846549be8f15822cf5dd9.png
[ExpandedBlockStart.gif]: /images/20220331/cca6d59f3f814489af4a20bb14fb0dbb.png
[InBlock.gif]: /images/20220331/ff053fa3af56453ba24763877e1c2073.png
[ExpandedSubBlockStart.gif]: /images/20220331/9c4a8d0bda314f60be9d6953d41f8970.png
[ExpandedSubBlockEnd.gif]: /images/20220331/176e07fc070f4a0fac799d55a04099ac.png
[ExpandedBlockEnd.gif]: /images/20220331/cc53363c88914d899e8a6b951f17dec7.png
[.NET_19_Observer Pattern]: http://www.cnblogs.com/Terrylee/archive/2006/10/23/Observer_Pattern.html
[Observer_02.gif]: /images/20220331/9683a5b0ff7b4789ade03b93b9fd5687.png
[Observer_01.gif]: /images/20220331/302fb109694c4882935fba2a5d041a9e.png
[Observer_03.gif]: /images/20220331/643f2e4d518144b0a0a9dbb0a3105656.png
[Observer_04.gif]: /images/20220331/9db69e3a36e9491c947109cae54e28a9.png
[Observer_05.gif]: /images/20220331/df10d634ca804adab29764fd5920011d.png
[Observer_06.gif]: /images/20220331/d6ad9248984c4356bf2dad582b31e434.png
[idior]: http://idior.cnblogs.com/
[.NET 1]: http://terrylee.cnblogs.com/archive/2006/06/01/334911.html
[TerryLee]: http://terrylee.cnblogs.com
[17_Observer Pattern]: http://blog.csdn.net/rocket5725/article/details/4325090
[view plain]: http://blog.csdn.net/rocket5725/article/details/4325090#
[C_ - _Observer Pattern]: http://www.cnblogs.com/webabcd/archive/2007/05/26/760498.html
[webabcd]: http://webabcd.cnblogs.com/
[o_Observer.png]: /images/20220331/f8ecbbf33e444a2d86e259991ef4cded.png
[http_www.dofactory.com_Patterns_PatternObserver.aspx]: http://www.dofactory.com/Patterns/PatternObserver.aspx
[Link 2]: http://files.cnblogs.com/webabcd/Pattern.rar