如何在 .Net Core 中使用 IHostedService
在我們應(yīng)用程序中常常會有一些執(zhí)行后臺任務(wù)和任務(wù)調(diào)度的需求，那如何在 ASP.Net Core 中實現(xiàn)呢？可以利用 Azure WebJobs 或者其他一些第三方任務(wù)調(diào)度框架，如：Quartz 和 Hangfire。
在 ASP.Net Core 中，也可以將 后臺任務(wù) 作為托管服務(wù)的模式，所謂的 托管服務(wù) 只需要實現(xiàn)框架中的 IHostedService 接口并囊括進你需要的業(yè)務(wù)邏輯作為后臺任務(wù)，這篇文章將會討論如何在 ASP.Net Core 中構(gòu)建托管服務(wù)。
創(chuàng)建托管服務(wù)
要想創(chuàng)建托管服務(wù)，只需要實現(xiàn) IHostedService 接口即可，下面就是 IHostedService 接口的聲明。
public?interface?IHostedService
{
????Task?StartAsync(CancellationToken?cancellationToken);
????Task?StopAsync(CancellationToken?cancellationToken);
}
這一節(jié)中我們在 ASP.Net Core 中做一個極簡版的 托管服務(wù), 首先自定義一個 MyFirstHostedService 托管類，代碼如下：
????public?class?MyFirstHostedService?:?IHostedService
????{
????????protected?async?override?Task?ExecuteAsync(CancellationToken?token)
????????{
????????????throw?new?NotImplementedException();
????????}
????}
創(chuàng)建 BackgroundService
有一點要注意，上一節(jié)的 MyFirstHostedService 實現(xiàn)了 IHostedService 接口，實際開發(fā)中并不需要這樣做，因為 .Net Core 中已經(jīng)提供了抽象類 BackgroundService，所以接下來重寫抽象類的 ExecuteAsync 方法即可，如下代碼所示：
????public?class?MyFirstHostedService?:?BackgroundService
????{
????????protected?async?override?Task?ExecuteAsync(CancellationToken?token)
????????{
????????????throw?new?NotImplementedException();
????????}
????}
下面的代碼片段展示了一個簡單的 Log 方法，用于記錄當(dāng)前時間到文件中，這個方法由 托管服務(wù) 觸發(fā)。
????????private?async?Task?Log()
????????{
????????????using?(StreamWriter?sw?=?new?StreamWriter(@"D:\log.txt",true))
????????????{
????????????????await?sw.WriteLineAsync(DateTime.Now.ToLongTimeString());
????????????}
????????}
使用 ExecuteAsync 方法
接下來看看如何實現(xiàn) ExecuteAsync 方法，這個方法的邏輯就是周期性（second/s）的調(diào)用 Log() 方法,如下代碼所示：
????protected?async?override?Task?ExecuteAsync(CancellationToken?token)
????{
????????while?(!token.IsCancellationRequested)
????????{
????????????await?Log();
????????????await?Task.Delay(1000,?token);
????????}
????}
好了，下面是完整的 MyFirstHostedService 類代碼，僅供參考。
using?Microsoft.Extensions.Hosting;
using?System;
using?System.IO;
using?System.Threading;
using?System.Threading.Tasks;
namespace?HostedServicesApp
{
????public?class?MyFirstHostedService?:?BackgroundService
????{
????????protected?async?override?Task?ExecuteAsync(CancellationToken?token)
????????{
????????????while?(!token.IsCancellationRequested)
????????????{
????????????????await?Log();
????????????????await?Task.Delay(1000,?token);
????????????}
????????}
????????private?async?Task?Log()
????????{
????????????using?(StreamWriter?sw?=?new?StreamWriter(@"D:\log.txt",true))
????????????{
????????????????await?sw.WriteLineAsync(DateTime.Now.ToLongTimeString());
????????????}
????????}
????}??
}
托管服務(wù)注冊
托管服務(wù)類已經(jīng)寫好了，要想注入到 Asp.NET Core 中，需要在 Startup.ConfigureServices 中將 托管服務(wù)類 注入到 ServiceCollection 中，如下代碼所示：
????public?void?ConfigureServices(IServiceCollection?services)
????{
????????services.AddHostedService();
????????services.AddMvc().SetCompatibilityVersion(CompatibilityVersion.Version_2_2);
????}?
當(dāng)把應(yīng)用程序跑起來后，你會看見程序每秒都會往 ?D:\log.txt 文件中記錄日志。
在 IHostedService 中提供的 StartAsync 和 StopAsync 可用于在 ASP.NET Core 中執(zhí)行或停止后臺任務(wù)，你可以用它在你的應(yīng)用程序中更新數(shù)據(jù)或其他操作，還有這些周期性業(yè)務(wù)邏輯是跑在后臺線程中的，這樣就不會導(dǎo)致主請求線程的阻塞。
譯文鏈接：https://www.infoworld.com/article/3390741/how-to-use-ihostedservice-in-aspnet-core.html