Head First设计模式之观察者模式

//被观察者public interface IObject
{ IList<IMonitor> ListMonitor { get; set; } //定义观察者集合，因为多个观察者观察一个对象，所以这里用集合
string SubjectState { get; set; } //被观察者的状态 void AddMonitor(IMonitor monitor); //添加一个观察者 void RemoveMonitor(IMonitor monitor); //移除一个观察者 void SendMessage(); //向所有观察者发送消息 }
public class Subject : IObject
{ private IList<IMonitor> listMonitor = new List<IMonitor>(); public string SubjectState //被观察者的状态
{
get;set;
} public IList<IMonitor> ListMonitor //实现具体的观察者列表属性
{
get { return listMonitor; }
set { listMonitor = value; }
} public void AddMonitor(IMonitor monitor) //实现具体的添加观察者方法
{
listMonitor.Add(monitor); } public void RemoveMonitor(IMonitor monitor) //实现具体的移除观察者方法
{ listMonitor.Remove(monitor);
} public void SendMessage() //实现具体的发送消息方法
{
foreach (IMonitor m in listMonitor) //发送给所有添加过的观察者，让观察者执行update方法以同步更新自身状态
{
m.Update();
}
}
}//观察者 public interface IMonitor //定义观察者接口
{
void Update();
} public class Monitor : IMonitor //实现具体观察者
{
private string monitorState="Stop!"; //观察者初始状态，会随着被观察者变化而变化
private string name; //观察者名称，用于标记不同观察者
private IObject subject; //被观察者对象 public Monitor (IObject subject, string name) //在构造观察者时，传入被观察者对象，以及标识该观察者名称
{
this.subject = subject;
this.name = name;
Console.WriteLine("我是观察者{0}，我的初始状态是{1}", name, monitorState); } public void Update() //当被观察者状态改变，观察者需要随之改变
{
monitorState = subject.SubjectState;
Console.WriteLine("我是观察者{0}，我的状态是{1}", name, monitorState); }
}//前端调用 static void Main(string[] args)
{ IObject subject = new Subject();
subject.AddMonitor(new Monitor(subject, "Monitor_1"));
subject.AddMonitor(new Monitor(subject, "Monitor_2"));
subject.AddMonitor(new Monitor(subject, "Monitor_3")); subject.SubjectState = "Start!";
subject.SendMessage(); Console.Read();
}
}