在 ASP Net Core 中使用 hangfire 激活类

Question

我在配置 HangFire 时遇到问题。我试图在 ASP Net Core 中触发并忘记一个令人震惊的调用。

报警服务：

public void FireAndForgetAlarm(int statusCode, string message, string subject = null, IList<string> attachmentFilePaths = null)
{
    BackgroundJob.Enqueue(() => Alarm(statusCode, message, subject, 
    attachmentFilePaths));
}

*Alarm 方法是公开的。

错误描述：

警告：Hangfire.AutomaticRetryAttribute[0] 无法处理作业“eb7f76ea-7522-49e2-b7b9-3ed3ed091a0c”：发生异常。 10 次重试第 2 次将在 00:01:02 执行。 System.InvalidOperationException：尝试激活“Wms.Alarming.AlarmingService”时无法解析“Wms.Alarming.AlarmingConfig”类型的服务。 在 Microsoft.Extensions.DependencyInjection.ActivatorUtilities.ConstructorMatcher.CreateInstance（IServiceProvider 提供程序） 在 Microsoft.Extensions.DependencyInjection.ActivatorUtilities.CreateInstance（IServiceProvider 提供程序，类型 instanceType，Object[] 参数） 在 Microsoft.Extensions.DependencyInjection.ActivatorUtilities.GetServiceOrCreateInstance（IServiceProvider 提供程序，类型类型） 在 Hangfire.AspNetCore.AspNetCoreJobActivatorScope.Resolve（类型类型） 在 Hangfire.Server.CoreBackgroundJobPerformer.Perform（PerformContext 上下文） 在 Hangfire.Server.BackgroundJobPerformer.c__DisplayClass9_0.b__0() 在 Hangfire.Server.BackgroundJobPerformer.InvokePerformFilter（IServerFilter 过滤器，PerformingContext preContext，Func1 continuation) at Hangfire.Server.BackgroundJobPerformer.<>c__DisplayClass9_1.<PerformJobWithFilters>b__2() at Hangfire.Server.BackgroundJobPerformer.PerformJobWithFilters(PerformContext context, IEnumerable1 过滤器） 在 Hangfire.Server.BackgroundJobPerformer.Perform（PerformContext 上下文） 在 Hangfire.Server.Worker.PerformJob(BackgroundProcessContext context, IStorageConnection connection, String jobId)

我的启动类包含：

public void ConfigureServices(IServiceCollection services)
{
    services.ConfigureAlarmingServices(new AlarmingConfig()
    {
        Port = int.Parse(ConfigurationManager.AppSettings["mailPort"]), // for SSL 465
        Sender = ConfigurationManager.AppSettings["mailSender"],
        SmtpServer = ConfigurationManager.AppSettings["smtpServer"],
        Recipients = ConfigurationManager.AppSettings["mailRecipients"],
        SenderPassword = ConfigurationManager.AppSettings["mailPassword"]
    });
    services.AddHangfire(c => {
            c.UseMemoryStorage();
    });
}

public void Configure(IApplicationBuilder app, IWebHostEnvironment env) 
{
     app.UseHangfireServer(new BackgroundJobServerOptions(){Activator = new AspNetCoreJobActivator(app.ApplicationServices.GetRequiredService<IServiceScopeFactory>())});
}

注意事项：

• 我已经为启动类尝试了多个版本，包括将激活器放在 AddHangire 方法中。没有任何尝试真正奏效，我也正确地遵循了文档。
• 报警服务配置正确，无需 HangFire 即可工作。
• 在警报配置中传递文字不起作用
• 唯一的解决方案是使方法静态化，但这不允许好的 DI
• 我在他们的文档中看到了一个解决方案，他们总是有一个默认构造函数并使用参数调用构造函数。但是，这对我来说是不可能的，因为我也在注入记录器。

在 cmets 中请求的扩展方法的内容：

public static void ConfigureAlarmingServices(this IServiceCollection collection, AlarmingConfig config)
{
    collection.AddSingleton<IAlarmingService>(x=> new 
    AlarmingService(x.GetService<ILogger<IAlarmingService>>(), config));
}

Answer 1

首先，您看到的异常的重要部分是：

在尝试激活“Wms.Alarming.AlarmingService”时无法解析“Wms.Alarming.AlarmingConfig”类型的服务

这表明在您的代码中的某处（您尚未显示的部分）您正在尝试注入 AlarmingService 的实例。

您已经配置了如何为接口IAlarmingService 解析单例服务，这意味着您应该能够拥有一个依赖于IAlarmingService 的类。但是，如果您的类具体依赖于AlarmingService（而不是接口），您将收到此错误，因为您尚未定义如何解决AlarmingService 类型的依赖关系。

要么...

• 您没有显示的代码应该只依赖于IAlarmingService 而不是具体类本身 (AlarmingService) 或..
• 您还需要配置 DI 容器来处理特定于 AlarmingService 类型的依赖项，例如：

public static void ConfigureAlarmingServices(this IServiceCollection collection, AlarmingConfig config)
{
    collection.AddSingleton<AlarmingService>(
        x => new AlarmingService(x.GetService<ILogger<AlarmingService>>(), config));
    collection.AddSingleton<IAlarmingService>(x => x.GetService<AlarmingService>());
}

我认为第一点是你需要解决的问题。