Quartz.NET任务中调用其他服务及获取数据库上下文的问题咨询

当然可以在Quartz.NET的自定义任务里调用其他服务、获取数据库上下文——那些只打印控制台的示例只是入门用的，实际项目里这种需求太常见了！下面给你两种最常用的实现方式，优先推荐第一种依赖注入的方案，更符合.NET的设计规范。

一、通过依赖注入（DI）注入服务/数据库上下文（推荐） #

这是最规范、最易维护的方式，核心是让Quartz和你的应用依赖注入容器集成，这样自定义任务就能直接通过构造函数拿到需要的依赖。

1. 确保Quartz集成DI容器 #

在.NET Core/.NET 5+的项目里，配置Quartz时要指定使用支持DI的Job工厂，比如AddScopedJobFactory（或者自定义JobFactory），这样Quartz会从你的DI容器里解析任务实例。

2. 编写带依赖的自定义任务 #

直接把数据库上下文、业务服务等依赖通过构造函数注入到你的MyTask中：

public class MyTask : IJob
{
    private readonly MyDbContext _dbContext;
    private readonly IMyBusinessService _businessService;

    // 构造函数注入所需依赖
    public MyTask(MyDbContext dbContext, IMyBusinessService businessService)
    {
        _dbContext = dbContext;
        _businessService = businessService;
    }

    public async Task Execute(IJobExecutionContext context)
    {
        // 直接使用数据库上下文更新数据
        var targetEntity = await _dbContext.MyEntities.FirstOrDefaultAsync(e => e.Id == 123);
        if (targetEntity != null)
        {
            targetEntity.LastUpdatedTime = DateTime.Now;
            await _dbContext.SaveChangesAsync();
        }

        // 调用其他业务服务
        await _businessService.ProcessTaskAsync();
    }
}

3. 在项目启动时配置DI与Quartz #

在Program.cs（或Startup.cs）里注册你的数据库上下文、业务服务，同时配置Quartz的任务和触发器：

var builder = WebApplication.CreateBuilder(args);

// 1. 注册数据库上下文和业务服务
builder.Services.AddDbContext<MyDbContext>(options =>
    options.UseSqlServer(builder.Configuration.GetConnectionString("DefaultConnection")));
builder.Services.AddScoped<IMyBusinessService, MyBusinessService>();

// 2. 配置Quartz
builder.Services.AddQuartz(q =>
{
    // 注册自定义任务
    var jobKey = new JobKey("MyTask");
    q.AddJob<MyTask>(opts => opts.WithIdentity(jobKey));

    // 配置触发器（这里示例为每5分钟执行一次）
    q.AddTrigger(opts => opts
        .ForJob(jobKey)
        .WithIdentity("MyTaskTrigger")
        .WithCronSchedule("0 0/5 * * * ?"));
});

// 3. 添加Quartz宿主服务，让Quartz随应用一起启动
builder.Services.AddQuartzHostedService(q => q.WaitForJobsToComplete = true);

var app = builder.Build();
// ...其他中间件配置
app.Run();

二、手动获取服务上下文（不推荐，仅兼容旧场景） #

如果你的项目是老版本，或者因为某些原因无法使用构造注入，可以通过Quartz的调度上下文手动获取服务提供者，但这属于服务定位器模式，会降低代码的可测试性和可维护性，尽量避免。

示例代码：

public async Task Execute(IJobExecutionContext context)
{
    // 从调度上下文获取服务提供者（需要提前在启动时存入）
    if (context.Scheduler.Context.TryGetValue("ServiceProvider", out var spObj) 
        && spObj is IServiceProvider serviceProvider)
    {
        // 创建作用域，确保服务的生命周期正确
        using var scope = serviceProvider.CreateScope();
        var dbContext = scope.ServiceProvider.GetRequiredService<MyDbContext>();

        // 后续数据库操作...
        var entity = await dbContext.MyEntities.FindAsync(456);
        if (entity != null)
        {
            entity.Status = "Completed";
            await dbContext.SaveChangesAsync();
        }
    }
}

需要注意：这种方式需要在启动时把IServiceProvider存入Quartz调度器的上下文，比如：

builder.Services.AddQuartz(q =>
{
    // ...其他配置
    q.SchedulerId = "MyScheduler";
    q.SchedulerName = "My App Scheduler";
});

builder.Services.AddQuartzHostedService(q =>
{
    q.WaitForJobsToComplete = true;
    q.StartDelay = TimeSpan.FromSeconds(10);
    // 存入服务提供者
    q.SchedulerFactory = new StdSchedulerFactory();
    q.SchedulerFactory.Initialize(props =>
    {
        props["quartz.scheduler.context.key.ServiceProvider"] = builder.Services.BuildServiceProvider();
    });
});

总结 #

优先使用依赖注入的方式，这不仅符合.NET的设计理念，还能让你的任务代码更清晰、更易于测试和维护。只要确保Quartz和DI容器正确集成，就能轻松在自定义任务里调用任何你需要的服务啦！

内容的提问来源于stack exchange，提问作者Mario Erro