Hangfire Background Worker Manager

Hangfire是一个高级的后台工作者管理. 你可以用ABP框架Hangfire集成代替默认后台工作者管理.

主要优点是你可以使用相同的服务器群来管理你的后台作业和工作线程以及利用 Hangfire 提供的Recurring Jobs高级调度功能.

安装

建议使用ABP CLI安装包.

使用ABP CLI

在项目的文件夹(.csproj文件)中打开命令行窗口输入以下命令:

abp add-package Volo.Abp.BackgroundWorkers.Hangfire

手动安装

如果你想手动安装;

1. 添加 Volo.Abp.BackgroundWorkers.Hangfire NuGet包添加到你的项目:

   Install-Package Volo.Abp.BackgroundWorkers.Hangfire

2. 添加 AbpBackgroundWorkersHangfireModule 到你的模块的依赖列表:

[DependsOn(
    //...other dependencies
    typeof(AbpBackgroundWorkersHangfireModule) //Add the new module dependency
    )]
public class YourModule : AbpModule
{
}

Hangfire后台工作者集成提供了 HangfirePeriodicBackgroundWorkerAdapter 来适配 PeriodicBackgroundWorkerBase 和 AsyncPeriodicBackgroundWorkerBase 派生类. 所以你依然可以按照后台工作者文档来定义后台作业.

创建后台工作者

HangfireBackgroundWorkerBase 是创建一个后台工作者简单的方法.

public class MyLogWorker : HangfireBackgroundWorkerBase
{
    public MyLogWorker()
    {
        RecurringJobId = nameof(MyLogWorker);
        CronExpression = Cron.Daily();
    }
    public override Task DoWorkAsync()
    {
        Logger.LogInformation("Executed MyLogWorker..!");
        return Task.CompletedTask;
    }
}

• RecurringJobId 是一个可选参数, 参阅 Hangfire文档
• CronExpression 是CRON表达式, 参阅 CRON 表达式

你可以直接实现 IHangfireBackgroundWorker, 但是 HangfireBackgroundWorkerBase 提供了一些有用的属性,例如 Logger.

UnitOfWork

使用 UnitOfWorkAttribute 你需要为工作者定义一个接口:

public interface IMyLogWorker : IHangfireBackgroundWorker
{
}
[ExposeServices(typeof(IMyLogWorker))]
public class MyLogWorker : HangfireBackgroundWorkerBase, IMyLogWorker
{
    public MyLogWorker()
    {
        RecurringJobId = nameof(MyLogWorker);
        CronExpression = Cron.Daily();
    }
    [UnitOfWork]
    public override Task DoWorkAsync()
    {
        Logger.LogInformation("Executed MyLogWorker..!");
        return Task.CompletedTask;
    }
}

注册到后台工作者管理器

创建一个后台工作者后, 你应该添加到 IBackgroundWorkerManager, 最常用的地方是在你模块类的 OnApplicationInitialization 方法中:

[DependsOn(typeof(AbpBackgroundWorkersModule))]
public class MyModule : AbpModule
{
    public override void OnApplicationInitialization(
        ApplicationInitializationContext context)
    {
        context.AddBackgroundWorker<MyLogWorker>();
        //如果定义了接口
        //context.AddBackgroundWorker<IMyLogWorker>(); 
    }
}

context.AddBackgroundWorker(...) 是一个是以下代码快捷的扩展方法:

context.ServiceProvider
    .GetRequiredService<IBackgroundWorkerManager>()
    .Add(
        context
            .ServiceProvider
            .GetRequiredService<MyLogWorker>()
    );

它解析给定的后台工作者并添加到 IBackgroundWorkerManager.

虽然我们通常在 OnApplicationInitialization 中添加后台工作者, 但对此没有限制. 你可以在任何地方注入 IBackgroundWorkerManager 并在运行时添加后台工作者.