在C#中实现观察者模式,通常涉及两个主要的组件:主题(Subject)和观察者(Observer)。主题负责维护观察者列表,并在其状态发生变化时通知所有注册的观察者。观察者则是对主题状态感兴趣的对象,它们将自己注册到主题上,并在主题状态变化时接收到通知。
下面是一个简单的C#实现示例:
1. 定义观察者接口
首先,定义一个IObserver接口,它声明了一个Update方法,用于在主题状态变化时接收通知。
public interface IObserver
{
void Update(string message);
}
2. 定义主题接口
然后,定义一个ISubject接口,它声明了注册、注销观察者和通知观察者的方法。
public interface ISubject
{
void RegisterObserver(IObserver observer);
void RemoveObserver(IObserver observer);
void NotifyObservers(string message);
}
3. 实现具体的主题类
接下来,实现一个具体的主题类,该类实现了ISubject接口,并维护了一个观察者列表。
using System.Collections.Generic;
public class ConcreteSubject : ISubject
{
private List<IObserver> observers = new List<IObserver>();
public void RegisterObserver(IObserver observer)
{
observers.Add(observer);
}
public void RemoveObserver(IObserver observer)
{
observers.Remove(observer);
}
public void NotifyObservers(string message)
{
foreach (IObserver observer in observers)
{
observer.Update(message);
}
}
// 假设这是主题的一个状态,我们可以修改这个状态并通知观察者
public void SomeBusinessLogic()
{
// ... 执行一些业务逻辑
string result = "Business logic executed";
NotifyObservers(result);
}
}
4. 实现具体的观察者类
然后,实现一个或多个具体的观察者类,这些类实现了IObserver接口。
public class ConcreteObserver : IObserver
{
private string name;
public ConcreteObserver(string name)
{
this.name = name;
}
public void Update(string message)
{
Console.WriteLine($"{name} received: {message}");
}
}
5. 使用示例
最后,演示如何使用这些类。
class Program
{
static void Main(string[] args)
{
// 创建主题
var subject = new ConcreteSubject();
// 创建观察者
IObserver observer1 = new ConcreteObserver("Observer 1");
IObserver observer2 = new ConcreteObserver("Observer 2");
// 注册观察者
subject.RegisterObserver(observer1);
subject.RegisterObserver(observer2);
// 触发主题的业务逻辑,这将通知所有注册的观察者
subject.SomeBusinessLogic();
// 注销一个观察者
subject.RemoveObserver(observer1);
// 再次触发主题的业务逻辑,此时observer1不应接收到消息
subject.SomeBusinessLogic();
}
}
在这个示例中,ConcreteSubject类作为主题,维护了一个观察者列表,并在其SomeBusinessLogic方法被调用时通知所有注册的观察者。ConcreteObserver类作为观察者,实现了IObserver接口,并在接收到通知时打印一条消息。在Main方法中,我们创建了这些类的实例,并展示了如何注册、注销观察者以及触发主题的业务逻辑。