blocks|key|1813626|text|这段代码进行重构的时机已经成熟。|type|unstyled|depth|inlineStyleRanges|entityRanges|data|1813627|将调度器放在IHostedService中，让它来处理调度器的启动。|offset|length|style|CODE|1813628|public+interface+IHostedService+{
++++//
++++//+Summary:
++++//+++++Triggered+when+the+application+host+is+ready+to+start+the+service.
++++Task+StartAsync(CancellationToken+cancellationToken);
++++//
++++//+Summary:
++++//+++++Triggered+when+the+application+host+is+performing+a+graceful+shutdown.
++++Task+StopAsync(CancellationToken+cancellationToken);
}

public+class+SchedulerService+:+IHostedService+{
++++readonly+IJobFactory+jobFactory;
++++readonly+ISchedulerFactory+schedulerFactory
++++IScheduler++scheduler;

++++public+SchedulerService(IJobFactory+jobFactory,+ISchedulerFactory+schedulerFactory)+{
++++++++this.jobFactory+=+jobFactory;
++++++++this.schedulerFactory+=+schedulerFactory;
++++}

++++public+async+Task+StartAsync(CancellationToken+cancellationToken)+{
++++++++scheduler+=+await+schedulerFactory.GetScheduler();
++++++++scheduler.JobFactory+=+jobFactory;

++++++++IJobDetail+job+=+JobBuilder.Create<Job1>()
++++++++++++.WithIdentity("job1")
++++++++++++.Build();

++++++++ITrigger++trigger+=+TriggerBuilder.Create()
++++++++++++.WithIdentity("trigger1")
++++++++++++.StartNow()
++++++++++++.WithSimpleSchedule(x+=>+x.WithIntervalInSeconds(1)
++++++++++++++++.RepeatForever())
++++++++++++.Build();

++++++++await+scheduler.ScheduleJob(job,+trigger);

++++++++await+scheduler.Start(cancellationToken);
++++}

++++public+Task+StopAsync(CancellationToken+cancellationToken)+{
++++++++return+scheduler.Shutdown(cancellationToken);
++++}
}|code-block|syntax|javascript|1813629|现在，通过将所有类型添加到服务集合中，可以在启动时干净地完成配置|1813630|class+Program+{
++++static+async+Task+Main(string[]+args)+{

++++++++var+services+=+new+ServiceCollection();

++++++++//...

++++++++services.AddHttpClient<IDependency,+Dependency>();
++++++++services.AddScoped<Job1>();
++++++++services.AddTransient<ISchedulerFactory,+StdSchedulerFactory>();
++++++++services.AddTransient<IJobFactory>(serviceProvider+=>+new+JobFactory(serviceProvider));+
++++++++services.AddTransient<IHostedService,+SchedulerService>();

++++++++//...

++++++++IServiceProvider+serviceProvider+=+services.BuildServiceProvider();

++++++++var+service+=+serviceProvider.GetRequiredService<IHostedService>();+
++++++++await+service.StartAsync();

++++++++Console.ReadKey();

++++}
}|1813631|因此，现在服务将管理启动，并根据需要注入所有必要的依赖项。|1813632|包括类型化的客户端Dependency类，假设如下|1813633|public+class+Dependency+:+IDependency+{

++++public+Dependency(HttpClient+httpClient)+{
++++++//+<snipped>
++++}
}

public+class+Job1:+IJob+{
++++public+Job1(IDependency+dependency)+{
++++++//+<snipped>
++++}
}|1813634|entityMap^0|0|6|E|0|0|0|0|0|9|A|0|0^^$0|@$1|2|3|4|5|6|7|Y|8|@]|9|@]|A|$]]|$1|B|3|C|5|6|7|Z|8|@$D|10|E|11|F|G]]|9|@]|A|$]]|$1|H|3|I|5|J|7|12|8|@]|9|@]|A|$K|L]]|$1|M|3|N|5|6|7|13|8|@]|9|@]|A|$]]|$1|O|3|P|5|J|7|14|8|@]|9|@]|A|$K|L]]|$1|Q|3|R|5|6|7|15|8|@]|9|@]|A|$]]|$1|S|3|T|5|6|7|16|8|@$D|17|E|18|F|G]]|9|@]|A|$]]|$1|U|3|V|5|J|7|19|8|@]|9|@]|A|$K|L]]|$1|W|3|-4|5|6|7|1A|8|@]|9|@]|A|$]]]|X|$]]

This code is ripe for a refactoring.

Put the scheduler in a <code>IHostedService</code> and let that handle the start of the scheduler.

<pre><code>public interface IHostedService {
 //
 // Summary:
 // Triggered when the application host is ready to start the service.
 Task StartAsync(CancellationToken cancellationToken);
 //
 // Summary:
 // Triggered when the application host is performing a graceful shutdown.
 Task StopAsync(CancellationToken cancellationToken);
}

public class SchedulerService : IHostedService {
 readonly IJobFactory jobFactory;
 readonly ISchedulerFactory schedulerFactory
 IScheduler scheduler;

 public SchedulerService(IJobFactory jobFactory, ISchedulerFactory schedulerFactory) {
 this.jobFactory = jobFactory;
 this.schedulerFactory = schedulerFactory;
 }

 public async Task StartAsync(CancellationToken cancellationToken) {
 scheduler = await schedulerFactory.GetScheduler();
 scheduler.JobFactory = jobFactory;

 IJobDetail job = JobBuilder.Create&lt;Job1&gt;()
 .WithIdentity("job1")
 .Build();

 ITrigger trigger = TriggerBuilder.Create()
 .WithIdentity("trigger1")
 .StartNow()
 .WithSimpleSchedule(x =&gt; x.WithIntervalInSeconds(1)
 .RepeatForever())
 .Build();

 await scheduler.ScheduleJob(job, trigger);

 await scheduler.Start(cancellationToken);
 }

 public Task StopAsync(CancellationToken cancellationToken) {
 return scheduler.Shutdown(cancellationToken);
 }
}
</code></pre>

With that out of the way, now the configuration can be done cleanly at startup by adding all the types to the service collection

<pre><code>class Program {
 static async Task Main(string[] args) {

 var services = new ServiceCollection();

 //...

 services.AddHttpClient&lt;IDependency, Dependency&gt;();
 services.AddScoped&lt;Job1&gt;();
 services.AddTransient&lt;ISchedulerFactory, StdSchedulerFactory&gt;();
 services.AddTransient&lt;IJobFactory&gt;(serviceProvider =&gt; new JobFactory(serviceProvider)); 
 services.AddTransient&lt;IHostedService, SchedulerService&gt;();

 //...

 IServiceProvider serviceProvider = services.BuildServiceProvider();

 var service = serviceProvider.GetRequiredService&lt;IHostedService&gt;(); 
 await service.StartAsync();

 Console.ReadKey();

 }
}
</code></pre>

So now the service will manage the startup and also all necessary dependencies will get injected as needed.

Including your Typed Client <code>Dependency</code> class
assuming the following

<pre><code>public class Dependency : IDependency {

 public Dependency(HttpClient httpClient) {
 // &lt;snipped&gt;
 }
}

public class Job1: IJob {
 public Job1(IDependency dependency) {
 // &lt;snipped&gt;
 }
}
</code></pre>

I have a <code>JobFactory : IJobFactory</code> that works. I can create scheduled jobs just fine, and inject simple dependencies with no problem, but I do have a problem with one issue. One of the dependencies itself depends on <code>HttpClient</code>, but that doesn't seem to work.

E.g.

<pre><code>services.AddHttpClient&lt;Dependency&gt;("dependency");
services.AddSingleton(typeof(Dependency));

using (var serviceProvider = services.BuildServiceProvider())
{
 var schedulerFactory = new StdSchedulerFactory();
 var scheduler = await schedulerFactory.GetScheduler();
 scheduler.JobFactory = new JobFactory(serviceProvider);
 await scheduler.Start();

 var job = JobBuilder.Create&lt;Job1&gt;()
 .WithIdentity("job1")
 .Build();
 var trigger = TriggerBuilder.Create()
 .WithIdentity("trigger1")
 .StartNow()
 .WithSimpleSchedule(x =&gt; x
 .WithIntervalInSeconds(1)
 .RepeatForever())
 .Build();
 await scheduler.ScheduleJob(job, trigger);
}
</code></pre>

with dependency constructor being

<pre><code>public Dependency(HttpClient httpClient)
{
 // &lt;snipped&gt;
}
</code></pre>

and job constructor being

<pre><code>public Job1(Dependency dependency)
{
 // &lt;snipped&gt;
}
</code></pre>

When I try to run this, I'm told the job is throwing an unhandled exception. Debugging through my JobFactory tells me that httpClient isn't getting injected at all. Shouldn't .AddHttpClient be handling this? Does it not work because of the multiple levels of DI? Is it possible to do another way?

Note, I attempted to also manually register <code>Job1</code> like I did <code>Dependency</code>, but that didn't solve the problem.

Quartz.Net Job with multiple levels of DI

我有一个可以工作的JobFactory : IJobFactory。其中一个依赖项本身依赖于HttpClient，但这似乎不起作用。例如。services.AddHttpClient<Dependency>("dependency");services.AddSingleton(typeof(Dependency));...

问具有多级DI的Quartz.Net作业
EN

社区

活动

资源

关于

腾讯云开发者

热门产品

热门推荐

更多推荐

问具有多级DI的Quartz.Net作业EN

社区

活动

资源

关于

腾讯云开发者

热门产品

热门推荐

更多推荐

问具有多级DI的Quartz.Net作业
EN