Yoko.Hangfire.Redis 1.0.3.4

Yoko.Hangfire.Redis

🔍 Hangfire的Redis持久化Job插件，支持自定义仪表盘Title

🔍 最低 NET Framework 4.7.2 / NET Standard 2.0

💎 参考配置（Net5）

1、Startup

public static ConnectionMultiplexer Redis;

public Startup(IConfiguration configuration)
{
    Configuration = configuration;
    Redis = ConnectionMultiplexer.Connect(Configuration.GetConnectionString("Redis"));
}

2、appsettings.json

"ConnectionStrings": {
    "Redis": "127.0.0.1:6379"
  }

3、Startup.ConfigureServices

//=========================WebApi===========================
//在.NETCore3.0+后WebApi控制器使用dynamic,object类型接受传值，
//后台接收到的参数中会包含一个ValueKind的属性，包含ValueKind属性会影响取参的便捷性
//所以将对象序列化程序改为NewtonsoftJson便可正常取值
//services.AddControllers().AddNewtonsoftJson(options =>
//{
//    options.SerializerSettings.ContractResolver = new DefaultContractResolver();
//});
//==========================================================
//Hangfire
services.AddHangfire(configuration =>
{
    configuration.UseRedisStorage(Redis, new RedisStorageOptions()
    {
        FetchTimeout = TimeSpan.FromMinutes(5),
        Db = 1,
        Prefix = "{APiServer}:",
        //活动服务器超时时间
        InvisibilityTimeout = TimeSpan.FromHours(1),
        //任务过期检查频率
        ExpiryCheckInterval = TimeSpan.FromHours(1),
        DeletedListSize = 10000,
        SucceededListSize = 10000
    })
    .UseHangfireDashboard(new JobDashboardOptions()
    {
        DashboardTitle = "API任务调度管理系统",
        DashboardName = "API任务调度管理系统",
        DashboardFooter = "API任务调度管理系统 V1.0.0"
    })
    //.UseConsole(new ConsoleOptions()
    //{
    //    BackgroundColor = "#000079"
    //})
    .UseDashboardMetric(DashboardMetrics.AwaitingCount)
    .UseDashboardMetric(DashboardMetrics.ProcessingCount)
    .UseDashboardMetric(DashboardMetrics.RecurringJobCount)
    .UseDashboardMetric(DashboardMetrics.RetriesCount)
    .UseDashboardMetric(DashboardMetrics.FailedCount)
    .UseDashboardMetric(DashboardMetrics.SucceededCount);
});
//IHostedService
services.AddHangfireServer(options =>
{
    options.ServerTimeout = TimeSpan.FromMinutes(4);
    options.SchedulePollingInterval = TimeSpan.FromSeconds(1);//秒级任务需要配置短点，一般任务可以配置默认时间，默认15秒
    options.ShutdownTimeout = TimeSpan.FromMinutes(30);//超时时间
    options.Queues = new[] { "testjob", "apis", "default" };//默认队列
    options.WorkerCount = Math.Max(Environment.ProcessorCount, 40);//工作线程数，当前允许的最大线程，默认20
});

4、Startup.ConfigureServices

//只读面板
app.UseHangfireDashboard("/hangfire-read", new DashboardOptions
{
    AppPath = "#",
    DisplayStorageConnectionString = false,
    IsReadOnlyFunc = Context =>
    {
        return false;
    }
});
app.UseEndpoints(endpoints =>
{
    endpoints.MapHangfireDashboard();
});