前言

很多时候，后台任务对我们来说是一个利器，帮我们在后面处理了成千上万的事情。

在.NET Framework时代，我们可能比较多的就是一个项目，会有一到多个对应的Windows服务，这些Windows服务就可以当作是我们所说的后台任务了。

我喜欢将后台任务分为两大类，一类是不停的跑，好比MQ的消费者,RPC的服务端。另一类是定时的跑，好比定时任务。

那么在.NET Core时代是不是有一些不同的解决方案呢？答案是肯定的。

Generic Host就是其中一种方案，也是本文的主角。

什么是Generic Host

Generic Host是ASP.NET Core 2.1中的新增功能，它的目的是将HTTP管道从Web Host的API中分离出来，从而启用更多的Host方案。

现在2.1版本的Asp.Net Core中，有了两种可用的Host。

Web Host –适用于托管Web程序的Host,就是我们所熟悉的在Asp.Net Core应用程序的Mai函数中用CreateWebHostBuilder创建出来的常用的WebHost。

Generic Host (ASP.NET Core 2.1版本才有) – 适用于托管非 Web 应用（例如，运行后台任务的应用）。 在未来的版本中，通用主机将适用于托管任何类型的应用，包括 Web 应用。 通用主机最终将取代 Web 主机，这大概也是这种类型的主机叫做通用主机的原因。

这样可以让基于Generic Host的一些特性延用一些基础的功能。如：如配置、依赖关系注入和日志等。

Generic Host更倾向于通用性，换句话就是说，我们即可以在Web项目中使用，也可以在非Web项目中使用！

虽然有时候后台任务混杂在Web项目中并不是一个太好的选择，但也并不失是一个解决方案。尤其是在资源并不充足的时候。

比较好的做法还是让其独立出来，让它的职责更加单一。

下面就先来看看如何创建后台任务吧。

后台任务示例

我们先来写两个后台任务(一个一直跑，一个定时跑)，体验一下这些后台任务要怎么上手，同样也是我们后面要使用到的。

这两个任务统一继承BackgroundService这个抽象类，而不是IHostedService这个接口。后面会说到两者的区别。

1、一直跑的后台任务

先上代码

public class PrinterHostedService2 : BackgroundService{ private readonly ILogger _logger; private readonly AppSettings _settings; public PrinterHostedService2(ILoggerFactory loggerFactory, IOptionsSnapshot<AppSettings> options) { this._logger = loggerFactory.CreateLogger<PrinterHostedService2>(); this._settings = options.Value; } public override Task StopAsync(CancellationToken cancellationToken) { _logger.LogInformation("Printer2 is stopped"); return Task.CompletedTask; } protected override async Task ExecuteAsync(CancellationToken stoppingToken) { while (!stoppingToken.IsCancellationRequested) { _logger.LogInformation($"Printer2 is working. {_settings.PrinterDelaySecond}"); await Task.Delay(TimeSpan.FromSeconds(_settings.PrinterDelaySecond), stoppingToken); } }}

来看看里面的细节。

我们的这个服务继承了BackgroundService，就一定要实现里面的ExecuteAsync，至于StartAsync和StopAsync等方法可以选择性的override。

我们ExecuteAsync在里面就是输出了一下日志，然后休眠在配置文件中指定的秒数。

这个任务可以说是最简单的例子了，其中还用到了依赖注入，如果想在任务中注入数据仓储之类的，应该就不需要再多说了。

同样的方式再写一个定时的。

定时跑的后台任务

这里借助了Timer来完成定时跑的功能，同样的还可以结合Quartz来完成。

public class TimerHostedService : BackgroundService{ //other ... private Timer _timer; protected override Task ExecuteAsync(CancellationToken stoppingToken) { _timer = new Timer(DoWork, null, TimeSpan.Zero, TimeSpan.FromSeconds(_settings.TimerPeriod)); return Task.CompletedTask; } private void DoWork(object state) { _logger.LogInformation("Timer is working"); } public override Task StopAsync(CancellationToken cancellationToken) { _logger.LogInformation("Timer is stopping"); _timer?.Change(Timeout.Infinite, 0); return base.StopAsync(cancellationToken); } public override void Dispose() { _timer?.Dispose(); base.Dispose(); }}

和第一个后台任务相比，没有太大的差异。

下面我们先来看看如何用控制台的形式来启动这两个任务。

控制台形式

这里会同时引入NLog来记录任务跑的日志，方便我们观察。

Main函数的代码如下：

class Program{ static async Task Main(string[] args) { var builder = new HostBuilder() //logging .ConfigureLogging(factory => { //use nlog factory.AddNLog(new NLogProviderOptions { CaptureMessageTemplates = true, CaptureMessageProperties = true }); NLog.LogManager.LoadConfiguration("nlog.config"); }) //host config .ConfigureHostConfiguration(config => { //command line if (args != null) { config.AddCommandLine(args); } }) //app config .ConfigureAppConfiguration((hostContext, config) => { var env = hostContext.HostingEnvironment; config.AddJsonFile("appsettings.json", optional: true, reloadOnChange: true) .AddJsonFile($"appsettings.{env.EnvironmentName}.json", optional: true, reloadOnChange: true); config.AddEnvironmentVariables(); if (args != null) { config.AddCommandLine(args); } }) //service .ConfigureServices((hostContext, services) => { services.AddOptions(); services.Configure<AppSettings>(hostContext.Configuration.GetSection("AppSettings")); //basic usage services.AddHostedService<PrinterHostedService2>(); services.AddHostedService<TimerHostedService>(); }) ; //console await builder.RunConsoleAsync(); ////start and wait for shutdown //var host = builder.Build(); //using (host) //{ // await host.StartAsync(); // await host.WaitForShutdownAsync(); //} }}

对于控制台的方式，需要我们对HostBuilder有一定的了解，虽说它和WebHostBuild有相似的地方。可能大部分时候，我们是直接使用了WebHost.CreateDefaultBuilder(args)来构造的，如果对CreateDefaultBuilder里面的内容没有了解，那么对上面的代码可能就不会太清晰。

上述代码的大致流程如下：

• new一个HostBuilder对象
• 配置日志，主要是接入了NLog
• Host的配置，这里主要是引入了CommandLine，因为需要传递参数给程序
• 应用的配置，指定了配置文件，和引入CommandLine
• Service的配置，这个就和我们在Startup里面写的差不多了，最主要的是我们的后台服务要在这里注入
• 启动

其中，

2-5的顺序可以按个人习惯来写，里面的内容也和我们写Startup大同小异。

第6步，启动的时候，有多种方式，这里列出了两种行为等价的方式。

a. 通过RunConsoleAsync的方式来启动

b. 先StartAsync然后再WaitForShutdownAsync

RunConsoleAsync的奥秘，我觉得还是直接看下面的代码比较容易懂。

/// <summary>/// Listens for Ctrl+C or SIGTERM and calls <see cref="IApplicationLifetime.StopApplication"/> to start the shutdown process./// This will unblock extensions like RunAsync and WaitForShutdownAsync./// </summary>/// <param name="hostBuilder">The <see cref="IHostBuilder" /> to configure.</param>/// <returns>The same instance of the <see cref="IHostBuilder"/> for chaining.</returns>public static IHostBuilder UseConsoleLifetime(this IHostBuilder hostBuilder){ return hostBuilder.ConfigureServices((context, collection) => collection.AddSingleton<IHostLifetime, ConsoleLifetime>());}/// <summary>/// Enables console support, builds and starts the host, and waits for Ctrl+C or SIGTERM to shut down./// </summary>/// <param name="hostBuilder">The <see cref="IHostBuilder" /> to configure.</param>/// <param name="cancellationToken"></param>/// <returns></returns>public static Task RunConsoleAsync(this IHostBuilder hostBuilder, CancellationToken cancellationToken = default){ return hostBuilder.UseConsoleLifetime().Build().RunAsync(cancellationToken);}

这里涉及到了一个比较重要的IHostLifetime，Host的生命周期，ConsoleLifeTime是默认的一个，可以理解成当接收到ctrl+c这样的指令时，它就会触发停止。

接下来，写一下nlog的配置文件

<?xml version="1.0" encoding="utf-8" ?><nlog xmlns="http://sumeRabbitMQHostedService>() ;

总结

Generic Host让我们可以用熟悉的方式来处理后台任务，不得不说这是一个很👍的特性。

无论是将后台任务独立一个项目，还是将其混搭在Web项目中，都已经符合不少应用的情景了。

最后放上本文用到的示例代码

GenericHostDemo

好了，以上就是这篇文章的全部内容了，希望本文的内容对大家的学习或者工作具有一定的参考学习价值，如果有疑问大家可以留言交流，谢谢大家对的支持。