C# 使用.NET内置的 IObservable＜T＞ 和 IObserver＜T＞-观察者模式

 核心概念

1. IObservable<T>

   1. 表示 可观察的数据源（如事件流、实时数据）。

   2. 关键方法：Subscribe(IObserver<T> observer)，用于注册观察者。

2. IObserver<T>

   1. 表示 数据的接收者，响应数据变化。

   2. 三个核心方法：

      1. OnNext(T value)：接收新数据。

      2. OnError(Exception error)：处理错误。

      3. OnCompleted()：响应数据流结束。

观察者实现：

  public class 观察者 : IObserver<float>{public void OnNext(float price){Console.WriteLine($"最新股价: {price}$");}public void OnError(Exception ex){Console.WriteLine($"错误: {ex.Message}");}public void OnCompleted(){Console.WriteLine("股票数据流结束");}}

被观察者实现：

 public class 被观察者 : IObservable<float>{private List<IObserver<float>> _observers = new List<IObserver<float>>();public IDisposable Subscribe(IObserver<float> observer){_observers.Add(observer);return new Unsubscriber(_observers, observer);}//这段代码定义了一个 Unsubscriber 内部类，用于管理观察者（IObserver<T>）的订阅和取消订阅逻辑。//它的核心作用是 安全地从观察者列表中移除某个观察者，避免内存泄漏或无效通知。private class Unsubscriber : IDisposable{private List<IObserver<float>> _observers;private IObserver<float> _observer;public Unsubscriber(List<IObserver<float>> observers, IObserver<float> observer){_observers = observers;_observer = observer;}public void Dispose(){if (_observer != null && _observers.Contains(_observer))_observers.Remove(_observer);}}// 模拟股价变动public void UpdatePrice(float price){foreach (var observer in _observers){observer.OnNext(price);}}public void MarketClosed(){foreach (var observer in _observers){observer.OnCompleted();}}}

WInform调用案例：

    public partial class Form1 : Form{public Form1(){InitializeComponent();}观察者 A = new 观察者();被观察者 B = new 被观察者();IDisposable A回执;private void btn_观察_Click(object sender, EventArgs e){A回执 = B.Subscribe(A);}private void btn_取消观察_Click(object sender, EventArgs e){A回执.Dispose();}private void btn_价格一_Click(object sender, EventArgs e){B.UpdatePrice(1);}private void btn_价格二_Click(object sender, EventArgs e){B.UpdatePrice(2);}private void btn_股市关闭_Click(object sender, EventArgs e){B.MarketClosed();}}