c#如何实现观察者模式_c#观察者模式最全用法总结

小静同学_6010

小静同学_6010

2026-04-14

617人浏览

原创

优先使用 .NET 原生 IObservable + Observer.Create(),它线程安全、支持取消与错误传播;避免手写 Subject 或滥用 event,正确处理空事件调用、Dispose 和调度上下文。

c#如何实现观察者模式_c#观察者模式最全用法总结

Observer 和 IObservable 是 .NET 原生支持,不是“自己造轮子”的首选

如果你在写新项目或重构旧逻辑,优先用 IObservable + Observer.Create(),而不是手写 Subject 类或事件委托链。.NET Framework 4.0+ 和所有现代 .NET(5/6/7/8)都内置了响应式扩展(System.Reactive),它比手动维护订阅列表更健壮、线程安全、支持取消和错误传播。

常见错误是把 event 当成观察者模式等价物——事件没有取消订阅语法糖、不处理异常传递、无法链式组合(比如 .Where().Select().Take(5))。而 IObservable 天然支持这些。

  • 用 Observable.FromEventPattern() 包装 UI 事件(如按钮点击),避免手动 +=/-=
  • Observer.Create(onNext: Console.WriteLine, onError: ex => Log.Error(ex), onCompleted: () => Console.WriteLine("done")) 可一次性指定三类回调
  • 订阅后务必保留 IDisposable 返回值,调用 .Dispose() 才算真正取消——漏掉这步会导致内存泄漏

用 event 实现简易观察者时,必须防御 null 订阅者

event 本身不是线程安全的,且触发前不检查是否为空会直接抛 NullReferenceException。这不是风格问题,是运行时必踩的坑。

正确写法永远是:

public event Action<string> OnMessage;
// 触发时:
OnMessage?.Invoke("data");</string>

别写 if (OnMessage != null) OnMessage("data");——中间可能被其他线程取消订阅,导致空引用。

  • 如果需要线程安全分发,用 lock 包住整个调用(但会降低吞吐),或改用 ConcurrentQueue 缓存通知再批量执行
  • 不要在事件回调里长时间阻塞(如同步 HTTP 调用),否则拖慢所有订阅者;考虑用 Task.Run(() => { ... }) 卸载到后台线程
  • 事件参数建议封装为不可变类(record 或 readonly struct),避免订阅者意外修改影响其他监听方

自定义 Subject 时,Dispose() 必须清理所有订阅并阻止后续 Subscribe()

手写 Subject 类(比如继承 IObservable 和 IObserver)时,最常忽略的是:订阅者调用 .Dispose() 后,你还允许新订阅进来,或者没清空内部列表。

C#
C#

"避开 C# 常见错误——空陷阱、异步陷阱、LINQ 陷阱及资源泄漏。"

下载

典型错误结构:

private List<iobserver>> _observers = new();
public IDisposable Subscribe(IObserver<t> observer) {
    _observers.Add(observer); // 没检查是否已 disposed!
    return new Unsubscriber(_observers, observer);
}</t></iobserver>

正确做法是加一个 bool _isDisposed 标志,并在 Subscribe() 开头判断:

if (_isDisposed) throw new ObjectDisposedException(nameof(MySubject));
  • Unsubscriber 的 Dispose() 方法里,除了从列表移除,还要设 _isDisposed = true(如果这是单次使用的 subject)
  • 如果 subject 需要重用(比如广播最新值给新订阅者),就得实现“热”语义,此时要用 ReplaySubject 或 BehaviorSubject——别自己重复造
  • 手动管理生命周期时,Subscribe() 返回的 IDisposable 对象不能是匿名委托闭包,否则 GC 无法及时回收;应显式定义类型

调试观察者链断裂时,先看 Dispose() 调用时机和线程上下文

现象:某段逻辑明明调用了 OnNext(),但订阅者的回调就是不执行。90% 情况不是代码写错,而是 Dispose() 被提前触发,或回调发生在非预期线程(比如 UI 订阅者收到后台线程通知)。

排查步骤:

  • 在 Subscribe() 和 Unsubscriber.Dispose() 里加日志,确认谁、何时取消了订阅
  • 用 Observable.SubscribeOn(Scheduler.ThreadPool) 或 .ObserveOn(SynchronizationContext.Current) 显式控制调度,尤其 WinForms/WPF 中更新控件必须回到 UI 线程
  • 如果用了 async 回调(如 Observer.Create(async x => await Process(x))),注意 IObserver 不支持异步方法签名——必须用 Task.Run 包一层,否则 await 会丢失上下文

真正麻烦的是跨域(AppDomain)或跨进程场景,这时原生 IObservable 失效,得换 gRPC 或消息队列——但那已经不属于观察者模式范畴了。

相关文章

PHP速学视频免费教程(入门到精通)
PHP速学视频免费教程(入门到精通)

PHP怎么学习?PHP怎么入门?PHP在哪学?PHP怎么学才快?不用担心,这里为大家提供了PHP速学教程(入门到精通),有需要的小伙伴保存下载就能学习啦!

下载

相关标签:

c#

本站声明:本文内容由网友自发贡献,版权归原作者所有,本站不承担相应法律责任。如您发现有涉嫌抄袭侵权的内容,请联系admin@php.cn

相关专题

更多
c#是什么意思
c#是什么意思

C#是一种通用的面向对象编程语言,它在.NET框架上运行,可用于开发各种类型的应用程序。本专题为大家提供c#相关的各种文章、以及下载和课程。

2023.08.08

1092

5

什么是c#
什么是c#

C#(读作C Sharp)是一种现代的、通用的、面向对象的编程语言。它由微软公司开发,于2000年首次发布,主要用于开发Windows桌面应用程序、Web应用程序、移动应用程序以及游戏开发等领域。C#是一种类型安全和托管的编程语言,它结合了C++的强大性能和C语言的简单易学特点,并引入了许多新的特性和概念,如委托、属性、泛型和异步编程等,以提高开发效率和代码可维护性。

2023.08.31

3191

3

C#中base关键字的用法
C#中base关键字的用法

在C#中,base关键字用于访问当前类的基类成员,这包括基类的字段、属性、方法、构造函数、索引器以及事件。想了解更多C#的相关内容,可以阅读本专题下面的文章。

2024.03.13

905

8

C#Task用法
C#Task用法

Task在C#中是用于表示异步操作的对象,它位于System.Threading.Tasks命名空间中。想了解更多C#中各种用法的相关内容,可以阅读本专题下面的文章。

2024.03.14

2655

11

C# 并发与异步编程
C# 并发与异步编程

本专题系统讲解 C# 异步编程与并发控制,重点介绍 async 和 await 关键字、Task 类、线程池管理、并发数据结构、死锁与线程安全问题。通过多个实战项目,帮助学习者掌握 如何在 C# 中编写高效的异步代码,提升应用的并发性能与响应速度。

2026.02.03

332

18

C# 多线程与异步编程
C# 多线程与异步编程

本专题深入讲解 C# 中多线程与异步编程的核心概念与实战技巧,包括线程池管理、Task 类的使用、async/await 异步编程模式、并发控制与线程同步、死锁与竞态条件的解决方案。通过实际项目,帮助开发者掌握 如何在 C# 中构建高并发、低延迟的异步系统,提升应用性能和响应速度。

2026.02.06

429

20

C# ASP.NET Core微服务架构与API网关实践
C# ASP.NET Core微服务架构与API网关实践

本专题围绕 C# 在现代后端架构中的微服务实践展开,系统讲解基于 ASP.NET Core 构建可扩展服务体系的核心方法。内容涵盖服务拆分策略、RESTful API 设计、服务间通信、API 网关统一入口管理以及服务治理机制。通过真实项目案例,帮助开发者掌握构建高可用微服务系统的关键技术,提高系统的可扩展性与维护效率。

2026.03.11

631

24

C# Unity游戏开发与ECS架构实践
C# Unity游戏开发与ECS架构实践

本专题聚焦 C# 在 Unity 游戏开发中的应用,系统讲解 ECS(Entity-Component-System)架构设计、游戏对象管理、性能优化与内存控制策略。通过实际游戏案例,帮助开发者构建高性能、结构清晰的游戏系统,提高游戏开发效率与运行性能。

2026.04.13

329

20

c#是什么意思
c#是什么意思

C#是一种通用的面向对象编程语言,它在.NET框架上运行,可用于开发各种类型的应用程序。本专题为大家提供c#相关的各种文章、以及下载和课程。

2023.08.08

1092

5

热门下载

更多
网站特效
/
网站源码
/
网站素材
/
前端模板

精品课程

更多
相关推荐
/
热门推荐
/
最新课程
C++ Core Guidelines
C++ Core Guidelines

共0课时 | 0人学习

C++ Reference
C++ Reference

共0课时 | 0人学习

C++ 官方标准说明
C++ 官方标准说明

共0课时 | 0人学习