1. 概述
有时被称作发布/订阅模式,观察者模式定义了一种一对多的依赖关系,让多个观察者对象同时监听某一个主题对象。这个主题对象在状态发生变化时,会通知所有观察者对象,使它们能够自动更新自己。
2. 解决的问题
将一个系统分割成一个一些类相互协作的类有一个不好的副作用,那就是需要维护相关对象间的一致性。我们不希望为了维持一致性而使各类紧密耦合,这样会给维护、扩展和重用都带来不便。观察者就是解决这类的耦合关系的。
3. 模式中的角色
3.1 抽象主题(Subject):它把所有观察者对象的引用保存到一个聚集里,每个主题都可以有任何数量的观察者。抽象主题提供一个接口,可以增加和删除观察者对象。
3.2 具体主题(CustomerSubject):将有关状态存入具体观察者对象;在具体主题内部状态改变时,给所有登记过的观察者发出通知。
3.3 抽象观察者(Observer):为所有的具体观察者定义一个接口,在得到主题通知时更新自己。
3.4 具体观察者(CustomerObserver):实现抽象观察者角色所要求的更新接口,以便使本身的状态与主题状态协调。
4.代码实现
4.1 抽象主题(Subject)
public abstract class Subject { //定义观察者集合 private List<Observer> list = new List<Observer>(); /// <summary> /// 添加观察者 /// </summary> /// <param name="observer"></param> public void Add(Observer observer) { list.Add(observer); } /// <summary> /// 移除观察者 /// </summary> /// <param name="observer"></param> public void Remove(Observer observer) { list.Remove(observer); } /// <summary> /// 触发事件 /// </summary> public void Touch() { foreach (var item in list) { item.Update(); } } }
4.2 具体主题(CustomerSubject)
public class CustomerSubject : Subject { public string status; public string Status { get { return status; } set { status = value; Touch(); } } }
4.3 抽象观察者(Observer)
public abstract class Observer { public abstract void Update(); }
4.4 具体观察者(CustomerObserver)
public class CustomerObserver: Observer { public string status; public string name; public CustomerObserver(string _status, string _name) { status = _status; name = _name; } public override void Update() { Console.WriteLine($"name:{name},status:{status}"); } }
5. 模式总结
5.1 优点
5.1.1 观察者模式解除了主题和具体观察者的耦合,让耦合的双方都依赖于抽象,而不是依赖具体。从而使得各自的变化都不会影响另一边的变化。
5.2 缺点
5.2.1 依赖关系并未完全解除,抽象通知者依旧依赖抽象的观察者。
5.3 适用场景
5.3.1 当一个对象的改变需要给变其它对象时,而且它不知道具体有多少个对象有待改变时。
5.3.2 一个抽象某型有两个方面,当其中一个方面依赖于另一个方面,这时用观察者模式可以将这两者封装在独立的对象中使它们各自独立地改变和复用。
6. 模式引申,应用C#中的事件委托来彻底解除通知者和观察者之间的耦合。
6.1 关于委托的定义:委托是一种引用方法的类型。一旦为委托分配了方法,委托将与该方法有相同的行为。委托方法可以像其它任何方法一样,具有参数和返回值。委托可以看作是对函数(方法)的的抽象,是函数的“类”,委托的实例代表一个(或多个)具体的函数,它可以是多播的。
6.2 关于事件:事件基于委托,为委托提供了一种发布/订阅机制。事件的订阅与取消与我们刚才讲的观察者模式中的订阅与取消类似,只是表现形式有所不同。在观察者模式中,订阅使用方法Attach()来进行;在事件的订阅中使用“+=”。类似地,取消订阅在观察者模式中用Dettach(),而事件的取消用“-=”。
7. 下面例子用观察者模式来实现
实例描述:客户支付了订单款项,这时财务需要开具发票,出纳需要记账,配送员需要配货。
7.1 定义抽象主题
/// <summary> /// 抽象主题 /// </summary> public interface ISubject { void Notify(); }
7.2 定义抽象观察者
/// <summary> /// 工作岗位,这作为观察者的抽象 /// </summary> public abstract class JobStation { public abstract void Update(); }
7.3 具体观察者:会计
/// <summary> /// 会计 /// </summary> public class Accountant : JobStation { private string accountantState; private Customer customer; public Accountant(Customer _customer) { this.customer = _customer; } public override void Update() { if (customer.customerState == "已付款") { Console.WriteLine("我是会计,我来开具发票!"); accountantState = "已开发票"; } } }
7.4 具体观察者:出纳
/// <summary> /// 出纳 /// </summary> public class Cashier : JobStation { private string cashierState; private Customer customer; public Cashier(Customer _customer) { customer = _customer; } public override void Update() { if (customer.CustomerState == "已付款") { Console.WriteLine("我是出纳员,我给登记入账。"); cashierState = "已入账"; } } }
7.5 具体观察者:配送员
/// <summary> /// 配送员 /// </summary> public class Dilliveryman : JobStation { private string dillivierymanState; private Customer customer; public Dilliveryman(Customer _customer) { customer = _customer; } public override void Update() { if (customer.CustomerState == "已付款") { Console.WriteLine("我是配送员,我来发货。"); dillivierymanState = "已发货"; } } }
7.6 具体主题,这里是指客户
/// <summary> /// 具体主题,这里是客户 /// </summary> public class Customer : ISubject { public string customerState; public List<JobStation> observers = new List<JobStation>(); /// <summary> /// 增加观察者 /// </summary> /// <param name="observer"></param> public void Attach(JobStation observer) { observers.Add(observer); } /// <summary> /// 移除观察者 /// </summary> /// <param name="observer"></param> public void Detach(JobStation observer) { this.observers.Remove(observer); } /// <summary> /// 客户状态 /// </summary> public string CustomerState { get { return customerState; } set { customerState = value; } } public void Notify() { foreach (JobStation o in observers) { o.Update(); } } }
7.7 客户端代码
static void Main(string[] args) { Customer subject = new Customer(); subject.Attach(new Accountant(subject)); subject.Attach(new Cashier(subject)); subject.Attach(new Dilliveryman(subject)); subject.customerState = "已付款"; subject.Notify(); Console.Read(); }
运行结果:
8. 事件实现
实例描述:客户支付了订单款项,这时财务需要开具发票,出纳需要记账,配送员需要配货。
通过类图来看,观察者和主题之间已经不存在任何依赖关系了。
8.1 定义抽象主题和委托
/// <summary> /// 抽象主题 /// </summary> public interface ISubject { void Notify(); } /// <summary> /// 申明委托 /// </summary> public delegate void CustomerEventHandler();
8.2 定义财务类、出纳类、配送员类
/// <summary> /// 财务(已经不需要抽象的观察者类,并且不需要引用具体的主题) /// </summary> public class Accountant { private string accountantState; /// <summary> /// 开发票 /// </summary> public void GiveInvoice() { Console.WriteLine("我是会计,我来开具发票。"); accountantState = "已开发票"; } } /// <summary> /// 出纳(已经不需要抽象的观察者类,并且不需要引用具体的主题) /// </summary> public class Cashier { private string cashierState; public void Recoded() { Console.WriteLine("我是出纳员,我给登记入账。"); cashierState = "已入账"; } } /// <summary> /// 配送员(已经不需要抽象的观察者类,并且不需要引用具体的主题) /// </summary> public class Dilliveryman { private string dillivierymanState; public void Dilliver() { Console.WriteLine("我是配送员,我来发货。"); dillivierymanState = "已发货"; } }
8.3 客户端代码
static void Main(string[] args) { //生成主题实体 Customer customer = new Customer(); //会计实体 Accountant accountant= new Accountant(); //把会计的开发票方法添加到委托事件中 customer.Update += accountant.GiveInvoice; //出纳实体 Cashier cashier = new Cashier(); customer.Update += cashier.Recoded; //快递员实体 Dilliveryman dilliveryman = new Dilliveryman(); customer.Update += dilliveryman.Dilliver; customer.CustomerState ="已付款"; customer.Notify(); Console.Read(); }
运行结果:
附加:(1)可以简化写法,不用手动定义 委托,使用 程序集 System.Runtime 自带的委托类型:Action
(2)简化事件的调用,通过 Invoke() 方法调用。
程序集 System.Runtime