使用.net核心进行Hangfire依赖注入

如何在Hangfire中使用.net core的默认依赖注入？

我是Hangfire的新手,正在寻找一个与asp.net核心兼容的例子.

请参阅GitHub上的完整示例https://github.com/gonzigonz/HangfireCore-Example.
现场网站http://hangfirecore.azurewebsites.net/

确保您拥有Hangfire的核心版本:
dotnet add package Hangfire.AspNetCore

通过定义a来配置IoC JobActivator.以下是与默认的asp.net核心容器服务一起使用的配置:

public class HangfireActivator : Hangfire.JobActivator
{
    private readonly IServiceProvider _serviceProvider;

    public HangfireActivator(IServiceProvider serviceProvider)
    {
        _serviceProvider = serviceProvider;
    }

    public override object ActivateJob(Type type)
    {
        return _serviceProvider.GetService(type);
    }
}  

接下来在Startup.ConfigureServices方法中注册hangfire作为服务:

services.AddHangfire(opt => 
    opt.UseSqlServerStorage("Your Hangfire Connection string"));

在Startup.Configure方法中配置hangfire .与您的问题相关,关键是配置hangfire以使用HangfireActivator我们刚才定义的新内容.为此,您必须提供hangfire,IServiceProvider这可以通过将其添加到Configure方法的参数列表来实现.在运行时,DI将为您提供此服务:

public void Configure(
    IApplicationBuilder app, 
    IHostingEnvironment env, 
    ILoggerFactory loggerFactory,
    IServiceProvider serviceProvider)
{
    ...

    // Configure hangfire to use the new JobActivator we defined.
    GlobalConfiguration.Configuration
        .UseActivator(new HangfireActivator(serviceProvider));

    // The rest of the hangfire config as usual.
    app.UseHangfireServer();
    app.UseHangfireDashboard();
}  

将作业排入队列时,请使用通常是您的界面的注册类型.除非您以这种方式注册,否则请勿使用具体类型.您必须使用在IoC注册的类型,否则Hang​​fire将无法找到它. 例如,您已经注册了以下服务:

services.AddScoped();
services.AddScoped();

    BackgroundJob.Enqueue(() => dbManager.DoSomething());

    BackgroundJob.Enqueue( ms => ms.DoSomething());

public class JobService : IJobService
{
    private IClientService _clientService;
    private INodeServices _nodeServices;

    //Constructor
    public JobService(IClientService clientService, INodeServices nodeServices)
    {
        _clientService = clientService;
        _nodeServices = nodeServices;
    }

    //Some task to execute
    public async Task SomeTask(Guid subject)
    {
        // Do some job here
        Client client = _clientService.FindUserBySubject(subject);
    }      
}