C#观察者模式：事件驱动编程的三种实现方式

1. 观察者模式像订阅杂志一样理解事件驱动第一次听说观察者模式时我的反应和大多数新手一样困惑——这到底是个什么魔法直到某天在咖啡厅看到一位顾客订阅杂志的过程突然茅塞顿开。想象你走进报刊亭对老板说有新刊到货时请通知我。这就是观察者模式的精髓你观察者不需要每天来店里查看轮询而是在感兴趣的事件新刊到货发生时自动获得通知。在C#中实现这种机制主要涉及两个核心角色被观察者Subject就像杂志社维护订阅者列表并提供注册/取消接口观察者Observer如同读者定义接收到通知时的处理逻辑// 基础接口定义 public interface IObserverT { void Update(T data); } public interface ISubjectT { void Register(IObserverT observer); void Unregister(IObserverT observer); void Notify(); }关键理解观察者模式实现了对象间的松耦合。杂志社不需要知道读者具体是谁、做什么工作只需在出版时广播通知。这种设计让系统更容易扩展——新增读者类型不会影响出版流程。2. C#中的三种实现方式对比2.1 经典手写实现这是最基础的方式适合理解原理。我们以温度监控系统为例public class TemperatureSensor : ISubjectfloat { private ListIObserverfloat _observers new(); private float _currentTemp; public void Register(IObserverfloat obs) _observers.Add(obs); public void Unregister(IObserverfloat obs) _observers.Remove(obs); public void Notify() { foreach(var obs in _observers) obs.Update(_currentTemp); } public void SetTemperature(float temp) { _currentTemp temp; Notify(); } } public class Display : IObserverfloat { public void Update(float temp) { Console.WriteLine($当前温度{temp}℃); } }避坑提示记得在Unregister时做null检查。我曾遇到过因未处理null导致的系统崩溃特别是在长时间运行的服务中。2.2 使用事件和委托C#原生的事件机制本质就是观察者模式。这种方式更符合语言习惯public class TemperatureSensor { public event Actionfloat OnTemperatureChanged; private float _currentTemp; public float CurrentTemperature { get _currentTemp; set { if(_currentTemp ! value) { _currentTemp value; OnTemperatureChanged?.Invoke(value); } } } } // 使用示例 var sensor new TemperatureSensor(); sensor.OnTemperatureChanged temp Console.WriteLine($温度更新{temp});优势分析语法更简洁内置线程安全机制无需手动管理订阅列表编译器会自动生成add/remove方法2.3 IObservable接口Reactive Extensions对于复杂事件处理System.IObservable提供了更强大的解决方案public class TemperatureSensor : IObservablefloat { private ListIObserverfloat _observers new(); public IDisposable Subscribe(IObserverfloat observer) { _observers.Add(observer); return new Unsubscriber(_observers, observer); } private class Unsubscriber : IDisposable { private ListIObserverfloat _observers; private IObserverfloat _observer; public void Dispose() { if(_observer ! null _observers.Contains(_observer)) _observers.Remove(_observer); } } public void ReportTemperature(float temp) { foreach(var obs in _observers) { obs.OnNext(temp); } } }适用场景对比表实现方式适用场景优点缺点经典实现教学、简单场景原理清晰需要手动管理事件委托大多数业务场景语法简洁、线程安全功能相对基础IObservable复杂事件流处理支持LINQ、强大操作符学习曲线陡峭3. 实战WPF中的温度监控系统让我们用WPF构建一个真实可用的温度监控界面。这个案例会展示如何将观察者模式应用于UI更新。3.1 模型层实现public class TemperatureModel : INotifyPropertyChanged { private float _temp; public float Temperature { get _temp; set { if(_temp ! value) { _temp value; OnPropertyChanged(); OnTemperatureChanged?.Invoke(value); } } } public event Actionfloat OnTemperatureChanged; public event PropertyChangedEventHandler PropertyChanged; protected void OnPropertyChanged([CallerMemberName] string name null) { PropertyChanged?.Invoke(this, new PropertyChangedEventArgs(name)); } }3.2 ViewModel绑定public class MainViewModel { private readonly TemperatureModel _model; public MainViewModel(TemperatureModel model) { _model model; _model.OnTemperatureChanged temp { // 这里可以添加业务逻辑 CurrentTemp temp; }; } private float _currentTemp; public float CurrentTemp { get _currentTemp; set { _currentTemp value; OnPropertyChanged(); } } public event PropertyChangedEventHandler PropertyChanged; protected void OnPropertyChanged([CallerMemberName] string name null) { PropertyChanged?.Invoke(this, new PropertyChangedEventArgs(name)); } }3.3 视图层XAMLWindow x:ClassTemperatureMonitor.MainWindow xmlnshttp://schemas.microsoft.com/winfx/2006/xaml/presentation xmlns:xhttp://schemas.microsoft.com/winfx/2006/xaml Title温度监控 Height200 Width300 StackPanel TextBlock Text{Binding CurrentTemp, StringFormat当前温度{0}℃} FontSize24 Margin10/ Button Content模拟温度变化 ClickOnTempChange Margin10/ /StackPanel /Window重要经验在WPF中一定要通过Dispatcher.Invoke更新UI线程。我曾遇到过因跨线程访问UI控件导致的诡异崩溃问题。4. 高级应用与性能优化4.1 弱引用事件处理内存泄漏是观察者模式的常见陷阱。当观察者不显式取消注册时会导致对象无法被GC回收public class WeakEventManager { private readonly ListWeakReferenceActionfloat _handlers new(); public void AddHandler(Actionfloat handler) { _handlers.Add(new WeakReferenceActionfloat(handler)); } public void Raise(float temp) { var toRemove new ListWeakReferenceActionfloat(); foreach(var wr in _handlers) { if(wr.TryGetTarget(out var handler)) { handler(temp); } else { toRemove.Add(wr); } } foreach(var dead in toRemove) { _handlers.Remove(dead); } } }4.2 异步事件处理当观察者处理较耗时为避免阻塞通知线程public event Funcfloat, Task OnTemperatureChangedAsync; // 触发方式 if(OnTemperatureChangedAsync ! null) { var handlers OnTemperatureChangedAsync.GetInvocationList() .CastFuncfloat, Task(); foreach(var handler in handlers) { _ Task.Run(() handler.Invoke(_currentTemp)); } }4.3 事件聚合器模式对于跨模块通信可以使用集中式事件管理器public class EventAggregator { private readonly ConcurrentDictionaryType, object _events new(); public TEvent GetEventTEvent() where TEvent : new() { return (TEvent)_events.GetOrAdd(typeof(TEvent), _ new TEvent()); } } // 定义强类型事件 public class TemperatureChangedEvent { public event Actionfloat OnEvent; public void Publish(float temp) OnEvent?.Invoke(temp); public void Subscribe(Actionfloat action) OnEvent action; public void Unsubscribe(Actionfloat action) OnEvent - action; }性能优化数据对比处理10000次通知方式内存占用执行时间线程安全普通事件1.2MB45ms否弱引用事件2.1MB68ms是异步事件1.3MB120ms部分事件聚合器1.8MB55ms是5. 常见问题与调试技巧5.1 事件不触发检查清单订阅检查确认操作确实执行使用调试器查看事件调用列表临时添加日志输出空值检查// 错误方式 OnTemperatureChanged(temp); // 可能NullReferenceException // 正确方式 OnTemperatureChanged?.Invoke(temp);线程上下文问题UI事件需要在主线程触发使用SynchronizationContext.Post跨线程5.2 内存泄漏排查使用内存分析工具检查在VS中使用Diagnostic Tools特别关注事件持有对象引用静态事件监听器未取消的定时器5.3 设计原则验证好的观察者模式实现应该通过以下检查被观察者不需要知道观察者的具体类型可以动态添加/移除观察者通知机制不依赖特定线程模型没有形成观察者之间的隐式依赖6. 模式变体与应用场景扩展6.1 推模型 vs 拉模型推模型事件发生时发送完整数据void Update(TemperatureData data);拉模型观察者根据需要获取数据void Update(ISubject sender); // 观察者调用 sender.GetTemperature()选择依据数据量小且固定 → 推模型数据量大或可选 → 拉模型需要最小化通知开销 → 拉模型6.2 中介者模式结合当观察者之间也需要通信时可以引入中介者public class MonitoringMediator { private readonly ListISensor _sensors new(); private readonly ListIDisplay _displays new(); public void RegisterSensor(ISensor sensor) { sensor.OnAlert OnSensorAlert; _sensors.Add(sensor); } private void OnSensorAlert(AlertData data) { foreach(var display in _displays) { display.ShowAlert(data); } } }6.3 C#特定优化技巧使用EventHandler 标准模式public event EventHandlerTemperatureChangedEventArgs TemperatureChanged; public class TemperatureChangedEventArgs : EventArgs { public float NewValue { get; } public float OldValue { get; } }避免频繁通知private float _temp; public float Temperature { get _temp; set { if(Math.Abs(_temp - value) 0.1) { // 阈值检查 _temp value; OnTemperatureChanged?.Invoke(value); } } }使用ValueChanged模式public class ValueChangedT { private T _value; public T Value { get _value; set { if(!EqualityComparerT.Default.Equals(_value, value)) { _value value; Changed?.Invoke(value); } } } public event ActionT Changed; }观察者模式在C#生态中的典型应用WPF/Silverlight数据绑定ASP.NET Core中间件管道实体框架变更跟踪SignalR客户端通知后台服务状态监控