NHibernate 数据在多线程应用程序中不同步

Question

我在多线程场景中使用 NHibernate。这是一个执行以下操作的测试。

1. （启动多线程服务器。）
2. 向服务器发送请求。服务器创建一个状态为A 的新Foo 对象，并使用NHibernate 将其存储在数据库中。
3. 为新创建的Foo 对象设置状态B。
4. 向服务器发送请求。服务器使用 NHibernate 从 DB 获取 Foo，读取其状态（应为 B）并采取相应措施。
5. （停止服务器。）

现在我的问题是，在第 4 步中偶尔（在 1 - 2% 的情况下）服务器会读取状态 A，而它应该读取 B 并且测试失败。 我在这里做错了什么？

NHibernate 会话通过设置为 thread static 的CurrentSessionContext 检索。我使用 Fluent NHibernate，但我想这并不重要。

编辑

关于服务器的详细信息： 服务器是一个简单的 TCP 服务器。启动时，它会创建一个新的 thread task 来等待传入的连接。当一个新连接被接受时，它会创建另一个 thread task 来处理来自连接的请求并发送响应。处理thread task 终止。

服务器使用Task.Factory.StartNew() 创建新的线程 任务。

编辑 2

我编写了一个小型 NUnit 测试来重现此行为。它失败了

预期：打开但被：初始化

在第一次迭代中。

[Test]
[Explicit]
public void NHibernateProblem()
{
    for (var i = 0; i < 100; i++)
    {
        var identifier = Guid.NewGuid().ToString();
        var session1 = Database.GetCurrentSession();
        using (var dbTransaction = session1.BeginTransaction())
        {
            var transaction1 = new Transaction
            {
                Identifier = identifier,
                Status = TransactionStatus.Initialized
            };

            session1.SaveOrUpdate(transaction1);
            dbTransaction.Commit();
        }

        Task.Factory.StartNew(() =>
        {
            var session2 = Database.GetCurrentSession();
            using (var dbTransaction = session2.BeginTransaction())
            {
                var transaction2 = session2
                    .QueryOver<Transaction>()
                    .Where(t => t.Identifier == identifier)
                    .SingleOrDefault();

                transaction2.Status = TransactionStatus.Open;

                session2.SaveOrUpdate(transaction2);
                dbTransaction.Commit();
            }
        }).Wait();

        var session3 = Database.GetCurrentSession();
        using (var dbTransaction = session3.BeginTransaction())
        {
            var transaction3 = session3
                .QueryOver<Transaction>()
                .Where(t => t.Identifier == identifier)
                .SingleOrDefault();

            dbTransaction.Commit();
            Console.WriteLine("iteration {0}", i);

            Assert.That(transaction3.Status, Is.EqualTo(TransactionStatus.Open));
        }
    }
}

Database.GetCurrentSession() 看起来像这样：

public virtual ISession GetCurrentSession()
{
    if (CurrentSessionContext.HasBind(SessionFactory))
    {
        var currentSession = SessionFactory.GetCurrentSession();
        return currentSession;
    }

    var session = SessionFactory.OpenSession();
    session.FlushMode = FlushMode.Always;
    session.CacheMode = CacheMode.Ignore;
    CurrentSessionContext.Bind(session);
    return session;
}

我认为映射关系不大。

Answer 1

在所示的单元测试中，session3 将与 session1 相同，因此 transaction3 将与 transaction1 是同一对象实例，因此它仍将显示添加事务对象时的值。

第三部分的查询将命中数据库，但 NHibernate 会看到获取的对象已经加载并返回会话已经在内存中保存的实例。它通常不会覆盖对象中的值。

Answer 2

在服务器中，一般做法是为每个请求创建一个会话，并在请求开始时启动事务。当请求即将完成时，事务要么提交，要么回滚，具体取决于结果。

在您的测试中，它实际上并没有模拟这种场景，它对请求 1 和请求 3 使用相同的会话，而在实际场景中永远不会出现这种情况。

因此，为了测试实际场景，您可以为会话 3 创建一个新会话。