NHibernate OnPost事件提交前执行，如何同步Customer至NoSQL副本表？

没问题，要实现Customer数据到NoSQL副本的可靠同步，结合你现有的NHibernate代码，咱们可以利用NHibernate的事件监听机制来搞定，核心是要保证SQL和NoSQL的操作要么都成功，要么都失败，避免数据不一致。下面一步步来：

首先得写一个实现IPostUpdateEventListener的监听器，专门处理Customer更新后的同步逻辑。这里要注意：默认的PostUpdate事件是在Session Flush（也就是SQL执行到数据库）之后、事务提交之前触发的，正好符合你“事务提交前运行”的需求。

public class CustomerPostUpdateListener : IPostUpdateEventListener
{
    private readonly INoSqlRepository _noSqlRepository; // 替换成你实际的NoSQL操作仓储

    public CustomerPostUpdateListener(INoSqlRepository noSqlRepository)
    {
        _noSqlRepository = noSqlRepository;
    }

    public void OnPostUpdate(PostUpdateEvent @event)
    {
        // 只处理Customer实体
        if (@event.Entity is Customer customer)
        {
            try
            {
                // 把更新后的Customer数据同步到NoSQL
                var noSqlCustomer = new NoSqlCustomer
                {
                    Id = customer.Id,
                    Property1 = customer.Property1,
                    Property2 = customer.Property2
                    // 按需添加其他需要同步的属性
                };

                // 用Upsert（更新或插入）保证幂等性，避免重复操作出问题
                _noSqlRepository.Upsert(noSqlCustomer);
            }
            catch (Exception ex)
            {
                // 关键：如果NoSQL同步失败，一定要抛出异常
                // 这样NHibernate会回滚SQL事务，确保两边数据一致
                throw new InvalidOperationException("同步Customer到NoSQL失败，已触发SQL事务回滚", ex);
            }
        }
    }

    // 实现异步事件方法（NHibernate新版本要求）
    public Task OnPostUpdateAsync(PostUpdateEvent @event, CancellationToken cancellationToken)
    {
        OnPostUpdate(@event);
        return Task.CompletedTask;
    }
}

接下来要把这个监听器配置到SessionFactory里，让NHibernate能触发它。这里以Fluent NHibernate为例，代码注册更灵活：

// 假设你已经有了NoSQL仓储的实例
var noSqlRepository = new NoSqlRepository();

var sessionFactory = Fluently.Configure()
    .Database(/* 你的SQL数据库配置，比如MsSqlConfiguration.MsSql2012.ConnectionString("...") */)
    .Mappings(m => m.FluentMappings.AddFromAssemblyOf<Customer>())
    .ExposeConfiguration(cfg =>
    {
        // 获取事件监听器注册表
        var listenerRegistry = cfg.EventListeners;
        // 把自定义监听器添加到PostUpdate事件列表中
        var existingListeners = listenerRegistry.PostUpdateEventListeners;
        var newListeners = new IPostUpdateEventListener[existingListeners.Length + 1];
        Array.Copy(existingListeners, newListeners, existingListeners.Length);
        newListeners[existingListeners.Length] = new CustomerPostUpdateListener(noSqlRepository);
        listenerRegistry.PostUpdateEventListeners = newListeners;
    })
    .BuildSessionFactory();

如果你用的是XML配置（hibernate.cfg.xml），也可以在配置文件里添加监听器的全类名，不过代码注册的方式更适合依赖注入的场景。

• 异常一定要抛出来：如果NoSQL同步失败，必须抛出异常，这样NHibernate的tx.Commit()会自动回滚SQL事务，绝对不能吞掉异常，否则会出现SQL更新成功但NoSQL同步失败的不一致情况。
• NoSQL操作要幂等：用Upsert（更新或插入）而不是单纯的Update，这样就算因为重试（比如网络波动）触发多次同步，也不会导致数据异常。
• 避免异步操作“脱钩”：如果你的NoSQL操作是异步的，一定要在OnPostUpdateAsync里等待异步操作完成，不能直接返回任务就不管了，否则SQL事务可能在NoSQL操作完成前就提交了，破坏一致性。
• 测试边界场景：比如模拟NoSQL服务不可用、网络超时的情况，验证SQL事务是否会正确回滚。

你原来的NHibernate代码完全可以继续用，因为事件监听器会自动触发：

using (var session = SessionFactory.OpenSession())
{
    using (var tx = session.BeginTransaction())
    {
        var customer = session.Get<Customer>(id);
        customer.Property1 = "new value";
        customer.Property2 = "new value";
        // NHibernate默认会在Commit前自动Flush，这时候PostUpdate事件就会触发
        tx.Commit();
    }
}

当你调用tx.Commit()时，NHibernate会先Flush Session（执行SQL更新），然后触发PostUpdate事件，执行NoSQL同步逻辑。如果同步失败，抛出的异常会让tx.Commit()终止并回滚SQL事务，完美保证两边数据一致。

内容的提问来源于stack exchange，提问作者w0051977