【.NET生态系列】使用Hangfire+.NET 6实现定时任务管理 - ToB企服应用市场:ToB评测及商务社交产业平台

builder.Services.AddHangfire(c =>
{
// 使用内存数据库演示，在实际使用中，会配置对应数据库连接，要保证该数据库要存在
c.UseMemoryStorage();
});
// Hangfire全局配置
GlobalConfiguration.Configuration
.UseColouredConsoleLogProvider()
.UseSerilogLogProvider()
.UseMemoryStorage()
.WithJobExpirationTimeout(TimeSpan.FromDays(7));
// Hangfire服务器配置
builder.Services.AddHangfireServer(options =>
{
options.HeartbeatInterval = TimeSpan.FromSeconds(10);
});

复制代码

// 添加Hangfire Dashboard
app.UseHangfireDashboard();
app.UseAuthorization();
app.MapControllers();
// 配置Hangfire Dashboard路径和权限控制
app.MapHangfireDashboard("/hangfire", new DashboardOptions
{
AppPath = null,
DashboardTitle = "Hangfire Dashboard Test",
Authorization = new []
{
new HangfireCustomBasicAuthenticationFilter
{
User = app.Configuration.GetSection("HangfireCredentials:UserName").Value,
Pass = app.Configuration.GetSection("HangfireCredentials:Password").Value
}
}
});

复制代码

"HangfireCredentials": {
"UserName": "admin",
"Password": "admin@123"
}

复制代码

using Hangfire;
BackgroundJob.Enqueue(() => Console.WriteLine("Hello world from Hangfire with Fire and Forget job!"));

复制代码

var jobId = BackgroundJob.Enqueue(() => Console.WriteLine("Hello world from Hangfire with Fire and Forget job!"));
// Continuous Job, 通过指定上一个任务的Id来跟在上一个任务后执行
BackgroundJob.ContinueJobWith(jobId, () => Console.WriteLine("Hello world from Hangfire using continuous job!"));

复制代码

// 指定5天后执行
BackgroundJob.Schedule(() => Console.WriteLine("Hello world from Hangfire using scheduled job!"), TimeSpan.FromDays(5));

复制代码

namespace HelloHangfire;
public interface IJob
{
public Task<bool> RunJob();
}

复制代码

using Serilog;
namespace HelloHangfire;
public class Job : IJob
{
public async Task<bool> RunJob()
{
Log.Information($"start time: {DateTime.Now}");
// 模拟任务执行
await Task.Delay(1000);
Log.Information("Hello world from Hangfire in Recurring mode!");
Log.Information($"stop time: {DateTime.Now}");
return true;
}
}

复制代码

builder.Services.AddTransient<IJob, Job>();
// ...
var app = builder.Build();
// ...
var JobService = app.Services.GetRequiredService<IJob>();
// Recurring job
RecurringJob.AddOrUpdate("Run every minute", () => JobService.RunJob(), "* * * * *");

复制代码

info: Hangfire.BackgroundJobServer[0]
Starting Hangfire Server using job storage: 'Hangfire.MemoryStorage.MemoryStorage'
info: Hangfire.BackgroundJobServer[0]
Using the following options for Hangfire Server:
Worker count: 20
Listening queues: 'default'
Shutdown timeout: 00:00:15
Schedule polling interval: 00:00:15
info: Hangfire.Server.BackgroundServerProcess[0]
Server b8d0de54-caee-4c5e-86f5-e79a47fad51f successfully announced in 11.1236 ms
info: Hangfire.Server.BackgroundServerProcess[0]
Server b8d0de54-caee-4c5e-86f5-e79a47fad51f is starting the registered dispatchers: ServerWatchdog, ServerJobCancellationWatcher, ExpirationManager, CountersAggregator, Worker, DelayedJobScheduler, RecurringJobScheduler...
info: Hangfire.Server.BackgroundServerProcess[0]
Server b8d0de54-caee-4c5e-86f5-e79a47fad51f all the dispatchers started
Hello world from Hangfire with Fire and Forget job!
Hello world from Hangfire using continuous job!
info: Microsoft.Hosting.Lifetime[14]
Now listening on: https://localhost:7295
info: Microsoft.Hosting.Lifetime[14]
Now listening on: http://localhost:5121
info: Microsoft.Hosting.Lifetime[0]
Application started. Press Ctrl+C to shut down.
info: Microsoft.Hosting.Lifetime[0]
Hosting environment: Development
info: Microsoft.Hosting.Lifetime[0]
Content root path: /Users/yu.li1/Projects/asinta/Net6Demo/HelloHangfire/HelloHangfire/
[16:56:14 INF] start time: 02/25/2022 16:56:14
[16:57:14 INF] start time: 02/25/2022 16:57:14
[16:57:34 INF] Hello world from Hangfire in Recurring mode!
[16:57:34 INF] stop time: 02/25/2022 16:57:34

复制代码