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

MediatR领域事件发布的核心机制是通过IPublisher.Publish()分发INotification实现，需在事务提交前调用、处理器注册为transient、事件为不可变DTO。

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

MediatR 本身不直接提供“领域事件”抽象，它只负责消息（IRequest、INotification）的同步/异步分发。所谓“领域事件”，是业务建模概念，需靠 INotification 及其处理器（IHandleNotification）来模拟实现——关键在于：事件发布必须走 IPublisher.Publish()，而不是直接 new + 调用。

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

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

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

以订单创建为例，发布 OrderCreatedEvent 的典型流程如下：

// 1. 定义事件（纯数据）
public record OrderCreatedEvent(Guid OrderId, decimal Total) : INotification;
// 2. 在应用服务中完成业务逻辑后发布
public class OrderService
{
private readonly IPublisher _publisher;
private readonly AppDbContext _context;
public OrderService(IPublisher publisher, AppDbContext context)
{
    _publisher = publisher;
    _context = context;
}

public async Task 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 发布领域事件（它是为请求响应设计的）。

							

								
								

									大同搜索
									
多语言高质量的AI搜索
								
								下载 
							
						

为什么领域事件处理器不自动执行或执行两次
常见现象是 IHandleNotification 没触发，或在并发下重复执行。根本原因多出在注册和生命周期上：

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

验证方式：在处理器构造函数加日志，看是否被实例化；检查 DI 容器中 IHandleNotification 的注册数量是否为 1。
事务一致性怎么保障
MediatR 默认同步执行通知，但数据库事务已提交，无法回滚处理器中的异常。要真正实现“发布即一致”，必须引入事务钩子或外部补偿：

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

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