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運行程序,打開輸出視圖,看到如下內容QQ截圖20180129160059

    到此為止,Hangfire就已經可以使用了,我們打開數據庫

    image 可以看到數據庫中增加了不少以HangFire起頭的表,這些表就是Hangfire相關持久化生成的表。

  5. 回到瀏覽器,在當前瀏覽地址后輸入/hangfire ,訪問以下Hangfire的dashboard頁面,看一下任務的執行情況

image

image

因為有一個間隔一分鍾循環執行的任務,截圖這么一會的功夫,就已經執行了11次。在這個頁面中,可以把已經執行的任務再次執行,可以查看執行失敗的任務。

 

參考:

Hangfire項目實踐分享

HangFire任務調度實例(Console和MVC中)及Log4Net日志配置


免責聲明!

本站轉載的文章為個人學習借鑒使用,本站對版權不負任何法律責任。如果侵犯了您的隱私權益,請聯系本站郵箱yoyou2525@163.com刪除。



 
粵ICP備18138465號   © 2018-2025 CODEPRJ.COM