開源的.NET定時任務元件Hangfire解析

   項目慢慢就要開工了，很多園友都在問這個事情，看來大夥對這事很上心啊，事情需要一步步的來，盡量寫出一個我們都滿意的項目。以前每次在部落格前面都會扯淡一下，不過很多人都抱怨這樣做不好，加上我這人扯淡起來就停不住，有時候還會很感性的說出一些話，是以以後寫博文盡量少扯淡。（如果博文有不足之處，還望多多指正，我也會及時的修改，如果隻是單純的刷存在感，說一些過激的話，那我就不怎麼高興了）

   項目中很多時候都會使用到定時任務這樣一個功能需求，在.NET中對于完成定時任務的技術還是不怎麼多的，.NET Framework具有“内置”定時器功能，通過System.Timers.Timer類。在使用Timer類需要面對的問題：計時器沒有持久化機制；計時器具有不靈活的計劃（僅能設定開始時間和重複間隔，沒有基于日期，時間等）；計時器不使用線程池（每個定時器一個線程）；計時器沒有真正的管理方案 - 你必須編寫自己的機制，以便能夠記住，組織和檢索任務的名稱等。如果需要在.NET實作定時器的功能，可以嘗試使用以下這款開源免費的元件Quartz.Net元件。

  上面介紹了兩種方式，在這裡就介紹另外一種元件，那就是Hangfire元件。

一.Hangfire元件概述

    在.NET和.NET Core應用程式中執行背景處理的簡單方法。無需Windows服務或單獨的程序。由持久存儲支援,存儲方式有sqlserver、redis，mongodb等等。Hangfire支援所有類型的背景任務 - 短時間運作和長時間運作，CPU密集型和I / O密集型，一次性和周期性。

   1.元件特點：

   2.元件功能：

      上面是對Hangfire元件背景的一些簡單介紹，下面我們具體來了解一下Hangfire元件的使用方法。

二.Hangfire元件使用方法介紹

      既然想要學習了解一個元件，當然需要知道是怎麼樣取使用，如果不能使用，學着也沒有什麼很大的用處，下面介紹一下Hangfire元件的一些常用方法。

    1.ASP.NET MVC設定方式：

public void Configuration(IAppBuilder app)
{
    GlobalConfiguration.Configuration.UseSqlServerStorage("<connection string or its name>");
    app.UseHangfireDashboard();
    app.UseHangfireServer();
}      

GlobalConfiguration

類是配置Hangfire的首選方式。這是一些方法的入口點，包括來自第三方存儲實作或其他擴充的方法。用法很簡單，隻需

Hangfire

在應用程式初始化類中包含命名空間，并發現

GlobalConfiguration.Configuration

屬性的擴充方法

   2.控制台設定方式：

GlobalConfiguration.Configuration
                .UseColouredConsoleLogProvider()               
　　　　　　　　　 .UseSqlServerStorage(@"Server=.\sqlexpress;Database=Hangfire.Sample;Trusted_Connection=True;")
                .UseMsmqQueues(@".\Private$\hangfire{0}", "default", "critical");      

    3.基于隊列的任務處理：

var jobId = BackgroundJob.Enqueue(
    () => Console.WriteLine("Fire-and-forget!"));      

    4.延遲任務執行：

var jobId = BackgroundJob.Schedule(
    () => Console.WriteLine("Delayed!"),
    TimeSpan.FromDays(7));      

    5.循環任務執行：

RecurringJob.AddOrUpdate(
    () => Console.WriteLine("Recurring!"),
    Cron.Daily);      

    6.繼續在其父作業完成時執行：

BackgroundJob.ContinueWith(
    jobId,
    () => Console.WriteLine("Continuation!"));      

    7.批處理方法：

var batchId = BatchJob.StartNew(x =>
{
    x.Enqueue(() => Console.WriteLine("Job 1"));
    x.Enqueue(() => Console.WriteLine("Job 2"));
});      

    8.當父批次中的所有背景作業完成時，批處理繼續：

BatchJob.ContinueWith(batchId, x =>
{
    x.Enqueue(() => Console.WriteLine("Last Job"));
});      

    9.使用IoC容器：

public  class  ContainerJobActivator  ： JobActivator 
{ 
    private  IContainer  _container ;
    public  ContainerJobActivator （IContainer  container ）
    { 
        _container  =  container ; 
    }}
    public  override  object  ActivateJob （Type  type ）
    { 
        return  _container 。Resolve （type ）; 
    } 
}      

    在啟動Hangfire伺服器之前将其注冊為目前作業啟動器。

var container = new Container();
GlobalConfiguration.Configuration.UseActivator(new ContainerJobActivator(container));
...
app.UseHangfireServer();      

      Hangfire将作業儲存到持久存儲中，并以可靠的方式處理它們。這意味着你可以中止Hangfire工作線程，解除安裝應用程式域甚至終止程序，工作将被處理。Hangfire将作業标記為已完成，隻有當代碼的最後一行執行，并知道作業可能會失敗，最後一行。它包含不同的自動重試功能，可以處理代碼中的存儲錯誤或錯誤。

三.Hangfire元件核心對象解析

   上面介紹了Hangfire元件的常用方法，Hangfire元件的功能非常多，這裡就做介紹了，有興趣可以去官網進行檢視api。下面介紹一下Hangfire元件的一些核心對象，初探Hangfire元件深層次的問題。

   1.RecurringJob.AddOrUpdate()：

public static void AddOrUpdate(
            Expression<Action> methodCall,
            string cronExpression,
            TimeZoneInfo timeZone = null,
            string queue = EnqueuedState.DefaultQueue)
        {
            var job = Job.FromExpression(methodCall);
            var id = GetRecurringJobId(job);

            Instance.Value.AddOrUpdate(id, job, cronExpression, timeZone ?? TimeZoneInfo.Utc, queue);
        }      

   該方法用于定期作業在指定的CRON計劃上觸發多次。該方法具有16個重載，Job.FromExpression(methodCall);用于擷取基于Job類的新執行個體給定的方法調用的表達式樹。GetRecurringJobId(job)方法根據Job對象擷取對應的JobID。

   2.BackgroundJob.Enqueue()：

public static string Enqueue([NotNull, InstantHandle] Expression<Action> methodCall)
        {
            var client = ClientFactory();
            return client.Enqueue(methodCall);
        }      

   該方法基于給定的方法調用表達式建立一個新的fire-and-forget作業。該方法接受一個參數，表示将被編組到伺服器的方法調用表達式。接下來我們看一下var client = ClientFactory();方法的具體實作

internal static Func<IBackgroundJobClient> ClientFactory
        {
            get
            {
                lock (ClientFactoryLock)
                {
                    return _clientFactory ?? DefaultFactory;
                }
            }
            set
            {
                lock (ClientFactoryLock)
                {
                    _clientFactory = value;
                }
            }
        }      

   該屬性定義了一個Func<IBackgroundJobClient>的泛型委托。該屬性是一個可讀可寫的操作，對ClientFactoryLock加鎖，確定不發生死鎖情況。

四.總結

    上面簡單的介紹了Hangfire元件的背景和一些簡單的應用，也着重的介紹了一些對象。這個元件的功能很強大，需要了解的地方也較多，這一篇文章不可能全部介紹，用做抛磚引玉的作用。在這裡吐槽一句，微軟最近技術發展太快，很多技術還沒有來得及發展，就有新的技術出來，讓我們這些底層的人着實難受，事物發展有規律，不是以前缺的東西可以在很短的時間就可以補上，還是需要留下足夠的空間。

愛知求真，靜心鑽研，虛心學習，務實創新，細緻平和。