Hangfire可用作任务调度，类似延迟任务、队列任务、批量任务和定时任务等。

一、nuget Hangfire包

找到Hangfire.AspNetCore和Hangfire.SqlServer包，可以在nuget面板中找到或直接像如下方式安装：

Install Package Hangfire.AspNetCore

Install Package Hangfire.SqlServer

二、在Startup.cs文件中加入以下代码：

写一个Hangfire的扩展类，如下所示：

public static classHangFireModule

{public static IApplicationBuilder UseHangfire(thisIApplicationBuilder app)

{

app.UseHangfireServer();

app.UseHangfireDashboard();returnapp;

}public static IServiceCollection AddHangfire(thisIServiceCollection services)

{

services.AddHangfire(x=> x.UseSqlServerStorage(ConfigurationSetting.Configuration["ConnectionString:MyDb_Hangfire"]));returnservices;

}

}

在Startup的ConfigureServices方法中，加入services.AddHangfire();

在Startup的Configure方法中，加入app.UseHangfire();

三、自动加入任务

1.在当前模块中，新创建一个名为IHangfireTask的接口，将其注册为瞬时生命周期服务。我们将要实现的是，从此以后，继承该接口的类型都会被自动加入到任务调度中。

///

///Hangfire任务接口，任何继承该接口的都会加入到Hangfire任务///

public interfaceIHangfireTask : ITransient {///

///运行hangfire任务///

voidRun();

}

ITransient接口的作用就是，将所有继承ITransient的接口和类型注册为瞬时生命周期的服务。

2.在HangFireModule中新增一个UseHangfireTask扩展方法，目的是在Startup的Configure方法中使用，在程序启动的时候就执行该方法。

//运行Hangfire任务

public static void UseHangfireTask(thisIApplicationBuilder app) {//找到继承了IHangfireTask接口的实例

IList list = ServiceLocator.Services.GetServices()?.ToList();if (list?.Count > 0) {foreach (var item inlist) {

item.Run();

}

}

}

加入到Startup的Configure方法中：

public voidConfigure(IApplicationBuilder app, IHostingEnvironment env,IServiceProvider serviceProvider)

{

ServiceLocator.SetServices(serviceProvider);if(env.IsDevelopment())

{

app.UseDeveloperExceptionPage();

}else{

app.UseExceptionHandler();

}

app.UseMvc();

app.UseSwagger();

app.UseSwaggerUi();

app.UseHangfire();

app.UseHangfireTask();

}

如此这样，我们就做到了在程序刚启动时，程序就会自动去找到继承自IHangfireTask接口的所有类型并运行它们的Run()方法。

我们可以在Run()方法中实现诸如Hangfire的BackgroundJob或RecurringJob等任务。

接下来我们就用代码来实现一下！

我们现在想实现一个定时任务，则看如下代码：

public classRecurringTask:IHangfireTask

{private log4net.ILog log => LogHelper.Log4NetInstance.LogFactory(typeof(RecurringTask));public voidRunTask()

{

log.Info("每分钟执行一次定时任务");

}public voidRun()

{

RecurringJob.AddOrUpdate(()=> RunTask(), "* * * * *");

}

}

这里有一个地方需要注意，在使用RecurringJob或BackgroundJob的时候，就例如()=> RunTask()这个，RunTask方法的访问修饰符必须是public。如果有必要，尽量在RunTask方法内被调用的其他方法的访问修饰符也定义为public。

在Hangfire中，Cron表达式包含五个字段：分钟、小时、日期、月份、周，因此定时任务最低也只能是一分钟，没有秒数可供选择。

接下来我们看看程序运行的结果：

四、Hangfire的基本任务

1. BackgroundJob.Enqueue

作用：将一个任务放入到某个持久化的队列中并挨个执行，以便程序可以继续执行其他代码。该任务只执行一次。

实现：BackgroundJob.Enqueue(() => RunTask());

2. BackgroundJob.Schedule

作用：将一个任务延迟到某个时间点后执行。

实现：BackgroundJob.Schedule(() => RunTask(), TimeSpan.FromSeconds(30));

即在30秒后才执行RunTask()方法。

3. RecurringJob.AddOrUpdate

作用：重复执行一个任务，一般用作定时任务处理。

实现：RecurringJob.AddOrUpdate(()=> RunTask(), "* * * * *");

即每分钟都执行一次RunTask()方法。

4. BackgroundJob.ContinueWith

作用：类似工作流的形式，将多个任务连接起来按照顺序执行。

实现：

string jobId = BackgroundJob.Schedule(() => Console.WriteLine("第一个任务"),TimeSpan.FromSeconds(10));

BackgroundJob.ContinueWith(jobId, () => RunTask());

注意：以上RunTask()方法的访问修饰符必须是public。