设计模式之-观察者模式
基本简介
实现方式
“观察”
过程
观察者
被观察
撤销观察
经常猫叫了,老鼠跑了,主人醒了
猫大叫一声,所有的老鼠都开始逃跑,主人被惊醒。于是想了想,开启了下面的观察者模式:
一、 “猫叫系统”
银行的防盗系统、高温预警系统、事件处理系统、监控系统,以及这里的“猫叫系统”,其共同特点在于:一个对象的改变会同时影响其他对象做出相应的变化,但是又不知道到底会影响多少个对象。
二、 观察者模式
观察者模式定义了对象之间一对多的依赖关系,当一个对象的状态发生变化时,所有依赖于该对象的其他对象都会被通知,然后自动更新。
观察者模式中,被观察者管理其它的、依赖于它的观察者对象,当被观察者的状态发生变化时,被观察者会主动发出通知,通知依赖于它的观察者,当观察者收到通知时,会做出相应的动作。
三、 “猫叫系统”分析
下面是该例的具体分析过程:
1、系统中共有3个对象:Cat、Mouse、Human
2、首先,明确一下,哪些对象是观察者,也就是哪些对象需要被通知,哪些对象是被观察者。这里,猫是被观察者,正是由于猫的大叫,才引起后面的一系列反应。
3、当猫大叫的时候,就相当于发出了“警告”,此时,老鼠听到了,然后做出了反应,那就是逃跑。同时,睡梦中的Human也被“警告”吓醒了。
四、 观察者模型
五、 模式实现
public class People { string name; public People(string name) { this.name = name; } public void Getup() { Console.WriteLine("猫来了,{0}醒了", name); } } class Mouse { private string name; public Mouse(string name) { this.name = name; } public void Run() { Console.WriteLine("猫来了,{0},跑", name); } } class Cat { private string name; public Cat(string name) { this.name = name; } public delegate void CatShoutEventHandler(); public event CatShoutEventHandler CatShout; public void Shout() { Console.WriteLine("喵,我是:{0}", name); if (CatShout != null) { CatShout(); } } } class Program { static void Main(string[] args) { Cat cat = new Cat("Tom"); Mouse mouse1 = new Mouse("Jerrry"); Mouse mouse2 = new Mouse("Jack"); People people = new People("Owner"); cat.CatShout += new Cat.CatShoutEventHandler(mouse1.Run); cat.CatShout += new Cat.CatShoutEventHandler(mouse2.Run); cat.CatShout += new Cat.CatShoutEventHandler(people.Getup); cat.CatShout -= new Cat.CatShoutEventHandler(mouse2.Run); cat.Shout(); Console.Read(); } }
//Subject接口 public abstract class Subject { private ArrayList observerList = new ArrayList(); public void Attach(Observer observer) { observerList.Add(observer); } public void Detach(Observer observer) { observerList.Remove(observer); } public void Notify() { foreach (Observer item in observerList) { item.Update(); } } } public class Cat : Subject { private string catstate; public string CatState { get { return catstate; } set { catstate = value; } } } //Observer接口 public interface Observer { void Update(); } //具体的Observer public class Mouse : Observer { private Cat cat; public Mouse(Cat cat) { this.cat = cat; } public void Update() { if (this.cat.CatState == "cry") { Console.WriteLine("The cat cry, and the Mouse run!" ); } } } public class Human : Observer { private Cat cat; public Human(Cat cat) { this.cat = cat; } public void Update() { if (this.cat.CatState == "cry") { Console.WriteLine("The cat cry, and the Human wake!"); } } } //系统开始运行 class Program { static void Main(string[] args) { Cat cat = new Cat(); cat.Attach(new Mouse(cat)); cat.Attach(new Human(cat)); cat.CatState = "cry"; cat.Notify(); } }
View Code
代码示例—同事打酱油
View Code using System; using System.Collections.Generic; using System.Text; namespace 观察者模式 { class Program { static void Main(string[] args) { //老板胡汉三 Boss huhansan = new Boss(); //看股票的同事 StockObserver tongshi1 = new StockObserver("魏关姹", huhansan); //看NBA的同事 NBAObserver tongshi2 = new NBAObserver("易管查", huhansan); huhansan.Update += new EventHandler(tongshi1.CloseStockMarket); huhansan.Update += new EventHandler(tongshi2.CloseNBADirectSeeding); //老板回来 huhansan.SubjectState = "我胡汉三回来了!"; //发出通知 huhansan.Notify(); Console.Read(); } } //通知者接口 interface Subject { void Notify(); string SubjectState { get; set; } } //事件处理程序的委托 delegate void EventHandler(); class Secretary : Subject { //声明一事件Update,类型为委托EventHandler public event EventHandler Update; private string action; public void Notify() { Update(); } public string SubjectState { get { return action; } set { action = value; } } } class Boss : Subject { //声明一事件Update,类型为委托EventHandler public event EventHandler Update; private string action; public void Notify() { Update(); } public string SubjectState { get { return action; } set { action = value; } } } //看股票的同事 class StockObserver { private string name; private Subject sub; public StockObserver(string name, Subject sub) { this.name = name; this.sub = sub; } //关闭股票行情 public void CloseStockMarket() { Console.WriteLine("{0} {1} 关闭股票行情,继续工作!", sub.SubjectState, name); } } //看NBA的同事 class NBAObserver { private string name; private Subject sub; public NBAObserver(string name, Subject sub) { this.name = name; this.sub = sub; } //关闭NBA直播 public void CloseNBADirectSeeding() { Console.WriteLine("{0} {1} 关闭NBA直播,继续工作!", sub.SubjectState, name); } } }