新聞中心
本文轉(zhuǎn)載自微信公眾號「后端Q」,作者conan。轉(zhuǎn)載本文請聯(lián)系后端Q公眾號。

要求
Hangfire 適用于大多數(shù) .NET 平臺:.NET Framework 4.5 或更高版本、.NET Core 1.0 或更高版本,或任何與 .NET Standard 1.3 兼容的平臺。您可以將它與幾乎任何應(yīng)用程序框架集成,包括 ASP.NET、ASP.NET Core、控制臺應(yīng)用程序、Windows 服務(wù)、WCF,以及社區(qū)驅(qū)動的框架,如 Nancy 或 ServiceStack。
存儲
存儲是 Hangfire 保存與后臺作業(yè)處理相關(guān)的所有信息的地方。類型、方法名稱、參數(shù)等所有細(xì)節(jié)都被序列化并放入存儲中,沒有數(shù)據(jù)保存在進(jìn)程的內(nèi)存中。存儲子系統(tǒng)在 Hangfire 中被很好地抽象出來,可以為 RDBMS 和 NoSQL 解決方案實(shí)現(xiàn)。
這是您必須做出的主要決定,也是開始使用框架之前所需的唯一配置。以下示例顯示如何使用 SQL Server 數(shù)據(jù)庫配置 Hangfire。請注意,連接字符串可能會有所不同,具體取決于您的環(huán)境。
- GlobalConfiguration.Configuration
- .UseSqlServerStorage(@"Server=.\SQLEXPRESS; Database=Hangfire.Sample; Integrated Security=True");
客戶端
Client 負(fù)責(zé)創(chuàng)建后臺作業(yè)并將它們保存到 Storage 中。后臺作業(yè)是一個應(yīng)該在當(dāng)前執(zhí)行上下文之外執(zhí)行的工作單元,例如在后臺線程、其他進(jìn)程中,甚至在不同的服務(wù)器上——這一切都可以通過 Hangfire 實(shí)現(xiàn),即使沒有額外的配置。
- BackgroundJob.Enqueue(() => Console.WriteLine("Hello, world!"));
請注意,這不是委托,而是表達(dá)式樹。Hangfire 不是立即調(diào)用該方法,而是序列化類型 ( System.Console)、方法名稱 ( WriteLine,帶有所有參數(shù)類型以便稍后識別它) 和所有給定的參數(shù),并將其放入 Storage。
服務(wù)器
Hangfire Server 通過查詢存儲來處理后臺作業(yè)。粗略地說,它是一組后臺線程,它們偵聽 Storage 以獲取新的后臺作業(yè),并通過反序列化類型、方法和參數(shù)來執(zhí)行它們。
您可以將此后臺作業(yè)服務(wù)器放置在您想要的任何進(jìn)程中,包括像 ASP.NET 這樣的危險(xiǎn)進(jìn)程——即使您終止了一個進(jìn)程,您的后臺作業(yè)也會在重新啟動后自動重試。因此,在 Web 應(yīng)用程序的基本配置中,您不再需要使用 Windows 服務(wù)進(jìn)行后臺處理。
- using (new BackgroundJobServer())
- {
- Console.ReadLine();
- }
安裝
Hangfire 作為幾個 NuGet 包分發(fā),從主要的 Hangfire.Core 開始,它包含所有主要類和抽象。其他包如 Hangfire.SqlServer 提供功能或抽象實(shí)現(xiàn)。要開始使用 Hangfire,請安裝主軟件包并選擇可用的存儲空間之一。
Visual Studio 2017 發(fā)布后,出現(xiàn)了一種全新的 NuGet 包安裝方式。所以我放棄了列出安裝 NuGet 包的所有方法,并回退到使用該dotnet應(yīng)用程序幾乎在任何地方都可用的方法。
- dotnet add package Hangfire.Core
- dotnet add package Hangfire.SqlServer
配置
使用GlobalConfiguration類執(zhí)行配置。它的Configuration屬性提供了很多擴(kuò)展方法,既有來自 Hangfire.Core 的,也有來自其他包的。如果你安裝了一個新的包,不要猶豫,檢查是否有新的擴(kuò)展方法。
- GlobalConfiguration.Configuration
- .SetDataCompatibilityLevel(CompatibilityLevel.Version_170)
- .UseSimpleAssemblyNameTypeSerializer()
- .UseRecommendedSerializerSettings()
- .UseSqlServerStorage("Database=Hangfire.Sample; Integrated Security=True;", new SqlServerStorageOptions
- {
- CommandBatchMaxTimeout = TimeSpan.FromMinutes(5),
- SlidingInvisibilityTimeout = TimeSpan.FromMinutes(5),
- QueuePollInterval = TimeSpan.Zero,
- UseRecommendedIsolationLevel = true,
- UsePageLocksOnDequeue = true,
- DisableGlobalLocks = true
- })
- .UseBatches()
- .UsePerformanceCounters();
方法調(diào)用可以鏈接起來,因此不需要一次又一次地使用類名。全局配置是為了簡單起見,幾乎每個 Hangfire 類都允許您指定存儲、過濾器等的覆蓋。在 ASP.NET Core 環(huán)境中,全局配置類隱藏在AddHangfire方法中。
用法
以下是所有運(yùn)行中的 Hangfire 組件,作為打印“Hello, world!”的完整工作示例。來自后臺線程的消息。您可以注釋與服務(wù)器相關(guān)的行,并多次運(yùn)行該程序——只要您再次取消注釋這些行,就會處理所有后臺作業(yè)。
- using System;
- using Hangfire;
- using Hangfire.SqlServer;
- namespace ConsoleApplication2
- {
- class Program
- {
- static void Main()
- {
- GlobalConfiguration.Configuration
- .SetDataCompatibilityLevel(CompatibilityLevel.Version_170)
- .UseColouredConsoleLogProvider()
- .UseSimpleAssemblyNameTypeSerializer()
- .UseRecommendedSerializerSettings()
- .UseSqlServerStorage("Database=Hangfire.Sample; Integrated Security=True;", new SqlServerStorageOptions
- {
- CommandBatchMaxTimeout = TimeSpan.FromMinutes(5),
- SlidingInvisibilityTimeout = TimeSpan.FromMinutes(5),
- QueuePollInterval = TimeSpan.Zero,
- UseRecommendedIsolationLevel = true,
- UsePageLocksOnDequeue = true,
- DisableGlobalLocks = true
- });
- BackgroundJob.Enqueue(() => Console.WriteLine("Hello, world!"));
- using (var server = new BackgroundJobServer())
- {
- Console.ReadLine();
- }
- }
- }
- }
分享名稱:一篇文章帶你了解Hangfire
URL地址:http://www.5511xx.com/article/cocsecc.html


咨詢
建站咨詢
