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](需自定义行为),并在处理器抛异常时手动回滚(不推荐,耦合太重)
别忽略这个细节:领域事件不是“发出去就完事”,它的语义是“某件事已确定发生”,不是“我打算让它发生”。
