.NET Core基于Generic Host实现后台任务方法教程
前言
很多时候,后台任务对我们来说是一个利器,帮我们在后面处理了成千上万的事情。
在.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://www.nlog-project.org/schemas/nlog.xsd" xsi:schemalocation="nlog nlog.xsd" xmlns:xsi="http://www.w3.org/2001/xmlschema-instance" autoreload="true" internalloglevel="info" > <targets> <target xsi:type="file" name="ghost" filename="logs/ghost.log" layout="${date}|${level:uppercase=true}|${message}" /> </targets> <rules> <logger name="ghost.*" minlevel="info" writeto="ghost" /> <logger name="microsoft.*" minlevel="info" writeto="ghost" /> </rules> </nlog>
这个时候已经可以通过命令启动我们的应用了。
dotnet run -- --environment staging
这里指定了运行环境为staging,而不是默认的production。
在构造hostbuilder的时候,可以通过useenvironment或configurehostconfiguration直接指定运行环境,但是个人更加倾向于在启动命令中去指定,避免一些不可控因素。
这个时候大致效果如下:
虽然效果已经出来了,不过大家可能会觉得这个有点小打小闹,下面来个略微复杂一点的后台任务,用来监听并消费rabbitmq的消息。
消费mq消息的后台任务
public class comsumerabbitmqhostedservice : backgroundservice { private readonly ilogger _logger; private readonly appsettings _settings; private iconnection _connection; private imodel _channel; public comsumerabbitmqhostedservice(iloggerfactory loggerfactory, ioptionssnapshot<appsettings> options) { this._logger = loggerfactory.createlogger<comsumerabbitmqhostedservice>(); this._settings = options.value; initrabbitmq(this._settings); } private void initrabbitmq(appsettings settings) { var factory = new connectionfactory { hostname = settings.hostname, }; _connection = factory.createconnection(); _channel = _connection.createmodel(); _channel.exchangedeclare(_settings.exchangename, exchangetype.topic); _channel.queuedeclare(_settings.queuename, false, false, false, null); _channel.queuebind(_settings.queuename, _settings.exchangename, _settings.routingkey, null); _channel.basicqos(0, 1, false); _connection.connectionshutdown += rabbitmq_connectionshutdown; } protected override task executeasync(cancellationtoken stoppingtoken) { stoppingtoken.throwifcancellationrequested(); var consumer = new eventingbasicconsumer(_channel); consumer.received += (ch, ea) => { var content = system.text.encoding.utf8.getstring(ea.body); handlemessage(content); _channel.basicack(ea.deliverytag, false); }; consumer.shutdown += onconsumershutdown; consumer.registered += onconsumerregistered; consumer.unregistered += onconsumerunregistered; consumer.consumercancelled += onconsumerconsumercancelled; _channel.basicconsume(_settings.queuename, false, consumer); return task.completedtask; } private void handlemessage(string content) { _logger.loginformation($"consumer received {content}"); } private void onconsumerconsumercancelled(object sender, consumereventargs e) { ... } private void onconsumerunregistered(object sender, consumereventargs e) { ... } private void onconsumerregistered(object sender, consumereventargs e) { ... } private void onconsumershutdown(object sender, shutdowneventargs e) { ... } private void rabbitmq_connectionshutdown(object sender, shutdowneventargs e) { ... } public override void dispose() { _channel.close(); _connection.close(); base.dispose(); } }
代码细节就不需要多说了,下面就启动mq发送程序来模拟消息的发送
同时看我们任务的日志输出
由启动到停止,效果都是符合我们预期的。
下面再来看看web形式的后台任务是怎么处理的。
web形式
这种模式下的后台任务,其实就是十分简单的了。
我们只要在startup的configureservices方法里面注册我们的几个后台任务就可以了。
public void configureservices(iservicecollection services) { services.addmvc().setcompatibilityversion(compatibilityversion.version_2_1); services.addhostedservice<printerhostedservice2>(); services.addhostedservice<timerhostedservice>(); services.addhostedservice<comsumerabbitmqhostedservice>(); }
启动web站点后,我们发了20条mq消息,再访问了一下web站点的首页,最后是停止站点。
下面是日志结果,都是符合我们的预期。
可能大家会比较好奇,这三个后台任务是怎么混合在web项目里面启动的。
答案就在下面的两个链接里。
https://github.com/aspnet/hosting/blob/2.1.1/src/microsoft.aspnetcore.hosting/internal/webhost.cs
https://github.com/aspnet/hosting/blob/2.1.1/src/microsoft.aspnetcore.hosting/internal/hostedserviceexecutor.cs
上面说了那么多,都是在本地直接运行的,可能大家会比较关注这个要怎样部署,下面我们就不看看怎么部署。
部署
部署的话,针对不同的情形(web和非web)都有不同的选择。
正常来说,如果本身就是web程序,那么平时我们怎么部署的,就和平时那样部署即可。
花点时间讲讲部署非web的情形。
其实这里的部署等价于让程序在后台运行。
在linux下面让程序在后台运行方式有好多好多,supervisor、screen、pm2、systemctl等。
这里主要介绍一下systemctl,同时用上面的例子来进行部署,由于个人服务器没有mq环境,所以没有启用消费mq的后台任务。
先创建一个 service 文件
vim /etc/systemd/system/ghostdemo.service
内容如下:
[unit] description=generic host demo [service] workingdirectory=/var/www/ghost execstart=/usr/bin/dotnet /var/www/ghost/consoleghost.dll --environment staging killsignal=sigint syslogidentifier=ghost-example [install] wantedby=multi-user.target
其中,各项配置的含义可以自行查找,这里不作说明。
然后可以通过下面的命令来启动和停止这个服务
service ghostdemo start service ghostdemo stop
测试无误之后,就可以设为自启动了。
systemctl enable ghostdemo.service
下面来看看运行的效果
我们先启动服务,然后去查看实时日志,可以看到应用的日志不停的输出。
当我们停了服务,再看实时日志,就会发现我们的两个后台任务已经停止了,也没有日志再进来了。
再去看看服务系统日志
sudo journalctl -fu ghostdemo.service
发现它确实也是停了。
在这里,我们还可以看到服务的当前环境和根路径。
ihostedservice和backgroundservice的区别
前面的所有示例中,我们用的都是backgroundservice,而不是ihostedservice。
这两者有什么区别呢?
可以这样简单的理解,ihostedservice是原料,backgroundservice是一个用原料加工过一部分的半成品。
这两个都是不能直接当成成品来用的,都需要进行加工才能做成一个可用的成品。
同时也意味着,如果使用ihostedservice可能会需要做比较多的控制。
基于前面的打印后台任务,在这里使用ihostedservice来实现。
如果我们只是纯綷的把实现代码放到startasync方法中,那么可能就会有惊喜了。
public class printerhostedservice : ihostedservice, idisposable { //other .... public async task startasync(cancellationtoken cancellationtoken) { while (!cancellationtoken.iscancellationrequested) { console.writeline("printer is working."); await task.delay(timespan.fromseconds(_settings.printerdelaysecond), cancellationtoken); } } public task stopasync(cancellationtoken cancellationtoken) { console.writeline("printer is stopped"); return task.completedtask; } }
运行之后,想用ctrl+c来停止,发现还是一直在跑。
ps一看,这个进程还在,kill掉之后才不会继续输出。。
问题出在那里呢?原因其实还是比较明显的,因为这个任务还没有启动成功,一直处于启动中的状态!
换句话说,startasync方法还没有执行完。这个问题一定要小心再小心。
要怎么处理这个问题呢?解决方法也比较简单,可以通过引用一个变量来记录要运行的任务,将其从startasync方法中解放出来。
public class printerhostedservice3 : ihostedservice, idisposable { //others ..... private bool _stopping; private task _backgroundtask; public task startasync(cancellationtoken cancellationtoken) { console.writeline("printer3 is starting."); _backgroundtask = backgroundtask(cancellationtoken); return task.completedtask; } private async task backgroundtask(cancellationtoken cancellationtoken) { while (!_stopping) { await task.delay(timespan.fromseconds(_settings.printerdelaysecond),cancellationtoken); console.writeline("printer3 is doing background work."); } } public task stopasync(cancellationtoken cancellationtoken) { console.writeline("printer3 is stopping."); _stopping = true; return task.completedtask; } public void dispose() { console.writeline("printer3 is disposing."); } }
这样就能让这个任务真正的启动成功了!效果就不放图了。
相对来说,backgroundservice用起来会比较简单,实现核心的executeasync这个抽象方法就差不多了,出错的概率也会比较低。
ihostbuilder的扩展写法
在注册服务的时候,我们还可以通过编写ihostbuilder的扩展方法来完成。
public static class extensions { public static ihostbuilder usehostedservice<t>(this ihostbuilder hostbuilder) where t : class, ihostedservice, idisposable { return hostbuilder.configureservices(services => services.addhostedservice<t>()); } public static ihostbuilder usecomsumerabbitmq(this ihostbuilder hostbuilder) { return hostbuilder.configureservices(services => services.addhostedservice<comsumerabbitmqhostedservice>()); } }
使用的时候就可以像下面一样。
var builder = new hostbuilder() //others ... .configureservices((hostcontext, services) => { services.addoptions(); services.configure<appsettings>(hostcontext.configuration.getsection("appsettings")); //basic usage //services.addhostedservice<printerhostedservice2>(); //services.addhostedservice<timerhostedservice>(); //services.addhostedservice<comsumerabbitmqhostedservice>(); }) //extensions usage .usecomsumerabbitmq() .usehostedservice<timerhostedservice>() .usehostedservice<printerhostedservice2>() //.usehostedservice<comsumerabbitmqhostedservice>() ;
总结
generic host让我们可以用熟悉的方式来处理后台任务,不得不说这是一个很????的特性。
无论是将后台任务独立一个项目,还是将其混搭在web项目中,都已经符合不少应用的情景了。
最后放上本文用到的示例代码
好了,以上就是这篇文章的全部内容了,希望本文的内容对大家的学习或者工作具有一定的参考学习价值,如果有疑问大家可以留言交流,谢谢大家对的支持。
下一篇: JS实现音乐钢琴特效
推荐阅读
-
.NET Core利用skiasharp文字头像生成方法教程(基于docker发布)
-
.net core 基于Hangfire+Mysql持久化实现定时任务配置方法
-
.NET Core基于Generic Host实现后台任务方法教程
-
详解ASP.NET Core 中基于工厂的中间件激活的实现方法
-
基于.net core微服务的另一种实现方法
-
.NET Core利用skiasharp文字头像生成方法教程(基于docker发布)
-
.net core 基于Hangfire+Mysql持久化实现定时任务配置方法
-
.NET Core基于Generic Host实现后台任务方法教程
-
基于.net core微服务的另一种实现方法
-
详解ASP.NET Core 中基于工厂的中间件激活的实现方法