观察者模式, 就像一群人在玩大家来找茬一样, 一幅一幅的玩.
这种玩的方式, 是类似于推拉模式中的推模式的. 推送给玩家的是, 两幅图片, 相同的部分和不同的部分都推送给你, 但是, 作为玩家来说, 其实更想要的, 只是不同的部分.
下面以一个简单的示意性实现为例,讨论观察者模式的结构。
观察者模式所涉及的角色有:
● 抽象主题(Subject)角色:抽象主题角色把所有对观察者对象的引用保存在一个聚集(比如ArrayList对象)里,每个主题都可以有任何数量的观察者。抽象主题提供一个接口,可以增加和删除观察者对象,抽象主题角色又叫做抽象被观察者(Observable)角色。
● 具体主题(ConcreteSubject)角色:将有关状态存入具体观察者对象;在具体主题的内部状态改变时,给所有登记过的观察者发出通知。具体主题角色又叫做具体被观察者(Concrete Observable)角色。
● 抽象观察者(Observer)角色:为所有的具体观察者定义一个接口,在得到主题的通知时更新自己,这个接口叫做更新接口。
● 具体观察者(ConcreteObserver)角色:存储与主题的状态自恰的状态。具体观察者角色实现抽象观察者角色所要求的更新接口,以便使本身的状态与主题的状态 像协调。如果需要,具体观察者角色可以保持一个指向具体主题对象的引用。
一、推送消息(一般实现方式)
先看看主题类吧
/// <summary>
/// 抽象主题 -- 新闻
/// </summary>
public abstract class Subject
{
private List<Observer> observers = new List<Observer>();
public void Register(Observer ob)
{
observers.Add(ob);
Console.WriteLine(ob.Name + " 订阅成功!");
}
public void Remove(Observer ob)
{
observers.Remove(ob);
Console.WriteLine(ob.Name + " 取消订阅!");
}
/// <summary>
/// 通知所有已注册的观察者对象
/// </summary>
public void Notify(string news)
{
foreach (var item in observers)
{
item.Read(news);
}
}
}
/// <summary>
/// 具体主题类 -- 今日头条
/// </summary>
public class ConcreteSubject : Subject
{
public string News { get; set; }
public void Publish(string news)
{
this.News = news;
Console.WriteLine("推送主题新闻为:" + this.News);
this.Notify(this.News);
}
}
有了主题之后, 就可以投入市场了, 让用户去收看
/// <summary>
/// 抽象观察者
/// </summary>
public abstract class Observer
{
public string Name { get; set; }
public abstract void Read(string news);
}
/// <summary>
/// 具体观察者 -- 安装了今日头条的用户
/// </summary>
public class ConcreteObserver : Observer
{
public override void Read(string news)
{
Console.WriteLine("{0} 看了新闻 : {1}", this.Name, news);
}
}
客户端:
var ob1 = new ConcreteObserver() { Name = "高俅" };
var ob2 = new ConcreteObserver() { Name = "小小" };
var ob3 = new ConcreteObserver() { Name = "林三" };
ConcreteSubject sub = new ConcreteSubject() { };
sub.Register(ob1);
sub.Register(ob2);
sub.Register(ob3);
Console.WriteLine("--------------------------------");
sub.Publish("最近好多明星结婚啦!");
Console.WriteLine("--------------------------------");
sub.Remove(ob2);
Console.WriteLine("--------------------------------");
sub.Publish("众泰出保时捷款了!");
Console.ReadKey();
结果:
就我而言, 我虽然安装了今日头条, 但是我并不是每一条都想去看的, 因为很多我不感兴趣. 就推模式而言, 不管我想不想要, 都推送给我, 真是有些烦躁, 那能不能只推送我感兴趣的新闻呢?
二、拉模式
拉模式与推模式最大的区别, 我觉得是在于, 观察者可以筛选推送的信息, 从观察者的角度来看, 就不再是无选择的一口吞, 而是有选择的, 选择自己感兴趣的信息接收.
作为观察者这一边, 需要作出部分改变了
/// <summary>
/// 抽象观察者
/// </summary>
public abstract class Observer
{
public string Name { get; set; }
public abstract void Read(Subject subject);
}
/// <summary>
/// 具体观察者 -- 安装了今日头条的用户
/// </summary>
public class ConcreteObserver : Observer
{
public List<string> Likes { get; set; }
public override void Read(Subject subject)
{
ConcreteSubject sub = subject as ConcreteSubject;
if (Likes.Contains(sub.GetCategory()))
{
Console.WriteLine("{0} 看了新闻 : {1}", this.Name, sub.News );
}
}
}
发布者这一方, 也需要修改一下
/// <summary>
/// 抽象主题 -- 新闻