你的位置:首页 > ASP.net教程

[ASP.net教程]观察者模式(发布、订阅)之(上) 李朝强 李朝强


什么是观察者模式?

摘自百度百科的说法:观察者模式(有时又被称为发布(publish )-订阅(Subscribe)模式、模型-视图(View)模式、源-收听者(Listener)模式或从属者模式)是软件设计模式的一种。在此种模式中,一个目标物件管理所有相依于它的观察者物件,并且在它本身的状态改变时主动发出通知。这通常透过呼叫各观察者所提供的方法来实现。此种模式通常被用来实现事件处理系统。

 说白了,就是一个主题,可以有N多个观察者,一个观察者,也可以订阅N多个主题。当一个主题,发生改变时,会通知订阅它的观察者,观察者收到通知后,可以做相应的处理。观察者模式,是软件设计模式中的一种。接下里,我们介绍下,使用C#实现的观察者模式。附上代码。

      首先,我们新建一个名为AppObserver的控制台项目。结构如下:

 Strategy目录下新建两个接口,一个IObserver(观察者)、一个ISubject(主题)。让我们看看,这两个接口分别定义了什么?

/* * Created by http://www.lichaoqiang.com * User: 李朝强 * Date: 2016/9/2 * Time: 16:25 * * To change this template use Tools | Options | Coding | Edit Standard Headers. */using System;using System.Collections.Generic;namespace AppObserver.Strategy{	/// <summary>	/// Description of ISubject.	/// </summary>	public interface ISubject	{		/// <summary>		/// 主题		/// </summary>		string Title{get;set;}				/// <summary>		/// 观察者		/// </summary>		List<IObserver> Observers{get;}				/// <summary>		/// 添加订阅		/// </summary>		/// <param name="observer"></param>		void AddObserver(IObserver observer);				/// <summary>		/// 发布		/// </summary>		void Publish();	}}

观察者接口(IObserver):

/* * Created by http://www.lichaoqiang.com * User: 李朝强 * Date: 2016/9/2 * Time: 16:27 * * To change this template use Tools | Options | Coding | Edit Standard Headers. */using System;using System.Collections.Generic;namespace AppObserver.Strategy{	/// <summary>	/// Description of IObserver.	/// </summary>	public interface IObserver	{				/// <summary>		/// 名称		/// </summary>		string Name{get;}				/// <summary>		/// 主题		/// </summary>		List<ISubject> Subjects{get;}				/// <summary>		/// 通知		/// </summary>		void Notify(ISubject subject);				/// <summary>		/// 订阅		/// </summary>		/// <param name="subject"></param>		void Subscribe(ISubject subject);						/// <summary>		/// 取消订阅		/// </summary>		/// <param name="subject"></param>		void Unsubscribe(ISubject subject);			}}

接下来,新建一个Support文件夹,提供对以上两个接口的实现。具体代码如下:

主题:

/* * Created by http://www.lichaoqiang.com * User: 李朝强 * Date: 2016/9/2 * Time: 16:34 * * To change this template use Tools | Options | Coding | Edit Standard Headers. */using System;using System.Collections.Generic;using AppObserver.Strategy;namespace AppObserver.Support{	/// <summary>	/// Description of Subject.	/// </summary>	public class Subject:ISubject	{				/// <summary>		/// 构造函数		/// </summary>		public Subject()		{			Observers = new List<IObserver>();		}				#region ISubject implementation				/// <summary>		/// 添加观察者		/// </summary>		/// <param name="observer"></param>		void ISubject.AddObserver(IObserver observer)		{			Observers.Add(observer);		} 		/// <summary>		/// 发布		/// </summary>		void ISubject.Publish()		{			if (null != Observers && Observers.Count > 0)				foreach (var item in Observers) {item.Notify(this);}		}			/// <summary>		/// 主题		/// </summary>		string ISubject.Title {			get;			set;		}			/// <summary>		/// 观察者		/// </summary>		public	List<IObserver> Observers { get; private set; }		#endregion			}}

观察者:

/* * Created by http://www.lichaoqiang.com * User: 李朝强 * Date: 2016/9/2 * Time: 16:37 * * To change this template use Tools | Options | Coding | Edit Standard Headers. */using System;using System.Collections.Generic;using AppObserver.Strategy;namespace AppObserver.Support{	/// <summary>	/// 观察者	/// </summary>	public class Observer:IObserver	{				/// <summary>		/// 构造函数		/// </summary>		public Observer()		{			Subjects = new List<ISubject>();		}				/// <summary>		/// 构造函数		/// </summary>		/// <param name="name"></param>		public Observer(String name)			: this()		{			Name = name;		}		#region IObserver implementation				/// <summary>		/// 名字		/// </summary>		public string Name{ get; private set; }						/// <summary>		/// 通知		/// </summary>		void IObserver.Notify(ISubject subject)		{			//这里具体可以处理你的业务逻辑			//我们可以通过扩展suject对象,来传递信息			Console.WriteLine("【{0}】收到最新通知(Notify)主题:{1}", this.Name, subject.Title);		}		/// <summary>		/// 订阅		/// </summary>		/// <param name="subject">主题</param>		void IObserver.Subscribe(ISubject subject)		{			subject.AddObserver(this);			Subjects.Add(subject);		}				/// <summary>		/// 取消订阅		/// </summary>		/// <param name="subject">主题</param>		void IObserver.Unsubscribe(ISubject subject)		{		  		} 				/// <summary>		///获取已订阅的主题		/// </summary>		public	List<ISubject> Subjects { get; private set; }		#endregion	}}

完成以上几步,就简单的实现了观察者模式。让我们一起来看看效果吧。

场景:张三和李四两个人,一个爱好体育和娱乐,一个爱好体育。于是,张三,拿起IiPhone 6s plus,打开App,点击并订阅了《体育频道》、《娱乐频道》两个栏目,李四看了,也马上掏出小米5s,以迅雷不及掩耳盗铃之势,打开相同的APP,也同样订阅了《体育频道》这档栏目。就在这个时候,远在千里之外的一座大都市,一个S身材的MZ,坐在办公桌前,准备好了资讯内容,准备这个时候,向广大粉丝,推送这些信息。于是,她先把准备好的体育信息,标题为“张继科XXXX”的主题,推送出去。然后,接着隔壁同事老王,负责《娱乐频道》的有痣青年,把主题为《王宝强XXXX》的信息,推送出去。这个时候,张三和李四的手机,不约而同的响起了一声清脆的声音。打开一看,效果如下:

张三和李四,顿时沉迷其中,认认真真的阅读起了这些内容。

 张三、李四虚构故事,以娱大家,博君一笑,夫复何求哈。