MVC中使用Hangfire執行定時任務

需求描述

項目中有一個通知公告的功能，在後臺管理員添加公告後須要推送消息給全部註冊用戶，讓其查看消息。消息推送移動端採用極光推送，可是消息在什麼時候發送是個問題，好比說有一個重要的會議通知，可能但願在會議開始前半天進行提醒，僅僅使用後臺代碼處理起來可能比較麻煩，這時就須要考慮到使用做業來處理這種定時執行的業務。

在NET平臺，做業有不少方式，能夠diy一個系統做業，或者使用數據庫的做業功能寫一個定時執行，再有一種方案就是使用外部開源的定時任務系統來完成。

首先來講，採用系統DIY做業的方式。在不一樣平臺上都有相應的命令來支持這一操做，完成起來也不是很難，可是這樣的話應用程序會和系統高耦合，萬一想換系統或者換服務器，做業內容直接丟失，再者若是搞很差維護起來也比較麻煩。因此這個pass掉了

再者說數據庫，各大數據庫也都支持做業功能，sql server 或者mysql等。一樣面臨的問題 第一，不一樣數據庫命令不一致；第二，添加了做業之後在數據庫調整，好比數據庫服務遷移會致使做業中斷；還有一點，數據庫做業若是作定時數據更新，數據庫備份是比較不錯的選擇，都在持久層層面，與業務無關。可是若是牽扯到業務，那就有些麻煩了，想象一下，數據庫定時執行了一個郵件發送的任務，生成了一條郵件的記錄，而後通知IIS相關進程發送郵件，頗有些本末倒置的感受。

前二者其實各有各的使用場景，仍是那句話，技術沒有好壞，只有適合不適合。針對咱們的業務來講，發起於應用內，在應用內部解決是比較好的方案。這樣就須要第三個方案，集成一個定時任務的系統進來（或者本身寫一個，實話說真沒寫過不知道有大的工做量）。

NET平臺定時任務

net平臺開源的定時任務系統也有很多吧，比較知名的有Quartz.net、Hangfire等等。初次使用這些，選擇的時候以知足業務的同時簡單快速爲主，綜合看了一下，最後選擇Hangfire。一下是摘自園子關於兩者區別的部分 ：

與quartz.net對比

在項目沒有引入Hangfire以前，一直使用的是Quartz.net。我的認爲Quartz.net在定時任務處理方面優點以下：

• 支持秒級單位的定時任務處理，可是Hangfire只能支持分鐘及以上的定時任務處理

緣由在於Hangfire用的是開源的NCrontab組件，跟linux上的crontab指令類似。

• 更加複雜的觸發器，日曆以及任務調度處理

• 可配置的定時任務

可是爲何要換Hangfire? 很大的緣由在於項目須要一個後臺可監控的應用，不用每次都要從服務器拉取日誌查看，在沒有ELK的時候至關不方便。Hangfire控制面板不只提供監控，也能夠手動的觸發執行定時任務。若是在定時任務處理方面沒有很高的要求，好比必定要5s定時執行，Hangfire值得擁有。拋開這些，Hangfire優點太明顯了：

• 持久化保存任務、隊列、統計信息

• 重試機制

• 多語言支持

• 支持任務取消

• 支持按指定Job Queue處理任務

• 服務器端工做線程可控，即job執行併發數控制

• 分佈式部署，支持高可用

• 良好的擴展性，如支持IOC、Hangfire Dashboard受權控制、Asp.net Core、持久化存儲等

說了這麼多的優勢，咱們能夠有個案例，例如秒殺場景：用戶下單->訂單生成->扣減庫存，Hangfire對於這種分佈式的應用處理也是適用的，最後會給出實現。

想了解更多參見原文：Hangfire項目實踐分享

 

在MVC中使用Hangfire

下文中開發環境爲 Vs 2017，Net Framework 4.5+，數據庫爲sql server 2008 r2 （要求sql server 2008+）

1. 首先在項目使用nuget引入相關包

   項目上右鍵，管理Nuget程序包→瀏覽，輸入Hangfire,分別安裝Hangfire、Hangfire.core、Hangfire.Sqlserver；

   在安裝hangfire時會關聯安裝owin,若是不想引入Owin的話能夠去掉，在註冊服務的時候須要單獨處理

2. 右鍵當前項目，添加OWIN Startup類，在文件中編寫代碼

   以下

   //指定使用Sqlserver進行定時任務的持久化
               GlobalConfiguration.Configuration.UseSqlServerStorage("DefaultConnection"); //啓用服務
    app.UseHangfireServer(); //啓用Dashboard面板
               app.UseHangfireDashboard();

3. 在項目中進入Controller文件夾，在HomeController中添加代碼

   public ActionResult Index() { //支持基於隊列的任務處理：任務執行不是同步的，而是放到一個持久化隊列中，以便立刻把請求控制權返回給調用者。
               var jobId = BackgroundJob.Enqueue(() => WriteLog("隊列任務")); //延遲任務執行：不是立刻調用方法，而是設定一個將來時間點再來執行。
               BackgroundJob.Schedule(() => WriteLog("延時任務"), TimeSpan.FromSeconds(10)); //循環任務執行：一行代碼添加劇復執行的任務，其內置了常見的時間循環模式，也可基於CRON表達式來設定複雜的模式。
               RecurringJob.AddOrUpdate(() => WriteLog("每分鐘執行任務"), Cron.Minutely); //注意最小單位是分鐘 //延續性任務執行：相似於.NET中的Task,能夠在第一個任務執行完以後緊接着再次執行另外的任務
               BackgroundJob.ContinueWith(jobId, () => WriteLog("連續任務")); return View(); }

   WriteLog方法在控制檯輸出了一些當前的任務信息，實際業務中能夠作不少事情，發郵件提醒、更新數據等等

   public void WriteLog(string msg) { Debug.WriteLine($"Hangfire於{DateTime.Now}執行了任務[{msg}]"); }

4. F5運行程序，打開輸出視圖，看到以下內容

   到此爲止，Hangfire就已經可使用了，咱們打開數據庫

   能夠看到數據庫中增長了很多以HangFire起頭的表，這些表就是Hangfire相關持久化生成的表。

5. 回到瀏覽器，在當前瀏覽地址後輸入/hangfire ，訪問如下Hangfire的dashboard頁面，看一下任務的執行狀況

由於有一個間隔一分鐘循環執行的任務，截圖這麼一會的功夫，就已經執行了11次。在這個頁面中，能夠把已經執行的任務再次執行，能夠查看執行失敗的任務。

 

參考：

Hangfire項目實踐分享

HangFire任務調度實例（Console和MVC中）及Log4Net日誌配置