При изучении проблемы я понял, что простое удаление ILog
из ядра перед разрешением планировщика, похоже, работает.Что касается причины, по которой я был немного неуверен.
Однако я заметил, что используемая версия Quartz имеет асинхронный API, поэтому пришлось внести некоторые изменения во время моего исследования проблемы.
В комментариях к документации по ссылкам было предложено изменить рефакторинг к новому синтаксису API асинхронизации
kernel.Bind<Task<IScheduler>>().ToMethod(async _ => {
ISchedulerFactory schedulerFactory = new StdSchedulerFactory();
var sched = await schedulerFactory.GetScheduler();
sched.JobFactory = new NinjectJobFactory(kernel);
return sched;
});
Я улучшил это, создав службу, которая рассказывает о преимуществах асинхронного API при запуске планировщика.
public interface IService {
Task Start();
}
public class Service : IService {
private readonly IJobFactory jobFactory;
private readonly ILog log;
private readonly ISchedulerFactory schedulerFactory;
public Service(IJobFactory jobFactory, ISchedulerFactory schedulerFactory, ILog log) {
this.jobFactory = jobFactory;
this.schedulerFactory = schedulerFactory;
this.log = log;
}
public async Task Start() {
IScheduler scheduler = await schedulerFactory.GetScheduler();
scheduler.JobFactory = jobFactory;
IJobDetail job = JobBuilder.Create()
.OfType<SimpleJob>()
.Build();
ITrigger trigger = TriggerBuilder.Create()
.WithIdentity("trigger1", "group1")
.StartNow()
.WithSimpleSchedule(x => x.WithIntervalInSeconds(3)
.RepeatForever())
.Build();
await scheduler.ScheduleJob(job, trigger);
await scheduler.Start();
log.Debug("Scheduler started");
}
}
Я создал загрузчик и использовал NinjectModule
s для правильной организации инъекций зависимостей
public class Bootstrapper {
public IKernel Init() {
var kernel = new StandardKernel();
kernel.Load(Assembly.GetExecutingAssembly());
kernel.Bind<IServiceProvider>().ToConstant(kernel);
return kernel;
}
}
public class LoggingModule : NinjectModule {
public override void Load() {
Bind<ILog>()
.ToMethod(x => LogManager.GetLogger(
x.Request.Target != null ? x.Request.Target.Member.DeclaringType : x.Request.Service)
);
}
}
public class QuartzModule : NinjectModule {
public override void Load() {
Bind<IJobFactory>().To<NinjectJobFactory>();
Bind<ISchedulerFactory>().To<StdSchedulerFactory>();
Bind<IService>().To<Service>();
}
}
class NinjectJobFactory : IJobFactory {
readonly IServiceProvider provider;
public NinjectJobFactory(IServiceProvider provider) {
this.provider = provider;
}
public IJob NewJob(TriggerFiredBundle bundle, IScheduler scheduler) {
IJobDetail jobDetail = bundle.JobDetail;
Type jobType = jobDetail.JobType;
try {
// this will inject any dependencies that the job requires
var value = (IJob)provider.GetService(jobType);
return value;
} catch (Exception e) {
throw new SchedulerException(string.Format("Problem while instantiating job '{0}' from the NinjectJobFactory.", bundle.JobDetail.Key), e);
}
}
/// <summary>
/// Allows the job factory to destroy/cleanup the job if needed.
/// No-op when using SimpleJobFactory.
/// </summary>
public void ReturnJob(IJob job) {
var disposable = job as IDisposable;
disposable?.Dispose();
}
}
С этим изменением и соответствующим образом обновляю основную программу
class Program {
static void Main(string[] args) {
Bootstrapper bootstrapper = new Bootstrapper();
var kernel = bootstrapper.Init();
WithQuartz(kernel).GetAwaiter().GetResult();
Console.ReadKey();
}
public static Task WithQuartz(IKernel kernel) {
var service = kernel.Get<IService>();
return service.Start();
}
}
кажется, все работает как ожидалось.