学步园

C# 之观察者模式

观察者模式有很多实现方式，从根本上说，该模式必须包含两个角色：观察者和被观察对象。在刚才的例子中，业务数据是被观察对象，用户界面是观察者。观察者和被观察者之间存在“观察”的逻辑关联，当被观察者发生改变的时候，观察者就会观察到这样的变化，并且做出相应的响应。 

　　观察者模式（Observer）完美的将观察者和被观察的对象分离开。举个例子，用户界面可以作为一个观察者，业务数据是被观察者，用户界面观察业务数据的变化，发现数据变化后，就显示在界面上。面向对象设计的一个原则是：系统中的每个类将重点放在某一个功能上，而不是其他方面。一个对象只做一件事情，并且将他做好。观察者模式在模块之间划定了清晰的界限，提高了应用程序的可维护性和重用性。

　　观察者模式有很多实现方式，从根本上说，该模式必须包含两个角色：观察者和被观察对象。在刚才的例子中，业务数据是被观察对象，用户界面是观察者。观察者和被观察者之间存在“观察”的逻辑关联，当被观察者发生改变的时候，观察者就会观察到这样的变化，并且做出相应的响应。如果在用户界面、业务数据之间使用这样的观察过程，可以确保界面和数据之间划清界限，假定应用程序的需求发生变化，需要修改界面的表现，只需要重新构建一个用户界面，业务数据不需要发生变化。

　　“观察”不是“直接调用”

　　实现观察者模式的时候要注意，观察者和被观察对象之间的互动关系不能体现成类之间的直接调用，否则就将使观察者和被观察对象之间紧密的耦合起来，从根本上违反面向对象的设计的原则。无论是观察者“观察”观察对象，还是被观察者将自己的改变“通知”观察者，都不应该直接调用。

　　实现观察者模式的例子

　　实现观察者模式有很多形式，比较直观的一种是使用一种“注册——通知——撤销注册”的形式。下面的三个图详细的描述了这样一种过程：

　　1：观察者（Observer）将自己注册到被观察对象（Subject）中，被观察对象将观察者存放在一个容器（Container）里。

　　2：被观察对象发生了某种变化（如图中的AskPriceChanged），从容器中得到所有注册过的观察者，将变化通知观察者。

　　3：观察者告诉被观察者要撤销观察，被观察者从容器中将观察者去除。

　　观察者将自己注册到被观察者的容器中时，被观察者不应该过问观察者的具体类型，而是应该使用观察者的接口。这样的优点是：假定程序中还有别的观察者，那么只要这个观察者也是相同的接口实现即可。一个被观察者可以对应多个观察者，当被观察者发生变化的时候，他可以将消息一一通知给所有的观察者。基于接口，而不是具体的实现——这一点为程序提供了更大的灵活性。

　　下面代码是使用C#实现观察者模式的例子：

//“观察者”接口
public interface IObserver {
  void Notify(object anObject);
}
//“被观察对象”接口
public interface IObservable {
  void Register(IObserver anObserver);
  void UnRegister(IObserver anObserver);
}

观察者和被观察对象都分别从这两个接口实现，所有的操作都是由这两个接口定义的，而不是具体的实现。所以观察者和被观察对象没有绑定在一起。我们可以方便的更改观察者和被观察对象的任意部分而不影响其他部分。

　　下面实现具体的被观察对象。下面的类是所有被观察对象的基类，实现了所有被观察对象都必须的方法。我们使用一个Hashtable作为观察者的容器。代码如下：

//所有被观察对象的基类
public class ObservableImpl : IObservable {
   //保存观察对象的容器
   protected Hashtable _observerContainer = new Hashtable();
   //注册观察者
   public void Register(IObserver anObserver){
     _observerContainer.Add(anObserver,anObserver);
   }
   //撤销注册
   public void UnRegister(IObserver anObserver){
     _observerContainer.Remove(anObserver);
   }
   //将事件通知观察者
   public void NotifyObservers(object anObject) {
     //枚举容器中的观察者，将事件一一通知给他们
     foreach(IObserver anObserver in _observerContainer.Keys) {
       anObserver.Notify(anObject);
    }
  }
}

　　上面的类不是最终要实现的被观察对象，而是所有被观察者的基类，其中实现了所有观察对象共有的功能。这个类可以干脆定义为abstract，使得程序员不可以创建其实例。接口以及实现这个接口的虚类既保持了类之间松散的耦合，又使多个具体实现可以使用相同的功能。

　　下面最终实现观察者模式，使用用户界面——业务数据作为例子：

//业务数据（被观察对象）
public class SomeData : ObservableImpl {
  //被观察者中的数据
  float _askPrice;
  //改变数据的属性
  public float AskPrice {
   set {
      _askPrice = value;
      base.NotifyObservers(_askPrice);//将改变的消息通知观察者
    }
  }
}
//用户界面（观察者）
public class SomeKindOfUI : IObserver {
  public void Notify(object anObject){
    Console.WriteLine("The new ask price is:" + anObject);
  }
}
//实际调用的过程
public class MainClass{
  public static void Main() {
    //创建观察者和被观察者
    SomeKindOfUI ui = new SomeKindOfUI();
    SomeData data = new SomeData();
    //在被观察对象中注册观察者
    data.Register(ui);
   //改变被观察对象中的数据，这时被观察者会通知观察者
   data.AskPrice = 1000f;
   //注销观察者，停止观察
   stock.UnRegister(stockDisplay);
  }
}

　　.NET中更好的实现方式

　　上面的形式是我们用一种最基本的方式实现了观察者模式，我们为观察者模式开发了一种特定的类型。在.NET框架中，使用代理以及事件，可以更好的实现观察者模式。C#中代理和事件的介绍可以看这一篇文章：在C#中使用代理的方式触发事件，里面有对代理和事件的详细描述，还有例程，这里就不多说了。在.NET支持的其他语言中也有各自的实现方式。

　　在事件的模式下，声明事件的类就是被观察者。被观察者不需要实现对观察者的注册，只需要公开一个事件，而不实行任何操作。被观察者也不需要将自己注册到观察对象中，而是要创建一个特定的代理的实例，将这个代理绑定到某个方法上。用这样的方式注册或者撤销观察者对观察对象的观察。仔细研究代理和事件的模式就不难发现，IObserver和IObservable接口的方法可以减少观察者和观察对象之间的耦合，而代理和事件几乎消除了这两个模块之间的耦合，灵活性提高了很多。

C#事件委托和观察者模式之比较

看了C#的事件，发觉跟学java时见到的观察者模式相似，网上搜了一下，有总结的帖子，转载如下：

using System.Collections;

namespace MyCollections
{
　 //-----------------------------------------------------------------------------
　 //该委托定义相当于观察者模式中的 Notify()函数，
　 //用来通知观察者关于subject 的变化
　 //通知观察者，观察者会自动执行观察者内的Update()，Update()方法会暴露给subjects.
　 // A delegate type for hooking up change notifications.
　 public delegate void ChangedEventHandler(object sender, EventArgs e);

　 //------------------------------------------------------------------------------
　 //该类相当于观察者模式中的subjects.

　 // A class that works just like ArrayList, but sends event
　 // notifications whenever the list changes.
　 public class ListWithChangedEvent: ArrayList
　 {
　　　// An event that clients can use to be notified whenever the
　　　// elements of the list change.
　　　public event ChangedEventHandler Changed;　　 //事件相当于实做Notify()函数

　　　// Invoke the Changed event; called whenever list changes
　　　protected virtual void OnChanged(EventArgs e)
　　　{
　　　　 if (Changed != null)　　　　　　　　　　　 //这里表示subjects状态有变化，需要通知observers.
　　　　　　 Changed(this, e);
　　　 }

　　　// Override some of the methods that can change the list;
　　　// invoke event after each
　　　public override int Add(object value)
　　　{
　　　　 int i = base.Add(value);
　　　　　OnChanged(EventArgs.Empty);
　　　　 return i;
　　　 }

　　　public override void Clear()
　　　{
　　　　 base.Clear();
　　　　　OnChanged(EventArgs.Empty);
　　　 }

　　　public override object this[int index]
　　　{
　　　　 set
　　　　 {
　　　　　　base[index] = value;
　　　　　　 OnChanged(EventArgs.Empty);
　　　　　}
　　　 }
　　}
}

using MyCollections;
namespace TestEvents
{
　 //侦听者类似于观察者模式中的observers
　 class EventListener
　 {
　　　private ListWithChangedEvent List;

　　　public EventListener(ListWithChangedEvent list)
　　　{
　　　　　List = list;
　　　　 // Add "ListChanged" to the Changed event on "List".
　　　　　List.Changed += new ChangedEventHandler(ListChanged);//这里类似于AddObserver();
　　　 }

　　　// This will be called whenever the list changes.
　　　private void ListChanged(object sender, EventArgs e)
　　　{
　　　　　Console.WriteLine("This is called when the event fires."); //这里类似于观察者暴露给subjects 的Update()方法
　　　　　Thread.Sleep(5000);
　　　 }

　　　public void Detach()
　　　{
　　　　 // Detach the event and delete the list
   List.Changed -= new ChangedEventHandler(ListChanged);//这里类似于RemoveObserver();
　　　　　List = null;
　　　 }
　　}

　 class Test
　 {
　　　// Test the ListWithChangedEvent class.
　　　public static void Main()
　　　{
　　　// Create a new list.
　　　 ListWithChangedEvent list = new ListWithChangedEvent();　　　 //创建一个subject(observable)

　　　// Create a class that listens to the list's change event.
　　　 EventListener listener = new EventListener(list);　　　　　　 //创建一个观察者

　　　// Add and remove items from the list.
　　　 list.Add("item 1");　　　　　　　　　　　　　　　　　　　　　 //subject 的状态发生变化，通知观察者作相应的动作 ListChanged()
　　　 list.Clear();　　　　　　　　　　　　　　　　　　　　　　　　 //同上　　　　　　　　　　　　　　
　　　 listener.Detach();//删除观察者
　　　 }
　　}
}