Xunet.Hangfire 1.8.12.2

Xunet.Hangfire

Timing scheduling library based on hangfire for .NET

Support .NET 6.0/7.0/8.0

��װ

ʹ��NuGet Package ����̨���ڰ�װ����

PM> Install-Package Xunet.Hangfire

ʹ��

Program.cs

var builder = WebApplication.CreateBuilder(args);

var connectionString = builder.Configuration.GetConnectionString("DefaultConnection");

if (connectionString == null) throw new ArgumentNullException(nameof(connectionString));

var sqlOptions = new MySqlStorageOptions()
{
    TablesPrefix = "Hangfire_"
};
var storage = new MySqlStorage(connectionString, sqlOptions);

builder.Services.AddHangfire((a, x) =>
{
    x.UseStorage(storage: storage).WithJobExpirationTimeout(timeout: TimeSpan.FromDays(7));
    x.UseConsole();
    x.UseHeartbeatPage(checkInterval: TimeSpan.FromSeconds(2));
    x.UseTagsWithMySql(sqlOptions: sqlOptions);
    x.UseRecurringJobAdmin(Assembly.GetExecutingAssembly());
});

builder.Services.AddHangfireServer(optionsAction: (provider, options) =>
{
    options.WorkerCount = 40;
    options.Queues = ["default"];
}
, storage: storage, additionalProcesses: new[]
{
    new ProcessMonitor(checkInterval: TimeSpan.FromSeconds(2))
});

var app = builder.Build();

app.MapHangfireDashboard(string.Empty, new DashboardOptions
{
    IsReadOnlyFunc = _ => false,
    DashboardTitle = "��ʱ����"
});

app.Run();

appsettings.json

{
  "Logging": {
    "LogLevel": {
      "Default": "Information",
      "Microsoft.AspNetCore": "Warning"
    }
  },
  "Kestrel": {
    "Endpoints": {
      "http": {
        "Url": "http://0.0.0.0:8888"
      }
    }
  },
  "ConnectionStrings": {
    "DefaultConnection": "server=127.0.0.1;uid=root;pwd=root;database=hangfire;Allow User Variables=True;"
  }
}