前言
观察者(Observer)模式也称发布-订阅(Publish-Subscribe)模式,定义了对象间一种一对多的依赖关系,当一个对象的状态发生改变时,所有依赖于它的对象都得到通知并被自动更新。
观察者模式的图解如下所示:
Subject(目标):
目标知道它的观察者。可以有任意多个观察者观察同一个目标。
Observer(观察者):
ConcreteSubject(具体目标):
将有关状态存入各ConcreteObserver对象。
当它的状态发生改变时,向它的各个观察者发出通知。
ConcreteObserver(具体观察者):
维护一个指向ConcreteSubject对象的引用。
存储有关状态,这些状态应与目标的状态保存一致。
实现Observer的更新接口以使自身状态与目标的状态保持一致。
不使用事件的示例
接下来我将根据上面的图解写一个C#观察者模式的例子,刚开始这个例子没有使用事件,在后面一个例子中使用事件。
首先来看看Subject(目标):
//主题接口
public interface ISubject
{
public void Attach(Observer observer);
public void Detach(Observer observer);
public void Notify();
public string? SubjectState { get; set; }
}
这里我使用的是接口,里面有Attach、Detach和Notify方法的声明,还有SubjectState属性的声明。
接下来看看ConcreteSubject(具体目标):
public class School : ISubject
{
private IList<Observer> observers = new List<Observer>();
public string? SubjectState { get; set; }
public void Attach(Observer observer)
{
observers.Add(observer);
}
public void Detach(Observer observer)
{
observers.Remove(observer);
}
public void Notify()
{
foreach (var observer in observers)
{
observer.Update();
}
}
}
这里我以学校发通知为例,School类实现了ISubject接口,有一个观察者的列表,在Attach方法中添加一个观察者,在Detach方法中移除一个观察者。在Notify方法中遍历观察者的列表,让每一个观察者都执行Update方法。
现在来看看Observer(观察者):
public abstract class Observer
{
protected string? name;
protected ISubject? subject;
public Observer(string name,ISubject subject)
{
this.name = name;
this.subject = subject;
}
public abstract void Update();
}
再看看ConcreteObserver(具体观察者):
public class Student : Observer
{
public Student(string name,ISubject subject) : base(name,subject)
{
}
public override void Update()
{
Console.WriteLine($"{name}接收到来自学校的通知:{subject?.SubjectState},
时间:{DateTime.Now}\r\n");
}
}
这里我以学生接收来自学校的消息为例,Student类继承自Observer抽象类,并重写了Update方法。
最后来看看怎么使用观察者模式:
static void Main(string[] args)
{
School school = new School();
Student student1 = new Student("小王", school);
Student student2 = new Student("小明", school);
Student student3 = new Student("小红", school);
school.Attach(student1);
school.Attach(student2);
school.Attach(student3);
school.SubjectState = "学校放假了";
school.Notify();
school.Detach(student3);
Task.Delay(3000).Wait();
school.SubjectState = "学校开学了";
school.Notify();
Console.ReadLine();
}
创建一个School对象,三个Student对象。
school.Attach(student1);
school.Attach(student2);
school.Attach(student3);
表示将student1、student2、student3添加到school中的观察者列表中。
school.SubjectState = "学校放假了";
school.Notify();
设置school中SubjectState属性的值,然后调用school的Notify方法。
school.Detach(student3);
将student3从school的观察者列表中移除。
Task.Delay(3000).Wait();
等待3秒。
school.SubjectState = "学校开学了";
school.Notify();
Console.ReadLine();
重新设置school中SubjectState属性的值,然后再调用school的Notify方法。
运行结果如下所示:
学校放假了,小王、小明和小红都接收到了学校的通知。由于后面小红被移出了观察者列表,因此学校开学了的消息小红没有接收到。
使用事件的示例
C#中可以通过事件来使用观察者模式,接下来我将以一个示例加以说明。
自定义事件数据类:
public class SendMessageArgs : EventArgs
{
public string? Message { get; set; }
public DateTime DateTime { get; set; }
public SendMessageArgs(string? message)
{
Message = message;
DateTime = DateTime.Now;
}
}
Person类:
public class Person
{
public string? Name { get; set; }
public event EventHandler<SendMessageArgs>? SendMessageEvent;
public Person(string? name)
{
Name = name;
}
public void SendMessage(string message)
{
SendMessageArgs sendMessageArgs = new SendMessageArgs(message);
SendMessageEvent?.Invoke(this, sendMessageArgs);
}
public void ShowMessage(object? sender,SendMessageArgs e)
{
Person? person = (Person?)sender;
Console.WriteLine($"{this.Name}:收到来自{person?.Name}的消息:{e.Message},时间:{e.DateTime}\r\n");
}
public void Subscribe(Person person)
{
person.SendMessageEvent += ShowMessage;
}
public void UnSubscribe(Person person)
{
person.SendMessageEvent -= ShowMessage;
}
}
Person类中的SendMessage方法会触发事件,ShowMessage方法是事件处理程序,Subscribe方法可以订阅事件,UnSubscribe方法可以取消订阅事件。
现在来看看是怎么使用:
static void Main(string[] args)
{
Person Trump = new Person("川普");
Person Biden = new Person("拜登");
Person person1 = new Person("person1");
Person person2 = new Person("person2");
Person person3 = new Person("person3");
person1.Subscribe(Trump);
person2.Subscribe(Trump);
person3.Subscribe(Trump);
person1.Subscribe(Biden);
Trump.SendMessage("Nobody kNows ... better than me!!!");
Task.Delay(2000).Wait();
Biden.SendMessage("I don't believe it!!!");
person3.UnSubscribe(Trump);
Task.Delay(2000).Wait();
Trump.SendMessage("Make ... Great Again!!!");
Console.ReadLine();
}
创建了5个Person对象,分别为Trump、Biden、person1、person2、person3。
person1、person2、person3订阅了Trump,person1订阅了Biden。
Trump发了一条消息,然后过了2秒,Biden也发了一条消息。
person3不再订阅Trump,过了2秒,Trump又发消息了。
运行结果如下所示:
由于person1、person2、person3订阅了Trump,所以可以收到来自Trump的消息。
由于person1订阅了Biden,所以可以收到来自Biden的消息。
后面person3退订了Trump,所以只有person1、person2能收到来自Trump的消息。
总结
以上使用C#分别创建了不通过事件与通过事件的示例,介绍了在C#中如何使用观察者模式,希望对你有所帮助。
参考
2、《大话设计模式》
3、《设计模式:可复用面向对象软件的基础》
4、YouTube [Design Patterns: C# Pub-Sub Simple Twitter example]