64 lines
2.6 KiB
C#
64 lines
2.6 KiB
C#
using Hangfire;
|
|
using Hangfire.Console;
|
|
using Hangfire.Dashboard;
|
|
using Hangfire.PerformContextAccessor;
|
|
using Hangfire.Storage.SQLite;
|
|
using HangfireExample.WebService.Filters;
|
|
|
|
namespace HangfireExample.WebService.Extensions
|
|
{
|
|
/// <summary>
|
|
/// Hangfire 的擴充方法。
|
|
/// </summary>
|
|
public static class HangfireExtension
|
|
{
|
|
/// <summary>
|
|
/// 加入 Hangfire 服務。
|
|
/// </summary>
|
|
/// <param name="services"></param>
|
|
/// <returns></returns>
|
|
public static IServiceCollection AddHangfire(this IServiceCollection services)
|
|
{
|
|
// 將 Hangfire 處理序存取加入服務
|
|
services.AddHangfirePerformContextAccessor();
|
|
// 將 Hangfire 加入服務，使用 SQLite 作為儲存區
|
|
services.AddHangfire(configuration => configuration
|
|
.UseSQLiteStorage("HangfireExample.db")
|
|
.UsePerformContextAccessorFilter()
|
|
.UseConsole());
|
|
// 將 Hangfire Server 加入服務
|
|
services.AddHangfireServer(options =>
|
|
{
|
|
// 指定 Hangfire Server 的名稱
|
|
options.ServerName = "HangfireExample";
|
|
// 指定 Hangfire Server 執行佇列的 Tags
|
|
options.Queues = ["default", "wb",];
|
|
});
|
|
return services;
|
|
}
|
|
|
|
public static WebApplication UseHangfireDashboard(this WebApplication app, IConfiguration configuration)
|
|
{
|
|
// Hangfire Dashboard 預設路由為 /Hangfire
|
|
app.UseHangfireDashboard(configuration.GetValue<string>("DashboardRoot"), new DashboardOptions
|
|
{
|
|
Authorization = [new DashboardAuthorizationFilter()],
|
|
// 指定 Dashboard 指定讀取，不能操作，如重新執行、再次加入排程與刪除任務等
|
|
IsReadOnlyFunc = (DashboardContext context) => false,
|
|
// 指定 Back to site 的連結
|
|
AppPath = "/swagger",
|
|
});
|
|
// 設定第二資料來源的 Dashboard
|
|
//app.UseHangfireDashboard(configuration.GetValue<string>("DashboardRoot"), new DashboardOptions
|
|
//{
|
|
// Authorization = [new DashboardAuthorizationFilter()],
|
|
// // 指定 Dashboard 指定讀取，不能操作，如重新執行、再次加入排程與刪除任務等
|
|
// IsReadOnlyFunc = (DashboardContext context) => true,
|
|
// // 指定 Back to site 的連結
|
|
// AppPath = "/swagger",
|
|
//}, new SQLiteStorage("HangfireExample2.db"));
|
|
return app;
|
|
}
|
|
}
|
|
}
|