NHibernate处理并发请求：Delete与SaveOrUpdate冲突问题求解

核心原因 #

这个异常是NHibernate乐观锁机制的触发结果：当你的Session加载某条记录后，该记录被其他事务删除或修改，当前Session尝试SaveOrUpdate时，NHibernate检测到对象状态与数据库不一致，就会抛出该异常。

具体解决方案 #

1. 提前检查记录的最新状态 #

在执行SaveOrUpdate前，直接从数据库重新获取记录的最新状态，判断是否存在：

// 假设你的缓存实体是CacheEntity，主键为Id
var targetEntity = session.Get<CacheEntity>(entityToUpdate.Id);

if (targetEntity == null)
{
    // 记录已被其他事务删除，跳过更新或执行降级逻辑
    return;
}

// 确认存在后，再执行更新操作
session.SaveOrUpdate(entityToUpdate);

注意：这种方式无法完全避免极短时间内的并发删除（Get之后到SaveOrUpdate之间记录被删），但能覆盖绝大多数常规场景。

2. 利用NHibernate的乐观锁机制（推荐） #

给缓存表添加版本控制字段（如Version整数列或LastModified时间戳列），通过NHibernate的乐观锁自动检测并发冲突：

• 实体类添加版本属性：

public class CacheEntity
{
    public virtual int Id { get; set; }
    public virtual string Data { get; set; }
    public virtual DateTime UpdatedDate { get; set; }
    // 乐观锁版本字段
    public virtual int Version { get; set; }
}

• 映射配置（以Fluent NHibernate为例）：

public class CacheEntityMap : ClassMap<CacheEntity>
{
    public CacheEntityMap()
    {
        Id(x => x.Id);
        Map(x => x.Data);
        Map(x => x.UpdatedDate);
        // 配置乐观锁版本
        Version(x => x.Version).Column("Version");
    }
}

• 捕获异常并处理：

using var transaction = session.BeginTransaction();
try
{
    session.SaveOrUpdate(entityToUpdate);
    transaction.Commit();
}
catch (StaleObjectStateException ex)
{
    transaction.Rollback();
    // 异常处理：重新查询记录是否存在，若不存在则提示用户；若存在可考虑重试更新
    var latestEntity = session.Get<CacheEntity>(entityToUpdate.Id);
    if (latestEntity == null)
    {
        // 记录已被删除，返回对应提示
    }
    else
    {
        // 记录被其他事务修改，可合并数据后重试或返回冲突提示
    }
}

3. 批量删除绕过Session缓存 #

针对你提到的两种删除场景，直接用HQL/SQL执行批量操作，避免将对象加载到Session引发缓存不一致：

• 按UpdatedDate保留最新行、删除旧行：

// 假设要保留UpdatedDate >= latestDate的记录，删除更早的
var deleteQuery = session.CreateQuery(@"
    delete from CacheEntity c 
    where c.UpdatedDate < :latestDate 
    and c.GroupId = :groupId") // 假设按分组处理，根据实际调整
    .SetParameter("latestDate", latestValidDate)
    .SetParameter("groupId", targetGroupId);

deleteQuery.ExecuteUpdate();

• 后台服务标记删除：
  如果是先标记再删除，直接用HQL更新标记，再批量删除标记的记录，同样绕过Session缓存。

4. 刷新Session缓存验证对象存在性 #

在SaveOrUpdate前调用Refresh方法，强制从数据库同步对象状态，若对象已被删除会抛出ObjectNotFoundException：

try
{
    // 刷新对象，同步最新数据库状态
    session.Refresh(entityToUpdate);
}
catch (ObjectNotFoundException ex)
{
    // 记录已被删除，执行对应处理逻辑
    return;
}

// 刷新成功后执行更新
session.SaveOrUpdate(entityToUpdate);

5. 调整事务隔离级别 #

针对删除操作的事务，使用REPEATABLE READ隔离级别，避免在删除过程中其他事务修改记录：

using var transaction = session.BeginTransaction(IsolationLevel.RepeatableRead);
try
{
    // 执行删除逻辑
    transaction.Commit();
}
catch (Exception ex)
{
    transaction.Rollback();
    // 异常处理
}

注意：更高的隔离级别会增加锁竞争，需根据系统并发压力权衡使用。

总结 #

• 批量删除场景优先使用HQL/SQL直接操作数据库，避免Session缓存干扰；
• 单条记录更新场景，结合乐观锁机制+异常捕获，能有效处理并发删除/修改；
• 提前检查或刷新对象状态，可在多数情况下避免异常触发。

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