C#观察者模式实战教程：事件通知与实时更新

观察者模式

代码：

///<观察者模式>
//1. 定义观察者接口
public interface IObserver 
{
    void Update(string message);
}
//2. 定义主题(被观察者)接口
public interface ISubject 
{
    void RegisterObserver(IObserver observer);
    void RemoveObserver(IObserver observer);
    void Notify();
}
//3. 定义具体主题(被观察者)
public class Subject : ISubject
{
    private List<IObserver> _observers = new List<IObserver>();
    private string _state { get ; set; }
    public string SetState
    {
        get { return _state; }
        set
        {
            _state = value;
            Notify();
        }
    }
    public void RegisterObserver(IObserver observer)
    {
        _observers.Add(observer);
    }
    public void RemoveObserver(IObserver observer)
    {
        _observers.Remove(observer);
    }
    public void Notify()
    {
        foreach (var observer in _observers)
        {
            observer.Update(_state);
        }
    }
}
//4. 定义具体观察者
public class Observer : IObserver
{
    private string _name;
    public Observer(string name) 
    { 
    _name = name;
    }
    public string GetName()
    { 
    return _name;
    }
    public void Update(string message)
    {
        Console.WriteLine($"Observer{_name} received message: {message}");
    }
}
///<观察者模式/>

执行流程：

Subject subject = new Subject();
IObserver observer1 = new Observer("100");
IObserver observer2 = new Observer("101");

subject.RegisterObserver(observer1);
subject.RegisterObserver(observer2);

subject.SetState = "New message"; // 自动通知所有观察者
subject.RemoveObserver(observer1);
subject.SetState = "Another message"; // 仅通知observer2

模式要点

1. 主题(Subject)

   • 维护观察者列表

   • 状态变更时自动通知

//设置状态调用Notify()方法
public string SetState
{
    get { return _state; }
    set
    {
        _state = value;
        Notify();
    }
}
//更新观察者列表中所有观察者的状态
public void Notify()
{
    foreach (var observer in _observers)
    {
        observer.Update(_state);
    }
}

2. 观察者(Observer)

   • 实现Update()方法

   • 接收主题通知

3. 接口分离

   • ISubject定义管理观察者的方法

   • IObserver定义更新接口

优势

• 主题和观察者松耦合

• 支持动态添加/移除观察者

• 状态变更自动传播

适用场景

• 事件通知系统

• 数据监控

• GUI事件处理

• 实时数据更新

完整代码:

///<观察者模式>
public interface IObserver 
{
    void Update(string message);
}
public interface ISubject 
{
    void RegisterObserver(IObserver observer);
    void RemoveObserver(IObserver observer);
    void Notify();
}
public class Subject : ISubject
{
    private List<IObserver> _observers = new List<IObserver>();
    private string _state { get ; set; }
    public string SetState
    {
        get { return _state; }
        set
        {
            _state = value;
            Notify();
        }
    }
    public void RegisterObserver(IObserver observer)
    {
        _observers.Add(observer);
    }
    public void RemoveObserver(IObserver observer)
    {
        _observers.Remove(observer);
    }
    public void Notify()
    {
        foreach (var observer in _observers)
        {
            observer.Update(_state);
        }
    }
}
public class Observer : IObserver
{
    private string _name;
    public Observer(string name) 
    { 
    _name = name;
    }
    public string GetName()
    { 
    return _name;
    }
    public void Update(string message)
    {
        Console.WriteLine($"Observer{_name} received message: {message}");
    }
}
///<观察者模式/>

public class Program
{
    public static void Main(string[] args)
    {
        ///<观察者模式>
        Console.WriteLine();
        Console.WriteLine("观察者模式:");
        Subject subject = new Subject();
        IObserver observer1 = new Observer("100");
        IObserver observer2 = new Observer("101");
        subject.RegisterObserver(observer1);
        subject.RegisterObserver(observer2);
        subject.SetState = "New message";
        subject.RemoveObserver(observer1);
        subject.SetState = "Another message";
        ///<观察者模式/>
     }
}