最近有個需求是固定時間取得特定資料進行修改，在查詢相關資料之後決定使用 ASP.NET Core Generic Host 為出發，在搭配 .NET 中熱門的排程套件 Quartz.Net，測試完畢之後再將程式註冊為 Windows Service 服務就可滿足使用者的需求，這篇文章是整理開發時的重點流程為系列文，給有需要使用 ASP.NET Core 開發排程相關應用程式需求的朋友一些參考，若有問題或是錯誤的地方歡迎各位高手給予指導。
GenericHostLab SampleCode 傳送門 : http://bit.ly/2Y1mqYNGeneric Host
在過去處理 HTTP 請求時可以使用 WebHostBuilder 類別來處理，在開發 ASP.NET Core 應用程式設定及建立 WebHost 以及使用 Kestrel 服務接收請求並處理應用程式的生命週期，使用 DI 設定或配置 Logging 等重要功能，但並非所有的需求都依賴於 HTTP ，如 BackgroundService 背景執行程序或是處理 Queue 的資料等工作就不需要依賴於 HTTP 請求，從 ASP.NET Core 2.1 開始提供 Generic Host (泛型主機)，提供開發者可以有新的選項來開發沒有 HTTP 請求的應用程式，可以透過 MSDN 示意圖了解
CreateHostedBuilder
如果選擇 Generic Host 開發程式，建議先了解 WebHostBuilder 背後預設配置的設定方式以及做了哪些事情，在之前 ASP.NET Core 環境佈署設定 appsettings.json 文章中有介紹過，建立新的 ASP.NTE Core 應用程式預設模板可以看到在 program.cs 中內建 CreateWebHostBuilder ，此方法代碼中設定很多預設的配置，像是指定讀取資料夾中的 appsetting.json、環境變數、logging 設定、使用 Kestrel Server 等預設內容。了解 WebHostBuilder 是如何設定的也有了基本概念，就可以發現有部分內容在 HostBuilder 是可以共用的，就可以開始著手開發 Generic Host 程式，首先先建立新的 ASP.NET Core Console 專案，並開啟 Program.cs 建立 CreateHostBuilder 運算式，代碼如下
private static IHostBuilder CreateHostBuilder() =>
new HostBuilder()
.ConfigureHostConfiguration(configHost =>
{
// setup Host configuration
configHost.SetBasePath(Directory.GetCurrentDirectory())
.AddJsonFile("hostsettings.json", optional: true)
.AddEnvironmentVariables();
})
.ConfigureAppConfiguration((hostContext, configApp) =>
{
// setup App configuration
configApp.AddJsonFile("appsettings.json")
.AddJsonFile(
$"appsettings.{hostContext.HostingEnvironment.EnvironmentName}.json",
optional: true, reloadOnChange: true)
.AddEnvironmentVariables();
})
.ConfigureServices((services =>
{
services.Configure<HostOptions>(option =>
{
option.ShutdownTimeout = TimeSpan.FromSeconds(30);
});
}))
.ConfigureLogging((hostingContext, logging) =>
{
// Get Config from Logging section
logging.AddConfiguration(hostingContext.Configuration.GetSection("Logging"))
.AddEventLog();
if (hostingContext.HostingEnvironment.IsDevelopment())
{
logging.AddConsole();
}
});
在 CreateHostBuilder 中首先先建立一個 HostBuilder，命名空間為 Microsoft.Extensions.Hosting，透過 HostBuilder 來定義創建的主機後，定義以下幾件事情
Install-Package Microsoft.Extensions.Hosting -Version 2.2.0 Install-Package Microsoft.Extensions.Configuration.FileExtensions -Version 2.2.0 Install-Package Microsoft.Extensions.Configuration.Json -Version 2.2.0 Install-Package Microsoft.Extensions.Configuration.EnvironmentVariables -Version 2.2.0 Install-Package Microsoft.Extensions.Configuration.CommandLine -Version 2.2.0 Install-Package Microsoft.Extensions.Logging.Console -Version 2.2.0 Install-Package Microsoft.Extensions.Logging.Debug -Version 2.2.0 Install-Package Microsoft.Extensions.Logging.EventLog如果對於 WebHostBuilder 原理想了解更多，可以參考 andrewlock 文章 : HostBuilder v.s WebHostBuilder
TimeHotedService
下一步是建立 TimeHostedService 類別並實作 IHostedSercice 介面，IHostedService interface 中提供 StartAsync 和 StopAsync 方法，在 MSDN 提到 Start 是在 IApplicationLifetime.ApplicationStarted 觸發之後會接續執行，反之 Stop 是主機停止停止時會觸發，source code 如下
namespace Microsoft.Extensions.Hosting
{
//
// Summary:
// Defines methods for objects that are managed by the host.
public interface IHostedService
{
//
// Summary:
// Triggered when the application host is ready to start the service.
Task StartAsync(CancellationToken cancellationToken);
//
// Summary:
// Triggered when the application host is performing a graceful shutdown.
Task StopAsync(CancellationToken cancellationToken);
}
}
起手式我們可以先建立簡單的 HostedService 來驗證是否正常，如果正常了在把 Service 替換為我們想要的 Quartz.Net 實作內容，在這邊建立 TimeHostedService 類別主要功能是每秒 console 中顯示現在的時間，代碼如下namespace GenericHostLab.Service
{
internal class TimedHostedService : IHostedService, IDisposable
{
private readonly ILogger _logger;
private Timer _timer;
public TimedHostedService(ILogger<TimedHostedService> logger)
{
_logger = logger;
}
public Task StartAsync(CancellationToken cancellationToken)
{
_logger.LogInformation("Timed Background Service is starting.");
_timer = new Timer(DoWork, null, TimeSpan.Zero, TimeSpan.FromSeconds(1));
return Task.CompletedTask;
}
private void DoWork(object state)
{
_logger.LogInformation($"[{DateTime.Now:yyyy-MM-dd hh:mm:ss}] Timed Background Service is working.");
}
public Task StopAsync(CancellationToken cancellationToken)
{
_logger.LogInformation("Timed Background Service is stopping.");
_timer?.Change(Timeout.Infinite, 0);
return Task.CompletedTask;
}
public void Dispose()
{
_timer?.Dispose();
}
}
}
將 TimedHostedService 加入到 Service 中.ConfigureServices((hostContext, services) =>
{
// ...
services.AddHostedService<TimedHostedService>();
}
在 main 方法中直接使用 RunConsoleAync static async Task Main(string[] args)
{
try
{
var builder = CreateHostBuilder();
await builder.RunConsoleAsync();
}
catch (Exception e)
{
Console.WriteLine(e);
throw;
}
}
這邊需要注意的是由於 async 是 C# 7.1 開始支援的功能，因此如果專案預設編譯需要設定為使用 C# 7.1 來進行編譯，否則上面代碼可能會造成編譯錯誤，錯誤訊息為 : Feature 'default literal' is not available in C# 7.0. Please use language version 7.1 or greater.，解決方法只要去設定專案編譯 C# 版本即可，設定方式為 專案點選右鍵 > property > Advance 
參考
Creating a Quartz.NET hosted service with ASP.NET Core
.NET 泛型主機
Creating a Quartz.NET hosted service with ASP.NET Core
.NET 泛型主機
0 意見:
張貼留言