在事务提交/回滚时触发逻辑EntityFrameworkCore.Triggered的Transactions事务扩展完整指南【免费下载链接】EntityFrameworkCore.TriggeredTriggers for EFCore. Respond to changes in your DbContext before and after they are committed to the database.项目地址: https://gitcode.com/gh_mirrors/en/EntityFrameworkCore.TriggeredEntityFrameworkCore.Triggered 是 EF Core 生态的触发器库它的Transactions 事务扩展允许你在事务提交前后、回滚前后精确挂接业务逻辑——例如仅在数据真正落库后发送通知、发布领域事件或在回滚时清理缓存。本文用通俗的方式带你 5 分钟掌握这个事务扩展的核心概念、最小可用示例与常见问题。一、为什么 BeforeSave / AfterSave 不够用先理解 EF Core 中一个容易被忽视的事实使用 SqlServer 等数据库时每次SaveChanges默认都会被包裹在一个自动事务里。EntityFrameworkCore.Triggered 基础版的两类触发器时机是触发器执行时机其修改是否包含在事务内IBeforeSaveTriggerTSaveChanges写库之前✅ 是IAfterSaveTriggerTSaveChanges写库之后❌ 否问题在于AfterSave 执行时事务并不一定已经提交。如果在这个时点发送邮件、调用第三方 API 或发布事件一旦事务随后回滚就会出现钱没扣、短信却发了的脏通知问题。Transactions 扩展正是为解决这个时机缝隙而设计它新增了 4 组精确对齐数据库事务边界的触发器。二、认识 8 个事务触发器接口同步 异步各一套Transactions 扩展提供 4 组触发器每组都有同步与异步两种写法触发时机同步接口异步接口典型用途提交前IBeforeCommitTriggerTIBeforeCommitAsyncTriggerT最后校验、生成快照提交后IAfterCommitTriggerTIAfterCommitAsyncTriggerT发通知、发事件、清缓存回滚前IBeforeRollbackTriggerTIBeforeRollbackAsyncTriggerT记录回滚原因回滚后IAfterRollbackTriggerTIAfterRollbackAsyncTriggerT恢复缓存、补偿逻辑这 8 个接口定义在 Transactions.Abstractions 项目中。以提交后的异步触发器 IAfterCommitAsyncTrigger.cs 为例它只有一个方法public interface IAfterCommitAsyncTriggerin TEntity where TEntity : class { Task AfterCommitAsync(ITriggerContextTEntity context, CancellationToken cancellationToken); }触发器通过ITriggerContextT拿到本次变更的实体、变更类型Added / Modified / Deleted等上下文信息接口定义见 ITriggerContext.cs。 建议一律使用异步版本避免同步阻塞引发的死锁问题。三、三步启用事务触发器安装、注册、手动管理事务第 1 步安装 NuGet 包dotnet add package EntityFrameworkCore.Triggered.Transactions第 2 步在 DbContext 配置中启用并注册触发器services.AddDbContextApplicationDbContext(options { options.UseTriggers(triggerOptions { triggerOptions .UseTransactionTriggers() // 启用事务触发器 .AddTriggerNotifyAfterCommitTrigger() .AddTriggerCleanupCacheOnRollbackTrigger(); }); });UseTransactionTriggers()的实现在 TriggersContextOptionsBuilderExtensions.cs它一次性把 8 个触发器类型外加生命周期接口注册进触发器系统。若你通过 DI 容器注册触发器这一步可以省略。第 3 步手动开启事务 创建触发器会话使用事务触发器的关键需要显式开启事务并手动控制触发顺序因此不能依赖库的自动会话管理而要自己创建触发器会话using var tx context.Database.BeginTransaction(); var triggerService context.GetServiceITriggerService(); var triggerSession triggerService.CreateSession(context); // 会话只跟踪自己发现的变更 try { await context.SaveChangesAsync(); await triggerSession.RaiseBeforeCommitAsyncTriggers(); await tx.CommitAsync(); await triggerSession.RaiseAfterCommitAsyncTriggers(); } catch { await triggerSession.RaiseBeforeRollbackAsyncTriggers(); await tx.RollbackAsync(); await triggerSession.RaiseAfterRollbackAsyncTriggers(); throw; }执行顺序一目了然SaveChangesAsync→ 数据写入事务尚未提交RaiseBeforeCommitAsyncTriggers→ 提交前最后检查CommitAsync→ 事务真正提交数据落库RaiseAfterCommitAsyncTriggers→ 只在数据确定入库后执行副作用出异常时走回滚分支依次执行两个回滚触发器后重新抛出。所有Raise*扩展方法的实现在 TriggeredSessionExtensions.cs。四、一个贴近实战的例子订单提交后才发短信// 只在订单真正提交入库后才发送短信 class OrderNotificationTrigger : IAfterCommitAsyncTriggerOrder { readonly ISmsService _sms; public OrderNotificationTrigger(ISmsService sms) _sms sms; public async Task AfterCommitAsync(ITriggerContextOrder context, CancellationToken ct) { if (context.ChangeType ChangeType.Added) { await _sms.SendOrderConfirmation(context.Entity, ct); } } } // 事务回滚后把写进缓存的订单草稿清掉 class OrderCacheCleanupTrigger : IAfterRollbackAsyncTriggerOrder { readonly ICacheService _cache; public OrderCacheCleanupTrigger(ICacheService cache) _cache cache; public Task AfterRollbackAsync(ITriggerContextOrder context, CancellationToken ct) { _cache.Remove($order:{context.Entity.Id}); return Task.CompletedTask; } }注意触发器只会针对本次会话内发现过的实体触发同一个 Order 不会被重复通知相关行为在 TriggeredSessionExtensionsTests.cs 中有完整单元测试验证。五、生命周期触发器一次提交只跑一次的汇总钩子如果逻辑与单个实体无关而是想在所有 BeforeCommit 触发器执行前/后统一做一件事比如批量统计可以使用Lifecycles命名空间下的 4 个生命周期接口位于 Transactions.Abstractions/Lifecycles/接口触发时机IBeforeCommitStartingTrigger/Async所有 BeforeCommit 触发器执行之前整个会话仅 1 次IBeforeCommitCompletedTrigger/Async所有 BeforeCommit 触发器执行之后仅 1 次IAfterCommitStartingTrigger/Async所有 AfterCommit 触发器执行之前仅 1 次IAfterCommitCompletedTrigger/Async所有 AfterCommit 触发器执行之后仅 1 次它们不接收实体上下文适合做汇总统计、批量上报等一次性工作例如统计本次提交共处理了多少条实体变更避免为每个实体重复执行相同逻辑。六、常见问题 FAQQ1为什么不能像普通触发器那样全自动事务触发器的时机依赖你显式开启的事务边界库无法猜测你在哪一行Commit所以必须手动调用BeginTransaction并在提交/回滚前后手动触发。这也是官方说明中想手动控制 TriggerSession 时无法继承 TriggeredDbContext的原因。Q2AfterCommit 里再调用 SaveChanges 会怎样那是一次全新的独立保存新事务不会再触发当前会话的 BeforeCommit/AfterCommit。注意别把必须随原事务提交的数据放进 AfterCommit 中写入。Q3事务触发器会级联吗不会。实现上统一采用非级联发现策略NonCascadingTriggerContextDiscoveryStrategy见 TriggeredSessionExtensions.cs保证事务边界处的触发逻辑简单、可预测。Q4支持哪些版本当前稳定线 V3 面向 EF Core 6.NET 6V2 面向 EF Core 3.1构建说明见 CLAUDE.md。七、源码快速导航想了解什么去哪里看8 个触发器接口的定义src/EntityFrameworkCore.Triggered.Transactions.Abstractions/生命周期接口src/EntityFrameworkCore.Triggered.Transactions.Abstractions/Lifecycles/Raise* 扩展方法实现TriggeredSessionExtensions.csUseTransactionTriggers 注册逻辑TriggersContextOptionsBuilderExtensions.cs触发器行为单元测试TriggeredSessionExtensionsTests.cs基础触发器Before/AfterSave用法README.md掌握以上内容你就能够在 EntityFrameworkCore.Triggered 的基础上精确控制数据落库那一刻的业务逻辑让通知、事件与缓存永远和数据库事务保持一致。✅【免费下载链接】EntityFrameworkCore.TriggeredTriggers for EFCore. Respond to changes in your DbContext before and after they are committed to the database.项目地址: https://gitcode.com/gh_mirrors/en/EntityFrameworkCore.Triggered创作声明：本文部分内容由AI辅助生成（AIGC），仅供参考