StructureMap 从线程局部范围返回已处置的 nHibenrate 会话对象

Question

[OR] 如何定义 UoW 的 StructureMap 生命周期以供 http 请求和quartz 作业使用

我有一个使用 SM 进行 IoC 的 Web 应用程序。我正在使用 HybridHttpOrThreadLocalScoped 范围来存储我的 nHibernate ISession 对象。对于我的网络请求，这在每个请求的会话中工作正常。

但我也有quartz.net 安排了一些工作。该作业使用相同的工作单元来获取 ISession 对象。在这种情况下，当调度程序启动作业时，一开始一切正常，并且作业运行良好几次，直到作业线程 ID 重复。

想象一下，当作业被调度时，它开始在 ID 为 11、12、13 的线程中运行，然后再次在 ID 为 11 的线程中运行。此时，结构图返回一个已释放的会话对象，我得到“System.ObjectDisposeException：会话已关闭！”错误。

因此，从我所看到的，会话保存在线程本地存储中，并且在工作单元结束时处置会话后，会话对象仍然保存在线程本地存储中。 似乎线程终止后，其本地存储不会被清除，并且当创建具有相同 id 的新线程时，StructureMap 会在旧线程本地存储中查找会话（这应该是我相信已清除新线程）并返回已处理的会话对象。

问题：

1. 有没有办法清除线程本地存储（终止时）？
2. 对于线程范围的对象是否有等效的“ReleaseAndDisposeAllHttpScopedObjects”？
3. 有没有办法使已处理的对象无效（或弹出），这样即使 SM 寻找它也找不到任何对象并且必须创建一个新实例？

我希望我的问题说清楚了。这花了我几个小时的时间，但我仍然没有找到解决方法。 我很感激任何提示：>

更新： 我添加了自己的解决方案，使 StructureMap 提供的 UoW 能够处理 http 请求和quartz 作业。如果您有更好/更容易/更简单的解决方案，请告诉我。

Answer 1

我正在重新审视我为使 StructureMap 与每个 Http 的 UoW 和每个石英作业的 UoW 一起工作所做的工作，我决定在这里分享我的解决方案。

所以我的想法是，我想使用 StructureMap 混合作用域在存在 http 上下文时获取 UoW 的实例，并在没有 http 上下文时（例如当石英作业触发时）为每个线程获取不同的 UoW 实例。像这样：

For<IUnitOfWork>().HybridHttpOrThreadLocalScoped().Use<UnitOfWork>();

UoW for http 工作得很好。问题是每个线程的 UoW。

这是发生的事情。当 quratz 作业触发时，它会从线程池中提取一个线程并开始使用该线程执行作业。当工作开始时，我请求一份 UoW。 StructureMap 在本地存储下查找该线程以返回 UoW，但因为它找不到任何 UoW，所以它实例化了一个并将其保存在线程的本地存储下。我获取了 UoW，然后执行 Begin、Commit、Dispose，一切都很好。

当从之前用于触发作业（并使用了 UoW）的线程池中提取线程时，就会出现问题。在这里，当您请求 UoW 时，StructureMap 会在缓存（线程本地存储）中查找并找到 UoW 并将其返回给您。但问题是UoW被处置了！

因此，我们不能真正将每个线程的 UoW 用于quartz作业，因为线程本身没有被释放，并且它们保存旧的缓存的已释放的UoW。 基本上，线程的生命周期与quartz作业的生命周期不匹配。这就是为什么我为quartz作业创建了自己的生命周期。

首先，我创建了自己的 http-quartz 混合生命周期类：

public class HybridHttpQuartzLifecycle : HttpLifecycleBase<HttpContextLifecycle, QuartzLifecycle>
{
    public override string Scope { get { return "HybridHttpQuartzLifecycle"; } }
}

然后我创建了 QuartzLifecyle 类：

public class QuartzLifecycle : ILifecycle
{

    public void EjectAll()
    {
        FindCache().DisposeAndClear();
    }

    public IObjectCache FindCache()
    {
        return QuartzContext.Cache;
    }

    public string Scope { get { return "QuartzLifecycle"; } }
}

然后我需要创建一些上下文类，例如 HttpContext for Quartz 来保存上下文相关信息。所以我创建了 QuartzContext 类。 当一个quartz作业被触发时，该作业的JobExecutionContext应该在QuartzContext中注册。然后，将在该特定 JobExecutionContext 下创建 StructureMap 实例的实际缓存 (MainObjectCache)。这样，作业执行完成后，缓存也会消失，我们就不会有在缓存中处理 UoW 的问题。

另外，由于 _jobExecutionContext 是 ThreadStatic，当我们从 QuartzContext 请求缓存时，它会返回来自为同一线程保存的 JobExecutionContext 的缓存。因此，当多个作业同时运行时，它们的 JobExecutionContext 是单独保存的，我们将为每个正在运行的作业拥有单独的缓存。

public class QuartzContext
{

    private static readonly string _cacheKey = "STRUCTUREMAP-INSTANCES";

    [ThreadStatic]
    private static JobExecutionContext _jobExecutionContext;

    protected static void Register(JobExecutionContext jobExecutionContext)
    {
        _jobExecutionContext = jobExecutionContext;
        _jobExecutionContext.Put(_cacheKey, new MainObjectCache());
    }

    public static IObjectCache Cache 
    { 
        get 
        {
            return (IObjectCache)_jobExecutionContext.Get(_cacheKey);
        } 
    }
}  

我有一个名为 BaseJobSingleSession 的抽象类，其他作业派生自该抽象类。该类扩展了 QuartzContext 类。您可以看到我在作业被触发时注册了 JobExecutionContext。

abstract class BaseJobSingleSession : QuartzContext, IStatefulJob
{
    public override void Execute(JobExecutionContext context)
    {
        Register(context);
        IUnitOfWork unitOfWork = ObjectFactory.GetInstance<IUnitOfWork>();

        try
        {
            unitOfWork.Begin();

            // do stuff ....

            unitOfWork.Commit();
        }
        catch (Exception exception)
        {
            unitOfWork.RollBack();

        }
        finally
        {
            unitOfWork.Dispose();
        }
    }
}

最后，我定义了 UoW 的生命周期：（

For<IUnitOfWork>().LifecycleIs(new HybridHttpQuartzLifecycle()).Use<UnitOfWork>();

对于生命周期和上下文类，我查看了 StructureMap 源代码以获得想法。）

请分享您的想法、意见和建议：>

Answer 2

为什么不为石英作业创建一个新会话？工作单元通常是数据库上的事务操作。我无法想象石英作业在事务上与网络请求/响应相关。创建新会话并不昂贵。这有可能吗？