安装包-NuGet

Hangfire.Core
Hangfire.AspNetCore
Hangfire.Dashboard.BasicAuthorization
Hangfire.SqlServer

服务配置

新建一个类 用作service配置

  1.  public static class HangfireService
  2.     {
  3.         public static void AddHangfireService(this IServiceCollection services)
  4.         {
  5.             // Add Hangfire services.
  6.             if (services == null) throw new ArgumentNullException(nameof(services));
  7.             services.AddHangfire(configuration => configuration
  8.        .SetDataCompatibilityLevel(CompatibilityLevel.Version_170)
  9.        .UseSimpleAssemblyNameTypeSerializer()
  10.        .UseRecommendedSerializerSettings()
  11.        .UseSqlServerStorage("数据库连接字符串", new SqlServerStorageOptions
  12.        {
  13.            CommandBatchMaxTimeout = TimeSpan.FromMinutes(5),
  14.            SlidingInvisibilityTimeout = TimeSpan.FromMinutes(5),
  15.            QueuePollInterval = TimeSpan.Zero,
  16.            UseRecommendedIsolationLevel = true,
  17.            UsePageLocksOnDequeue = true,
  18.            DisableGlobalLocks = true,
  19.            //JobExpirationCheckInterval = TimeSpan.FromHours(1), //- 作业到期检查间隔（管理过期记录）。默认值为1小时。
  20.            //CountersAggregateInterval = TimeSpan.FromMinutes(5), //- 聚合计数器的间隔。默认为5分钟。
  22.        }));
  24.             // Add the processing server as IHostedService
  25.             services.AddHangfireServer();
  27.         }
  28.     }

StartUp中添加服务

  1. services.AddHangfireService();

数据面板配置

新建一个类 进行配置

  1.  public static class HangfireMiddleware
  2.     {
  3.         public static void UseHangfireMiddleware(this IApplicationBuilder app)
  4.         {
  5.             if (app == null) throw new ArgumentNullException(nameof(app));
  7.             app.UseHangfireServer(ConfigureOptions());//配置服务
  8.             app.UseHangfireDashboard(AppsettingConfig.HangfirePathMatch, HfAuthor());//配置面板
  9.             //backgroundJobs.Enqueue(() => Console.WriteLine("Hello world from Hangfire!"));
  10.             //backgroundJobs.AddOrUpdate();
  11.             HangfireService();//配置各个任务
  12.         }
  13.         /// <summary>
  14.         /// 配置账号模板信息 
  15.         /// </summary>
  16.         /// <returns></returns>
  17.         public static DashboardOptions HfAuthor()
  18.         {
  20.             var filter = new BasicAuthAuthorizationFilter(
  21.             new BasicAuthAuthorizationFilterOptions
  22.             {
  23.                 SslRedirect = false,
  24.                 RequireSsl = false,
  25.                 LoginCaseSensitive = false,
  26.                 Users = new[]
  27.                 {
  28.                         new BasicAuthAuthorizationUser
  29.                         {
  30.                         Login = 账号, //可视化的登陆账号
  31.                         PasswordClear = 密码 //可视化的密码
  32.                         }
  33.                 }
  34.             });
  35.             return new DashboardOptions
  36.             {
  37.                 Authorization = new[] { filter }
  38.             };
  39.         }
  41.         /// <summary>
  42.         /// 配置启动
  43.         /// </summary>
  44.         /// <returns></returns>
  45.         public static BackgroundJobServerOptions ConfigureOptions()
  46.         {
  47.             return new BackgroundJobServerOptions
  48.             {
  49.                 Queues = new[] { HangfireConfigureQueue.Myqueue, HangfireConfigureQueue.Default },//队列名称，只能为小写
  50.                 WorkerCount = Environment.ProcessorCount * 5, //并发任务
  51.                 ServerName = AppsettingConfig.HangfireServerName, //代表服务名称
  53.             };
  54.         }
  56.         #region 配置服务
  57.         public static void HangfireService()
  58.         {
  59.             //这里呢就是需要触发的方法 "0/10 * * * * ? " 可以自行搜索cron表达式 代表循环的规律很简单
  61.             //GameLenthPush代表你要触发的类 UserGameLenthPush代表你要触发的方法
  63.             //RecurringJob.AddOrUpdate<GameLenthPush>(s => s.UserGameLenthPush(), "0/10 * * * * ? ", TimeZoneInfo.Local);
  64.             //RecurringJob.AddOrUpdate<ITestServices>(s => s.TestHangfiredefault(), "0/5 * * * * ? ", TimeZoneInfo.Local);
  65.             //RecurringJob.AddOrUpdate<ITestServices>(s => s.TestHangfireMyqueue(), "0/5 * * * * ? ", TimeZoneInfo.Local, HangfireConfigureQueue.Myqueue);
  67.         }
  68.         #endregion
  69.     }

添加服务面板

// 使用Hangfire
app.UseHangfireMiddleware();