C# 领域事件发布方法 C#如何使用MediatR实现领域事件

来源:这里教程网 时间:2026-02-21 17:40:48 作者:

MediatR 领域事件发布的核心机制是什么

MediatR 本身不直接提供“领域事件”抽象,它只负责消息(

IRequest
INotification
)的同步/异步分发。所谓“领域事件”,是业务建模概念,需靠
INotification
及其处理器(
IHandleNotification<t></t>
)来模拟实现——关键在于:事件发布必须走
IPublisher.Publish()
,而不是直接 new + 调用。

常见错误是把领域事件当普通类直接触发逻辑,绕过 MediatR 管道,导致事务一致性丢失、日志/重试/装饰器失效。

INotification
必须是无返回值、不可变的 DTO(如
OrderCreatedEvent
),不能带业务方法
所有处理器必须注册为 transient(每次发布新建实例),避免状态污染 发布点应在领域层完成业务变更后、事务提交前(如 EF Core 的
SaveChangesAsync
后立即
Publish

如何在 C# 中正确发布一个领域事件

以订单创建为例,发布

OrderCreatedEvent
的典型流程如下:

// 1. 定义事件(纯数据)
public record OrderCreatedEvent(Guid OrderId, decimal Total) : INotification;
<p>// 2. 在应用服务中完成业务逻辑后发布
public class OrderService
{
private readonly IPublisher _publisher;
private readonly AppDbContext _context;</p><pre class="brush:php;toolbar:false;">public OrderService(IPublisher publisher, AppDbContext context)
{
    _publisher = publisher;
    _context = context;
}
public async Task<Guid> CreateOrderAsync(CreateOrderCommand cmd)
{
    var order = new Order(cmd.Items);
    _context.Orders.Add(order);
    await _context.SaveChangesAsync(); // 事务已持久化
    // ✅ 正确:发布事件(此时可被事务拦截器捕获)
    await _publisher.Publish(new OrderCreatedEvent(order.Id, order.Total));
    return order.Id;
}

}

注意:

IPublisher
是 MediatR 提供的接口,由 DI 容器注入;不要用
IMediator
发布领域事件(它是为请求响应设计的)。

为什么领域事件处理器不自动执行或执行两次

常见现象是

IHandleNotification<t></t>
没触发,或在并发下重复执行。根本原因多出在注册和生命周期上:

未调用
services.AddMediatR(cfg => cfg.RegisterServicesFromAssemblyContaining<ordercreatedevent>())</ordercreatedevent>
,导致处理器未被扫描注册
处理器类未实现
IHandleNotification<ordercreatedevent></ordercreatedevent>
,或泛型参数写错(如用了
INotification
基类)
使用了 singleton 生命周期注册处理器(
AddSingleton<ihandlenotification>, Handler>()</ihandlenotification>
),引发状态共享和并发问题
EF Core 中启用了延迟加载代理,且事件处理器里又访问了未加载的导航属性,触发额外查询并卡住管道

验证方式:在处理器构造函数加日志,看是否被实例化;检查 DI 容器中

IHandleNotification<ordercreatedevent></ordercreatedevent>
的注册数量是否为 1。

事务一致性怎么保障

MediatR 默认同步执行通知,但数据库事务已提交,无法回滚处理器中的异常。要真正实现“发布即一致”,必须引入事务钩子或外部补偿:

用 EF Core 的
DbContext.SaveChanges
后的
Transaction.Commit
事件,在提交成功后再调用
Publish
(需自定义
SaveChangesAsync
包装)
更推荐方案:改用
Outbox Pattern
,把事件先写入本地 outbox 表(同事务),再由后台轮询投递——MediatR 不参与事务,只负责最终消费
若坚持用 MediatR 内联发布,至少让所有处理器标记为
[Transactional]
(需自定义行为),并在处理器抛异常时手动回滚(不推荐,耦合太重)

别忽略这个细节:领域事件不是“发出去就完事”,它的语义是“某件事已确定发生”,不是“我打算让它发生”。

相关推荐