Abp集成HangFire開源.NET任務調(diào)度框架

更新時間：2022年04月29日 10:18:03 作者：張飛洪

這篇文章主要為大家介紹了Abp集成HangFire開源.NET任務調(diào)度框架的示例解析，有需要的朋友可以借鑒參考下，希望能夠有所幫助，祝大家多多進步，早日升職加薪

簡要說明

后臺作業(yè)在系統(tǒng)開發(fā)的過程當中，是比較常用的功能。因為總是有一些長耗時的任務，而這些任務我們不是立即響應的，例如 Excel 文檔導入、批量發(fā)送短信通知等。

ABP vNext 提供了后臺作業(yè)的支持，并且還提供了對 HangFire 和 RabbitMQ 的后臺作業(yè)集成。開發(fā)人員在使用這些第三方庫的時候，基本就是開箱即用，不需要做其他復雜的配置。

ABP vNext 的實現(xiàn)就是在 CLR 的 Timer 之上封裝了一層，周期性地執(zhí)行用戶邏輯。
ABP vNext 默認提供的后臺任務管理器，就是在后臺作業(yè)基礎之上進行的封裝。

涉及到后臺任務的模塊一共有 6 個，它們分別是：

Volo.Abp.Threading ：提供了一些常用的線程組件，其中 AbpTimer 就是在里面實現(xiàn)的。
Volo.Abp.BackgroundWorkers ：后臺任務的定義和實現(xiàn)。
Volo.Abp.BackgroundJobs.Abstractions ：后臺任務的一些共有定義。
Volo.Abp.BackgroundJobs ：默認的后臺任務管理器實現(xiàn)。
Volo.Abp.BackgroundJobs.HangFire ：基于 Hangfire 庫實現(xiàn)的后臺任務管理器。
Volo.Abp.BackgroundJobs.RabbitMQ ：基于 RabbitMQ 實現(xiàn)的后臺任務管理器。

什么是Hangfire

Hangfire 是一個開源的.NET任務調(diào)度框架，目前1.6+版本已支持.NET Core。個人認為它最大特點在于內(nèi)置提供集成化的控制臺，方便后臺查看及監(jiān)控。

引用

<PackageReference Include="Volo.Abp.AspNetCore.Mvc" Version="1.0.2" />
<PackageReference Include="Volo.Abp.Autofac" Version="1.0.2" />
<PackageReference Include="Hangfire" Version="1.7.7" />
<PackageReference Include="Hangfire.AspNetCore" Version="1.7.7" />
<PackageReference Include="Hangfire.Dashboard.BasicAuthorization" Version="1.0.2" />
<PackageReference Include="Hangfire.Redis.StackExchange.StrongName" Version="1.7.0" />

啟動

public class Startup
   {
       public void ConfigureServices(IServiceCollection services)
       {
           services.AddApplication();
           var Configuration = services.GetConfiguration();
           GlobalStateHandlers.Handlers.Add(new SucceededStateExpireHandler(int.Parse(Configuration["Hangfire:JobExpirationTimeout"])));
           services.AddHostedService();
           services.AddHangfire(x =>
           {
               var connectionString = Configuration["Hangfire:Redis:ConnectionString"];
               x.UseRedisStorage(connectionString, new RedisStorageOptions()
               {
                   //活動服務器超時時間
                   InvisibilityTimeout = TimeSpan.FromMinutes(60),
                   Db = int.Parse(Configuration["Hangfire:Redis:Db"])
               });
               x.UseDashboardMetric(DashboardMetrics.ServerCount)
              .UseDashboardMetric(DashboardMetrics.RecurringJobCount)
              .UseDashboardMetric(DashboardMetrics.RetriesCount)
              .UseDashboardMetric(DashboardMetrics.AwaitingCount)
              .UseDashboardMetric(DashboardMetrics.EnqueuedAndQueueCount)
              .UseDashboardMetric(DashboardMetrics.ScheduledCount)
              .UseDashboardMetric(DashboardMetrics.ProcessingCount)
              .UseDashboardMetric(DashboardMetrics.SucceededCount)
              .UseDashboardMetric(DashboardMetrics.FailedCount)
              .UseDashboardMetric(DashboardMetrics.EnqueuedCountOrNull)
              .UseDashboardMetric(DashboardMetrics.FailedCountOrNull)
              .UseDashboardMetric(DashboardMetrics.DeletedCount);
           });
       }
       public void Configure(IApplicationBuilder app, IConfiguration Configuration)
       {
           app.InitializeApplication();
           app.UseAuthorization();
           var filter = new BasicAuthAuthorizationFilter(new BasicAuthAuthorizationFilterOptions
       {
           SslRedirect = false,
           RequireSsl = false,
           LoginCaseSensitive = false,
           Users = new[]
           {
                       new BasicAuthAuthorizationUser
                       {
                           Login = Configuration["Hangfire:Login"] ,
                           PasswordClear= Configuration["Hangfire:PasswordClear"]
                       }
           }
       });
           app.UseHangfireDashboard("", new DashboardOptions
           {
               Authorization = new[]
               {
                  filter
               },
           });
           var jobOptions = new BackgroundJobServerOptions
           {
               Queues = new[] { "critical", "test", "default" },
               WorkerCount = Environment.ProcessorCount * int.Parse(Configuration["Hangfire:ProcessorCount"]),
               ServerName = Configuration["Hangfire:ServerName"],
               SchedulePollingInterval = TimeSpan.FromSeconds(1), //計劃輪詢間隔  支持任務到秒
           };
           app.UseHangfireServer(jobOptions);
       }
   }

設置

///
   /// 已完成的job設置過期，防止數(shù)據(jù)無限增長
   ///
   public class SucceededStateExpireHandler : IStateHandler
   {
       public TimeSpan JobExpirationTimeout;
       public SucceededStateExpireHandler(int jobExpirationTimeout)
       {
           JobExpirationTimeout = TimeSpan.FromMinutes(jobExpirationTimeout);
       }
       public string StateName => SucceededState.StateName;
       public void Apply(ApplyStateContext context, IWriteOnlyTransaction transaction)
       {
           context.JobExpirationTimeout = JobExpirationTimeout;
       }
       public void Unapply(ApplyStateContext context, IWriteOnlyTransaction transaction)
       {
       }
   }

以上就是Abp集成HangFire開源.NET任務調(diào)度框架的詳細內(nèi)容，更多關于Abp集成HangFire框架的資料請關注腳本之家其它相關文章！

您可能感興趣的文章:

asp.net Silverlight中的模式窗體
現(xiàn)在Web開發(fā)技術中流行著模式窗體，這種不用跳轉(zhuǎn)頁面又能夠滿足與用戶進行數(shù)據(jù)交互的手段確實不錯，那我今天也談談Silverlight中的模式窗體吧。
2009-11-11
VS2017做為Unity3D的腳本編輯器需要的最精簡組件
這篇文章主要為大家詳細介紹了VS2017做為Unity3D的腳本編輯器需要的最精簡組件，具有一定的參考價值，感興趣的小伙伴們可以參考一下
2017-04-04
vs2010無法添加dll引用的處理方法
vs2010無法添加dll引用的處理方法，需要的朋友可以參考一下
2013-03-03
詳解在ASP.NET Core下使用SignalR技術
本篇文章主要介紹了在ASP.NET Core下使用SignalR技術，小編覺得挺不錯的，現(xiàn)在分享給大家，也給大家做個參考。一起跟隨小編過來看看吧
2017-02-02
mvc form表單提交的幾種形式整理總結(jié)
這篇文章主要介紹了mvc form表單提交的幾種形式整理總結(jié)的相關資料,這里提供了幾種方法及實例代碼，需要的朋友可以參考下
2016-12-12
asp.net利用反射實現(xiàn)給model類賦值的方法
這篇文章主要介紹了asp.net利用反射實現(xiàn)給model類賦值的方法,結(jié)合實例形式分析了asp.net使用反射給model類賦值的操作步驟與相關操作技巧,需要的朋友可以參考下
2017-03-03
asp.net 仿微信端菜單設置實例代碼詳解
本文通過實例代碼給大家介紹了asp.net 仿微信端菜單設置方法，代碼簡單易懂，非常不錯，具有一定的參考借鑒價值 ,需要的朋友可以參考下
2018-11-11
ASP.NET Core新建項目教程（3）
這篇文章主要為大家詳細介紹了如何在Visual Studio中創(chuàng)建一個新項目，具有一定的參考價值，感興趣的小伙伴們可以參考一下
2017-06-06
Asp.net 時間操作基類(支持短日期,長日期,時間差)
支持短日期,長日期,時間差的操作基類，方便大家直接使用
2008-11-11
ASP.NET?MVC實現(xiàn)區(qū)域路由
這篇文章介紹了ASP.NET?MVC實現(xiàn)區(qū)域路由的方法，文中通過示例代碼介紹的非常詳細。對大家的學習或工作具有一定的參考借鑒價值，需要的朋友可以參考下
2022-03-03