0

0

c# MediatR 的 Publish 并发策略(ParallelNoWait, SyncContinueOnException)

月夜之吻

月夜之吻

发布时间:2026-01-03 12:14:02

|

300人浏览过

|

来源于php中文网

原创

MediatR的Publish默认同步顺序执行,逐个await handler;ParallelNoWait策略真正并发但不等待、吞异常;SyncContinueOnException仍同步但异常不中断后续;可控并发需手动Task.WhenAll+错误处理。

c# mediatr 的 publish 并发策略(parallelnowait, synccontinueonexception)

MediatR 的 Publish 默认是同步顺序执行,不是并发

很多人看到 IPublisher.Publish 返回 Task 就默认它天然支持并发,其实不然。MediatR 的默认行为是:所有 IAsyncNotificationHandler 按注册顺序**逐个 await**,一个 handler 抛异常会中断后续 handler 执行(除非显式配置异常处理策略)。这和你手动写 await handler1.Handle(...); await handler2.Handle(...); 效果一致。

ParallelNoWait 策略:真正并发但完全放弃等待与错误传播

这是 MediatR 8+ 引入的并发策略,通过 ServiceCollection 配置启用:

services.AddMediatR(cfg =>
{
    cfg.RegisterServicesFromAssembly(typeof(Program).Assembly);
    cfg.NotificationPublisher = new ParallelNoWaitPublisher(); // 关键
});

它会把所有 handler 包装进 Task.Run 并发启动,然后立即返回已完成的 Task.CompletedTask —— 也就是说:

  • Publish 调用后几乎立刻返回,不等任何 handler 完成
  • handler 内部抛出的异常会被吞掉(仅记录到 ILogger),不会向上冒泡
  • 无法感知 handler 是否成功、耗时多久、是否被取消
  • 不适合依赖 handler 副作用(如发消息、更新缓存)后继续逻辑的场景

SyncContinueOnException 是假“并发”,本质是同步兜底

这个策略名字有误导性:它**不并发**,也不并行。它的作用只是让某个 handler 抛异常时,不影响其他 handler 继续执行 —— 仍按注册顺序同步调用,只是把每个 Handle 包在 try/catch 里:

services.AddMediatR(cfg =>
{
    cfg.RegisterServicesFromAssembly(typeof(Program).Assembly);
    cfg.NotificationPublisher = new SyncContinueOnExceptionPublisher();
});

典型适用场景:

问问小宇宙
问问小宇宙

问问小宇宙是小宇宙团队出品的播客AI检索工具

下载
  • 多个日志/埋点 handler,一个失败不该阻塞另一个
  • 监控类通知(如发送指标),允许部分失败
  • 你明确不需要 await 结果,但又希望保留调用顺序和可调试性

注意:它仍会等待全部 handler 同步执行完才返回 Task,只是异常不中断流程。

自己实现可控并发:用 Task.WhenAll + 显式错误处理

如果既要并发,又要捕获结果或控制失败策略,MediatR 不提供开箱即用方案,得自己封装。常见做法是在业务层手动聚合 handler 调用:

var tasks = handlers.Select(h => h.Handle(notification, cancellationToken));
var results = await Task.WhenAll(tasks); // 等全部完成,任一失败则整体失败

// 或带错误隔离:
var results = await Task.WhenAll(
    handlers.Select(h => 
        Task.Run(() => h.Handle(notification, cancellationToken))
                .ContinueWith(t => t.Exception?.InnerException, TaskContinuationOptions.OnlyOnFaulted)
                .ContinueWith(t => t.Result ?? null)
    )
);

关键点:

  • 必须从 DI 容器解析 IEnumerable>,不能靠 MediatR 自动分发
  • Task.WhenAll 失败时抛第一个异常;若要忽略部分失败,需用 ContinueWithawait task.OrNothing() 类辅助方法
  • 并发数不受控时可能压垮下游(如 DB 连接池),建议配合 SemaphoreSlim 限流

MediatR 的 Publish 并发能力很轻量,真正需要可靠异步协作时,往往该考虑事件总线(如 MassTransit)或后台任务队列(如 Hangfire)了。

相关专题

更多
php源码安装教程大全
php源码安装教程大全

本专题整合了php源码安装教程,阅读专题下面的文章了解更多详细内容。

203

2025.12.31

php网站源码教程大全
php网站源码教程大全

本专题整合了php网站源码相关教程,阅读专题下面的文章了解更多详细内容。

111

2025.12.31

视频文件格式
视频文件格式

本专题整合了视频文件格式相关内容,阅读专题下面的文章了解更多详细内容。

123

2025.12.31

不受国内限制的浏览器大全
不受国内限制的浏览器大全

想找真正自由、无限制的上网体验?本合集精选2025年最开放、隐私强、访问无阻的浏览器App,涵盖Tor、Brave、Via、X浏览器、Mullvad等高自由度工具。支持自定义搜索引擎、广告拦截、隐身模式及全球网站无障碍访问,部分更具备防追踪、去谷歌化、双内核切换等高级功能。无论日常浏览、隐私保护还是突破地域限制,总有一款适合你!

93

2025.12.31

出现404解决方法大全
出现404解决方法大全

本专题整合了404错误解决方法大全,阅读专题下面的文章了解更多详细内容。

663

2025.12.31

html5怎么播放视频
html5怎么播放视频

想让网页流畅播放视频?本合集详解HTML5视频播放核心方法!涵盖<video>标签基础用法、多格式兼容(MP4/WebM/OGV)、自定义播放控件、响应式适配及常见浏览器兼容问题解决方案。无需插件,纯前端实现高清视频嵌入,助你快速打造现代化网页视频体验。

19

2025.12.31

关闭win10系统自动更新教程大全
关闭win10系统自动更新教程大全

本专题整合了关闭win10系统自动更新教程大全,阅读专题下面的文章了解更多详细内容。

15

2025.12.31

阻止电脑自动安装软件教程
阻止电脑自动安装软件教程

本专题整合了阻止电脑自动安装软件教程,阅读专题下面的文章了解更多详细教程。

6

2025.12.31

html5怎么使用
html5怎么使用

想快速上手HTML5开发?本合集为你整理最实用的HTML5使用指南!涵盖HTML5基础语法、主流框架(如Bootstrap、Vue、React)集成方法,以及无需安装、直接在线编辑运行的平台推荐(如CodePen、JSFiddle)。无论你是新手还是进阶开发者,都能轻松掌握HTML5网页制作、响应式布局与交互功能开发,零配置开启高效前端编程之旅!

3

2025.12.31

热门下载

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

精品课程

更多
相关推荐
/
热门推荐
/
最新课程
10分钟--Midjourney创作自己的漫画
10分钟--Midjourney创作自己的漫画

共1课时 | 0.1万人学习

Midjourney 关键词系列整合
Midjourney 关键词系列整合

共13课时 | 0.9万人学习

AI绘画教程
AI绘画教程

共2课时 | 0.2万人学习

关于我们 免责申明 举报中心 意见反馈 讲师合作 广告合作 最新更新
php中文网:公益在线php培训,帮助PHP学习者快速成长!
关注服务号 技术交流群
PHP中文网订阅号
每天精选资源文章推送

Copyright 2014-2026 https://www.php.cn/ All Rights Reserved | php.cn | 湘ICP备2023035733号