在 NHibernate 中为长时间运行的任务确定事务和会话的范围

Question

在 Web 应用程序中使用 NHibernate 时，我通常会让 IoC 容器负责打开和关闭每个请求的 ISession 并提交/回滚事务。 HTTP 的本质使得在此类应用程序中定义清晰的工作单元变得非常容易。

现在，我的任务是编写一个小程序，任务调度程序将定期调用该程序来发送新闻通讯。时事通讯和订阅者的概念在我们的域模型中已经是明确定义的实体，向所有订阅者发送时事通讯将涉及执行与此类似的操作：

var subscribers = _session
    .QueryOver<Subscription>()
    .Where(s => !s.HasReceivedNewsletter)
    .List();

foreach (var subscriber in subscribers)
{
    SendNewsletterTo(subscriber);
    subscriber.HasReceivedNewsletter = true;
}

注意每个 Subscriber 对象如何在循环内更新，记录她现已收到时事通讯。这个想法是，如果邮件发送程序崩溃，它可以重新启动并从中断的地方继续发送新闻通讯。

我面临的问题是定义和实现工作单元模式。我可能需要在循环的每次迭代结束时提交对数据库的更改。简单地用 using (var trans = _session.BeginTransaction()) 块包装循环体似乎在运行时间上非常昂贵，而且我似乎还遇到了这个长时间运行的进程与其他进程之间的锁定问题使用相同数据库的（网络）应用程序。

在阅读了一些有关 NHibernate 事务的文章和文档后，我开始思考，我可能需要将订阅者列表与会话分离以避免锁定问题，并将每个订阅者重新附加到循环体中的新会话。不过，我不确定这对性能有何影响。

那么，NHibernate 专家，您将如何设计和实现这样的长时间运行的作业呢？

Answer 1

您不想在这里使用异步持久消息传递吗？类似 NServiceBus、Rhino Service Bus 或 MassTransit。看来您不必尽快发送大量消息，所以我认为您应该以每个用户 1 条持久消息的方式异步执行此操作

Answer 2

您不认为没有事务的无状态会话在这里会做得更好吗？

Answer 3

在一个会话中进行多个事务是没有问题的。这里将事务范围限制为更新单个订阅者是合适的，因为它是一个独立的操作。根据订阅者的数量和失败的可能性，最好一次获取少量订阅者。

foreach (var subscriber in subscribers)
{
    using (var txn = _session.BeginTransaction())
    {
        try
        {
            SendNewsletterTo(subscriber);
            subscriber.HasReceivedNewsletter = true;
            txn.Commit();
        }
        catch (Exception ex)
        {
            txn.Rollback();
            // log exception, clean up any actions SendNewsletterTo has taken if needed
            // Dispose of session and start over
        }   
    }
}