StructureMap връща изхвърлен обект на сесия nHibenrate от локален обхват на нишка

Преразглеждах какво направих, за да накарам StructureMap да работи с UoW за Http и UoW за кварцова работа и реших да споделя решението си тук.

Така че идеята беше, че исках да използвам хибридния обхват на StructureMap, за да получа екземпляр на UoW, когато има http контекст, и също така да получа различен екземпляр на UoW за нишка, когато няма http контекст (например, когато се задейства кварцова работа). Като този:

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

UoW за http работи добре. Проблемът беше UoW на нишка.

Ето какво става. Когато задание на Quratz се задейства, то изтегля нишка от пула с нишки и започва да изпълнява задачата, използвайки тази нишка. Когато работата започне, изисквам UoW. StructureMap търси в локалното хранилище за тази нишка, за да върне UoW, но тъй като не може да намери такова, създава такъв и го записва в локалното хранилище на нишката. Получавам UoW, след това изпълнявам Begin, Commit, Dispose и всичко е наред.

Проблемът възниква, когато нишка е изтеглена от пул от нишки, който е бил използван преди за стартиране на задание (и е използвал UoW). Тук, когато поискате UoW, StructureMap търси в кеша (локално хранилище на нишка) и намира UoW и ви го връща. Но проблемът е, че UoW е изхвърлен!

Така че не можем наистина да използваме UoW на нишка за кварцови задания, защото самите нишки не са изхвърлени и те държат старите кеширани изхвърлени UoW. По принцип жизненият цикъл на нишка не съвпада с жизнения цикъл на кварцова работа. Ето защо създадох свой собствен жизнен цикъл за кварцова работа.

Първо създадох свой собствен 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 за Quartz, който да съдържа свързаната с контекста информация. Така че създадох клас QuartzContext. Когато се стартира кварцово задание, JobExecutionContext за това задание трябва да се регистрира в QuartzContext. Тогава действителният кеш (MainObjectCache) за екземпляри на StructureMap ще бъде създаден под този конкретен JobExecutionContext. Така че по този начин, след като изпълнението на заданието приключи, кешът също ще изчезне и няма да имаме проблем с изхвърлянето на UoW в кеша.

Освен това, тъй като _jobExecutionContext е ThreadStatic, когато поискаме кеша от QuartzContext, той ще върне кеша от JobExecutionContext, който е запазен за същата нишка. Така че, когато няколко задания се изпълняват едновременно, техните JobExecutionContexts се записват отделно и ние ще имаме отделни кешове за всяко изпълнявано задание.

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, за да разбера идеята.)

Моля, споделете своите идеи, коментари и предложения: >

Защо не създадете нова сесия за кварцовите задачи? Една работна единица обикновено е транзакционна операция в db. Не мога да си представя, че кварцовите задачи са транзакционно свързани с уеб заявката/отговорите. Създаването на нови сесии не е скъпо. Възможно ли е това?