Правильно ли я регистрирую ObjectContext с помощью AutoFac?

У меня есть служба Windows, и я хочу убедиться, что мой EF ObjectContext удаляется между каждым его запуском. Служба работает дольше при каждом запуске. Кажется, что ObjectContext продолжает расти.Должен ли мой ObjectContext регистрироваться по-другому, или я что-то делаю не так?

Обзор того, что я делаю.

  • Я использую Quartz.NET для планирования моего обслуживания
  • I ' m с помощью Atlas для настройки и настройки моей службы Windows
  • Я использую Autofac в качестве моего IoC
  • Я использую Entity Framework в качестве модели данных

Walkthru кода:

  • Итак, программа запускается с регистрации службы с помощью Atlas.
  • Atlas зарегистрирует мои регистрации autofac, которые размещены в модуле MyModule
  • MyModule регистрирует ObjectContext в InstancePerLifetimeScope (это правильная область? ), то в нем будет один раз экземпляр моего настраиваемого UnitOfWork как InstancePerLifetimeScope (это правильная область?).
  • MyService размещается в Atlas, который получает планировщик Quartz и свойство AutofacJobListener и планирует выполнение задания (MyJob) каждые 5 минут при запуске службы.
  • MyJob, который получает экземпляр объекта Obje ctContext, введенное в него из AutofacJobListener. Эта работа обращается к базе данных и получает мои вещи.

Когда задание выполняется, оно вызывает и получает мои данные каждый раз, когда оно выполняется, это занимает больше времени (пример: 2 минуты при первом запуске, 4 минуты при втором запуске службы, 6 минут при следующем, 8 при следующем и скоро). Кажется, что мой ObjectContext с каждым разом становится все больше и больше. Данные, которые он извлекает, не изменились, осталось то же количество строк и столбцов. Я думаю, что мои регистрации неправильные, так ли это? Если нет, вы видите проблему с тем, что я делаю?

Программа

static class Program
{
    /// 
    /// The main entry point for the application.
    /// 
    static void Main(string[] args)
    {
        var configuration =
            Host.Configure(c =>
            {
                c.AllowMultipleInstances();
                c.WithRegistrations(b => b.RegisterModule(new MyModule()));
            }, args);
        Host.Start(configuration);
    }
}

Модуль

public class MyModule : Module
{
    protected override void Load(ContainerBuilder builder)
    {
        LoadQuartz(builder);
        LoadServices(builder);

        LoadInfrastructure(builder);
    }

    private void LoadInfrastructure(ContainerBuilder builder)
    {
        builder.Register(c => new ObjectContext())
                .As()
                .InstancePerLifetimeScope();

        builder.Register(c => new UnitOfWork(c.Resolve()))
            .As().As()
            .InstancePerLifetimeScope();
    }

    private void LoadQuartz(ContainerBuilder builder)
    {
        builder.Register(c => new StdSchedulerFactory().GetScheduler()).As().InstancePerLifetimeScope();
        builder.Register(c => new AutofacJobListener(c)).As();
    }

    private void LoadServices(ContainerBuilder builder)
    {
        builder.RegisterType().As().PropertiesAutowired();
    }
}

AutofacJobListener

public class AutofacJobListener : IJobListener
{
    private readonly IComponentContext _container;

    public AutofacJobListener(IComponentContext container)
    {
        _container = container;
    }

    public void JobToBeExecuted(JobExecutionContext context)
    {
        _container.InjectUnsetProperties(context.JobInstance);
    }

    public void JobExecutionVetoed(JobExecutionContext context)
    {
        /*noop*/
    }

    public void JobWasExecuted(JobExecutionContext context, JobExecutionException jobException)
    {
        /*noop*/
    }

    public string Name
    {
        get { return "AutofacInjectionJobListener"; }
    }
}

MyService

public class MyService : IAmAHostedProcess
{
    public IScheduler Scheduler { get; set; }
    public IJobListener AutofacJobListener { get; set; }

    #region Implementation of IAmAHostedProcess

    public void Start()
    {
        var trigger = TriggerUtils.MakeMinutelyTrigger(5);
        trigger.Name = @"Job Trigger";

        Scheduler.ScheduleJob(new JobDetail("Job", null, typeof(MyJob)), trigger);
        Scheduler.AddGlobalJobListener(AutofacJobListener);
        Scheduler.Start();
    }

    public void Stop()
    {
        Scheduler.Shutdown();
    }

    public void Resume()
    {
    }

    public void Pause()
    {
    }

    #endregion
}

Моя работа

public class MyJob : IJob
{
    public IObjectContext ObjectContext { get; set; }

    public void Execute(JobExecutionContext context)
    {
        var myStuff = ObjectContext.GetIQueryable();
    }
}

6
задан Mark 17 June 2011 в 19:45
поделиться