在ASP.NET Core中创建内部使用Scoped服务的Quartz.NET宿主服务

.NET Core 前端之家
前端之家收集整理的这篇文章主要介绍了在ASP.NET Core中创建内部使用Scoped服务的Quartz.NET宿主服务，前端之家小编觉得挺不错的，现在分享给大家，也给大家做个参考。

在我的上一篇文章中，我展示了如何使用ASP.NET Core创建Quartz.NET托管服务并使用它来按计划运行后台任务。不幸的是，由于Quartz.NET API的工作方式，在Quartz作业中使用Scoped依赖项注入服务有些麻烦。说明下这篇文章部分采用机翻。

作者：依乐祝

译文地址：https://www.cnblogs.com/yilezhu/p/12757411.html

原文地址：https://andrewlock.net/using-scoped-services-inside-a-quartz-net-hosted-service-with-asp-net-core/

在这篇文章中，我将展示一种简化工作中使用Scoped服务的方法。您可以使用相同的方法来管理EF Core的工作单元模式和其他面向切面的模型。

这篇文章是上篇文章引申出来的，因此，如果您还没有阅读的话，建议您先阅读上篇文章。

回顾-自定义JobFactory和单例的IJob

在上篇博客的最后，我们有一个实现了IJob接口并向控制台简单输出信息的HelloWorldJob。

public class HelloWorldJob : IJob
{
    private readonly ILogger<HelloWorldJob> _logger;
    public HelloWorldJob(ILogger<HelloWorldJob> logger)
    {
        _logger = logger;
    }
    public Task Execute(IJobExecutionContext context)
    {
        _logger.LogInformation("Hello world!");
        return Task.CompletedTask;
    }
}
@H_502_25@

我们还有一个IJobFactory的实现，以便我们在需要时从DI容器中检索作业的实例：


public class SingletonJobFactory : IJobFactory
{
    private readonly IServiceProvider _serviceProvider;
    public SingletonJobFactory(IServiceProvider serviceProvider)
    {
        _serviceProvider = serviceProvider;
    }
    public IJob NewJob(TriggerFiredBundle bundle,IScheduler scheduler)
    {
        return _serviceProvider.GetrequiredService(bundle.JobDetail.JobType) as IJob;
    }
    public void ReturnJob(IJob job) { }
}
@H_502_25@

这些服务都在Startup.ConfigureServices()中以单例形式注册：


services.AddSingleton<IJobFactory,SingletonJobFactory>();
services.AddSingleton<HelloWorldJob>();
@H_502_25@

对于这个非常基本的示例来说，这很好，但是如果您需要在IJob内部使用一些范围服务呢？例如，也许您需要使用EF Core DbContext遍历所有客户，并向他们发送电子邮件，并更新客户记录。我们假设这个任务为EmailReminderJob。


权宜之计


我在上一篇文章中展示的解决方案是将IServiceProvider注入到您的IJob的文档中，手动创建一个范围，并从中检索必要的服务。例如：


public class EmailReminderJob : IJob
{
    private readonly IServiceProvider _provider;
    public EmailReminderJob( IServiceProvider provider)
    {
        _provider = provider;
    }
    public Task Execute(IJobExecutionContext context)
    {
        using(var scope = _provider.CreateScope())
        {
            var dbContext = scope.ServiceProvider.GetService<AppDbContext>();
            var emailSender = scope.ServiceProvider.GetService<IEmailSender>();
            // fetch customers,send email,update DB
        }
        return Task.CompletedTask;
    }
}
@H_502_25@

在许多情况下，这种方法绝对可以。如果不是将实现直接放在工作内部（如我上面所做的那样），而是使用中介者模式来处理诸如工作单元或消息分发之类的跨领域问题，则尤其如此。


如果不是这种情况，您可能会受益于创建一个可以为您管理这些工作的帮助类。


QuartzJobRunner


要解决这些问题，您可以创建一个IJob的“中间” 实现，这里我们命名为QuartzJobRunner，该实现位于IJobFactory和要运行的IJob之间。我将很快介绍作业实现，但是首先让我们更新现有的IJobFactory实现以无论请求哪个作业，始终返回QuartzJobRunner的实例，：


using Microsoft.Extensions.DependencyInjection;
using Quartz;
using Quartz.Spi;
using System;
public class JobFactory : IJobFactory
{
    private readonly IServiceProvider _serviceProvider;
    public JobFactory(IServiceProvider serviceProvider)
    {
        _serviceProvider = serviceProvider;
    }
    public IJob NewJob(TriggerFiredBundle bundle,IScheduler scheduler)
    {
        return _serviceProvider.GetrequiredService<QuartzJobRunner>();
    }
    public void ReturnJob(IJob job) { }
}
@H_502_25@

如您所见，该NewJob()方法始终返回QuartzJobRunner的实例。我们将在Startup.ConfigureServices()中将QuartzJobRunner注册为单例模式，因此我们不必担心它没有被明确释放。


services.AddSingleton<QuartzJobRunner>();
@H_502_25@

我们将在QuartzJobRunner中创建实际所需的IJob实例。QuartzJobRunner中的job会创建范围，实例化IJob的请求并执行它：


using Microsoft.Extensions.DependencyInjection;
using Quartz;
using System;
using System.Threading.Tasks;
public class QuartzJobRunner : IJob
{
    private readonly IServiceProvider _serviceProvider;
    public QuartzJobRunner(IServiceProvider serviceProvider)
    {
        _serviceProvider = serviceProvider;
    }
    public async Task Execute(IJobExecutionContext context)
    {
        using (var scope = _serviceProvider.CreateScope())
        {
            var jobType = context.JobDetail.JobType;
            var job = scope.ServiceProvider.GetrequiredService(jobType) as IJob;
            await job.Execute(context);
        }
    }
}
@H_502_25@

在这一点上，您可能想知道，通过添加这个额外的间接层，我们获得了什么好处？主要有以下两个主要优点：


    

  • 我们可以将EmailReminderJob注册为范围服务，并直接将任何依赖项注入其构造函数中
    • 

  • 我们可以将其他横切关注点转移到QuartzJobRunner类中。
    • 



作业可以直接使用作用域服务


由于作业实例是从IServiceProvder作用域中解析来的，因此您可以在作业实现的构造函数中安全地使用作用域服务。这使的EmailReminderJob的实现更加清晰，并遵循构造函数注入的典型模式。如果您不熟悉DI范围界定问题，则可能很难理解它们，因此任何对您不利的事情在我看来都是一个好主意：


[DisallowConcurrentExecution]
public class EmailReminderJob : IJob
{
    private readonly AppDbContext _dbContext;
    private readonly IEmailSender _emailSender;
    public EmailReminderJob(AppDbContext dbContext,IEmailSender emailSender)
    {
        _dbContext = dbContext;
        _emailSender = emailSender;
    }
    public Task Execute(IJobExecutionContext context)
    {
        // fetch customers,update DB
        return Task.CompletedTask;
    }
}
@H_502_25@

这些IJob的实现可以使用以下任何生存期（作用域或瞬态）来在Startup.ConfigureServices()中注册（JobSchedule仍然可以是单例）：


services.AddScoped<EmailReminderJob>();
services.AddSingleton(new JobSchedule(
    jobType: typeof(EmailReminderJob),cronExpression: "0 0 12 * * ?")); // every day at noon
@H_502_25@

QuartzJobRunner可以处理横切关注点


QuartzJobRunner处理正在执行的IJob的整个生命周期：它从容器中获取，执行并释放它（在释放范围时）。因此，它很适合处理其他跨领域问题。


例如，假设您有一个需要更新数据库并将事件发送到消息总线的服务。您可以在每个单独的IJob实现中处理所有这些问题，也可以将跨领域的“提交更改”和“调度消息”操作移到QuartzJobRunner中。




这个例子显然是非常基础的。如果这里的代码适合您，我建议您观看吉米·博加德（Jimmy Bogard）的“六小段失败线”演讲，其中描述了一些问题！




public class QuartzJobRunner : IJob
{
    private readonly IServiceProvider _serviceProvider;
    public QuartzJobRunner(IServiceProvider serviceProvider)
    {
        _serviceProvider = serviceProvider;
    }
    public async Task Execute(IJobExecutionContext context)
    {
        using (var scope = _serviceProvider.CreateScope())
        {
            var jobType = context.JobDetail.JobType;
            var job = scope.ServiceProvider.GetrequiredService(jobType) as IJob;
            var dbContext = _serviceProvider.GetrequiredService<AppDbContext>();
            var messageBus = _serviceProvider.GetrequiredService<IBus>();
            await job.Execute(context);
            // job completed,save dbContext changes
            await dbContext.SaveChangesAsync();
            // db transaction succeeded,send messages
            await messageBus.DispatchAsync();
        }
    }
}
@H_502_25@

这里的QuartzJobRunner实现与上一个非常相似，但是在执行的我们请求的IJob之前，我们从DI容器中解析了DbContext和消息总线服务。当作业成功执行后（即未抛出异常），我们将所有未提交的更改保存在中DbContext，并在消息总线上调度事件。


将这些方法移到QuartzJobRunner中应该可以减少IJob实现中的重复代码，并且可以更容易地移到更正式的管道和其他模式（如果您希望以后这样做的话）。


可替代解决方案


我喜欢本文中显示的方法（使用中间QuartzJobRunner类），主要有两个原因：


    

  • 您的其他IJob实现不需要任何有关创建作用域的基础结构的知识，只需完成标准构造函数注入即可
    • 

  • 在IJobFactory中不需要做做任何特殊处理工作。该QuartzJobRunner通过创建和处理作用域隐式地处理这个问题。
    • 



但是，此处显示的方法并不是在工作中使用范围服务的唯一方法。马修·阿伯特（Matthew Abbot） 在这个文章中演示了一种方法，该方法旨在以正确处理运行后的作业的方式实现IJobFactory。它有点笨拙，因为你必须匹配接口API，但可以说它更接近你应该实现它的方式！我个人认为我会坚持使用这种QuartzJobRunner方法，但是你可以选择最适合您的方法

猜你在找的.NET Core相关文章

非root用户使用AntDeploy部署docker
AntDeploy这个东西非常好用，可以直接将.NET CORE的程序直接发布到docker，刚好我有这个需...
在.NET中体验GraphQL
前言 以前需要提供Web服务接口的时候，除了标准的WEBAPI形式，还考虑了OData、GraphQL等形...
C#脚本引擎CS-Script
最近想要在程序中嵌入一个C#脚本引擎，在.NET Framework时代用过一个叫做CS-Script的东西，...
使用Swagger直接上传文件的方法
经常使用swagger，可以通过设置[ProducesResponseType]标记接口的返回信息；swagger也能通...
武装你的WEBAPI-OData常见问题
本文属于OData系列 目录 武装你的WEBAPI-OData入门 武装你的WEBAPI-OData便捷查询 武装你的...
C#规则引擎RulesEngine
当编写应用程序时，经常性需要花费大量的时间与精力处理业务逻辑，往往业务逻辑的变化需要...
使用mDNS进行局域网服务发现（.NET Core）
想要服务写的好，配置文件不可少。如果是一个复杂的系统，甚至配置文件都是需要进行动态调...
DOTNET Core MVC（二）路由初探
搁置了几天，工作忙的一塌糊涂，今天终于抽空来继续看看MVC的知识。先来看看MVC的路由是如...
Asp.net Core MVC（四）
上一篇说的是asp.net mvc核心UseMvc的过程，末尾想捋一下asp.net核心的路由流转过程，现在...
DOTNET Core MVC （一）
以控台的形式，运行.net core&#160;mvc 代码， Host.CreateDefaultBuilder(args) .Con...
PHPJavaJava SEPythonC#C&C++RubyVBasp.NetGoPerlnettyDjangoDelphiJsp.NET CoreSpringFlaskSpringbootSpringMVCLuaLaravelMybatisAspGroovyThinkPHPYiiswoole
文件时间pythonm相等性PHP Warning时间问题问题解决pcntl_signal采样点wav模块动态文本调用频率限制对外暴露多个访问请求更新数据表模型结构type()方法比较速度手写体sobel算子保存模型Image类nn.Conv2dpytorch1.0kaggleDCGAN交并比range()用法打印模型反卷积卷积