谈谈.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方案。

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

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

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

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

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

后台任务示例

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

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

  1. 一直跑的后台任务

先上代码

640?wx_fmt=png

来看看里面的细节。

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

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

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

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

  1. 定时跑的后台任务

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

640?wx_fmt=png

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

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

控制台形式

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

Main函数的代码如下:

640?wx_fmt=png

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

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

  1. new一个HostBuilder对象

  2. 配置日志,主要是接入了NLog

  3. Host的配置,这里主要是引入了CommandLine,因为需要传递参数给程序

  4. 应用的配置,指定了配置文件,和引入CommandLine

  5. Service的配置,这个就和我们在Startup里面写的差不多了,最主要的是我们的后台服务要在这里注入

  6. 启动

其中,

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

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

a. 通过RunConsoleAsync的方式来启动

b. 先StartAsync然后再WaitForShutdownAsync

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

640?wx_fmt=png

这里涉及到了一个比较重要的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直接指定运行环境,但是个人更加倾向于在启动命令中去指定,避免一些不可控因素。

这个时候大致效果如下:

640?wx_fmt=png

虽然效果已经出来了,不过大家可能会觉得这个有点小打小闹,下面来个略微复杂一点的后台任务,用来监听并消费RabbitMQ的消息。

消费MQ消息的后台任务

640?wx_fmt=png

代码细节就不需要多说了,下面就启动MQ发送程序来模拟消息的发送

640?wx_fmt=png

同时看我们任务的日志输出

640?wx_fmt=png

由启动到停止,效果都是符合我们预期的。

下面再来看看Web形式的后台任务是怎么处理的。

Web形式

这种模式下的后台任务,其实就是十分简单的了。

我们只要在Startup的ConfigureServices方法里面注册我们的几个后台任务就可以了。

640?wx_fmt=png

启动Web站点后,我们发了20条MQ消息,再访问了一下Web站点的首页,最后是停止站点。

下面是日志结果,都是符合我们的预期。

640?wx_fmt=png

可能大家会比较好奇,这三个后台任务是怎么混合在Web项目里面启动的。

答案就在下面的两个链接里。

https://github.com/aspnet/Hosting/blob/2.1.1/src/Microsoft.AspNetCore.Hosting/Internal/WebHost.cs#L153

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

下面来看看运行的效果

640?wx_fmt=png

我们先启动服务,然后去查看实时日志,可以看到应用的日志不停的输出。

当我们停了服务,再看实时日志,就会发现我们的两个后台任务已经停止了,也没有日志再进来了。

再去看看服务系统日志

sudo journalctl -fu ghostdemo.service

640?wx_fmt=png

发现它确实也是停了。

在这里,我们还可以看到服务的当前环境和根路径。

IHostedService和BackgroundService的区别

前面的所有示例中,我们用的都是BackgroundService,而不是IHostedService。

这两者有什么区别呢?

可以这样简单的理解,IHostedService是原料,BackgroundService是一个用原料加工过一部分的半成品

这两个都是不能直接当成成品来用的,都需要进行加工才能做成一个可用的成品。

同时也意味着,如果使用IHostedService可能会需要做比较多的控制。

基于前面的打印后台任务,在这里使用IHostedService来实现。

如果我们只是纯綷的把实现代码放到StartAsync方法中,那么可能就会有惊喜了。

640?wx_fmt=png

运行之后,想用ctrl+c来停止,发现还是一直在跑。

640?wx_fmt=png

ps一看,这个进程还在,kill掉之后才不会继续输出。。

640?wx_fmt=png

问题出在那里呢?原因其实还是比较明显的,因为这个任务还没有启动成功,一直处于启动中的状态!

换句话说,StartAsync方法还没有执行完。这个问题一定要小心再小心。

要怎么处理这个问题呢?解决方法也比较简单,可以通过引用一个变量来记录要运行的任务,将其从StartAsync方法中解放出来。

640?wx_fmt=png

这样就能让这个任务真正的启动成功了!效果就不放图了。

相对来说,BackgroundService用起来会比较简单,实现核心的ExecuteAsync这个抽象方法就差不多了,出错的概率也会比较低。

IHostBuilder的扩展写法

在注册服务的时候,我们还可以通过编写IHostBuilder的扩展方法来完成。

640?wx_fmt=png

使用的时候就可以像下面一样。

640?wx_fmt=png

总结

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

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

最后放上本文用到的示例代码 https://github.com/catcherwong/Demos/tree/master/src/GenericHostDemo 

相关文章:

  • 在.NET Core微服务中使用HostBuilder和Generic Host

  • Asp.net Core 2.1新功能Generic Host(通用主机)深度学习

  • ASP.NET Core 2.1 : 十一. 如何在后台运行一个任务

  • .NET Core开源组件:后台任务利器之Hangfire

  • Quartz.Net分布式任务管理平台(第二版)

  • Asp.Net Core 使用Quartz基于界面画接口管理做定时任务

  • .Net Core小技巧 - Hosted Services + Quartz实现定时任务调度


原文地址: https://www.cnblogs.com/catcher1994/p/9961228.html


.NET社区新闻,深度好文,欢迎访问公众号文章汇总 http://www.csharpkit.com

640?wx_fmt=jpeg

本文来自互联网用户投稿,该文观点仅代表作者本人,不代表本站立场。本站仅提供信息存储空间服务,不拥有所有权,不承担相关法律责任。如若转载,请注明出处:http://www.mzph.cn/news/318983.shtml

如若内容造成侵权/违法违规/事实不符,请联系多彩编程网进行投诉反馈email:809451989@qq.com,一经查实,立即删除!

相关文章

P3971-[TJOI2014]Alice and Bob【贪心】

正题 题目链接:https://www.luogu.com.cn/problem/P3971 题目大意 一个1∼n1\sim n1∼n的一个排列&#xff0c;设aia_iai​表示以iii结尾的最长上升子序列长度&#xff0c;bib_ibi​表示以iii开头的最长下降子序列长度。 给出序列aaa求序列bbb的最大和。 1≤n≤1051\leq n\l…

牛客题霸 [平衡二叉树] C++题解/答案

牛客题霸 [平衡二叉树] C题解/答案 题目描述 输入一棵二叉树&#xff0c;判断该二叉树是否是平衡二叉树。 在这里&#xff0c;我们只需要考虑其平衡性&#xff0c;不需要考虑其是不是排序二叉树 题解&#xff1a; 今天上数据结构刚考了平衡二叉树 平衡二叉树定义(AVL)&…

2018 KubeCon + CloudNativeCon完美落幕,行云献力

2018年11月13-15日&#xff0c;由云原生计算基金会&#xff08;CNCF&#xff09;组织的KubeConCloudNativeCon首次登陆中国。经过了三天的技术交流和展示&#xff0c;大会随着15日下午最后一个议程的结束而完美落幕。作为云原生领域全球最大的峰会&#xff0c;KubeConCloudNati…

atcoder E - Greedy Ant(最优解等价+dp)

E - Greedy Ant Grice题解最开始看不懂神的思路&#xff0c;还评论请教了一波应该是个集训队大佬QaQ snuke在当前轮直接选取&#xff0c;那么状态会非常不好记录 我们保留snuke在之前轮&#xff0c;选择放弃暂时不选的次数&#xff0c;然后等蚂蚁走到这来了再选 虽然这个跟原游…

P4884-多少个1?【BSGS】

正题 题目链接:https://www.luogu.com.cn/problem/P4884 题目大意 求一个最小的nnn使得nnn个连续的111其在模mmm意义下等于kkk。 6≤m≤1011,0<k<m6\leq m\leq 10^{11},0<k<m6≤m≤1011,0<k<m 解题思路 补一道老题 nnn个连续的111就是10n−19\frac{10^n-1…

牛客题霸 [进制转换] C++题解/答案

进制转换 题目描述 给定一个十进制数M&#xff0c;以及需要转换的进制数N。将十进制数M转化为N进制数 题解&#xff1a; 看似简单的进制转换套路非常多 1.M是32位整数&#xff0c;有可能是负数&#xff0c;所以还要特判一下 2.N的范围是[2,16]&#xff0c;大于10要用ABCD来…

魔方Newlife.Cube权限系统的使用及模版覆盖详解

讲人&#xff1a;大石头时间&#xff1a;2018-11-14 晚上20&#xff1a;00地点&#xff1a;钉钉群&#xff08;组织代码BKMV7685&#xff09;QQ群&#xff1a;1600800内容&#xff1a;魔方Newlife.Cube权限系统的使用及模版覆盖详解准备源码地址: https://github.com/NewLifeX/…

P4383 [八省联考2018]林克卡特树(树形dp+wqs二分)

[八省联考2018]林克卡特树 题目大意&#xff1a;给定一棵有负权边的树&#xff0c;现在必须恰好删去kkk条边&#xff0c;并加上恰好kkk条权值为000的边&#xff0c;要求最大化它的直径长度。 首先考虑删去KKK条边的效果&#xff1a;把整棵树变成k1k1k1个连通块 然后用0权变把这…

bzoj4025-二分图【线段树分治,并查集】

正题 题目链接:https://darkbzoj.tk/problem/4025 题目大意 nnn个点mmm条边&#xff0c;每条边会在一个TTT以内的时间段内出现&#xff0c;对于任意一个TTT以内的时刻求图是否是一个二分图。 1≤n,T≤105,1≤m≤21051\leq n,T\leq 10^5,1\leq m\leq 2\times 10^51≤n,T≤105,1…

牛客题霸 [删除有序链表中重复的元素] C++题解/答案

牛客题霸 [删除有序链表中重复的元素] C题解/答案 题目描述 删除给出链表中的重复元素&#xff08;链表中元素从小到大有序&#xff09;&#xff0c;使链表中的所有元素都只出现一次 例如&#xff1a; 给出的链表为1\to1\to21→1→2,返回1 \to 21→2. 给出的链表为1\to1\to 2 \…

我在微软做研发 | 亚洲创新的科研之力

丹棱君有话说&#xff1a;在庆祝微软亚洲研究院成立 20 周年之际&#xff0c;微软亚洲研究院的几位科学家向我们讲述了在这里&#xff0c;如何以科研热情推动了技术创新。走进微软亚洲研究院的办公园区&#xff0c;便会被这里安静的研究氛围所包围。在当今越来越多追求速度、提…

codeforces1208 F. Bits And Pieces(SOS DP)

heyuhhh高维前缀和总结 SOS DP SOS Dynamic Programming [Tutorial] 之前写过相关的题目枚举子集dp 枚举子集 F[mask]∑i∈maskA[i],i&maskiF[mask]\sum_{i\in mask}A[i],i\&maskiF[mask]i∈mask∑​A[i],i&maski 方法1&#xff0c;O(4n)O(4^n)O(4n)暴力枚举 for(…

P5956-[POI2017]Podzielno【数学】

正题 题目链接:https://www.luogu.com.cn/problem/P5956 题目大意 BBB进制下&#xff0c;给出序列aaa&#xff0c;aia_iai​表示数字iii有多少个。求一个最大的XXX在BBB进制下&#xff0c;由给出的数字组成&#xff08;不一定要用完&#xff09;&#xff0c;且其是B−1B-1B−1…

牛客题霸 [回文数字(palindrome-number)] C++题解/答案

牛客题霸 [回文数字] C题解/答案 题解: 首先&#xff1a;负数不可以回文&#xff08;起码看着就不对称&#xff09; 然后我们将x翻转&#xff0c;很简单sumsum*10x%10; 因为x最终会变成0&#xff0c;所以用y先存一下x 最后比较sum与y是否相等 面试&#xff1a; class Solut…

codeforces1494 D. Dogeforces(构造)

昨晚1h20min做完了3个题&#xff0c;看下排名600左右&#xff0c;感觉稳可以上分了&#xff0c;于是看了下D构造&#xff1f;感觉不太会没细想于是看了看E感觉好像和之前有一个题目很像&#xff08;那个题我讨论了好长时间&#xff09;&#xff0c;然后磨叽磨叽还有20min感觉写…

P4126-[AHOI2009]最小割【网络流,tarjan】

正题 题目链接:https://www.luogu.com.cn/problem/P4126 题目大意 给出nnn个点mmm条边的一张有向图和起点终点。对于每条边求其是否是最小割的可行割/必须割 1≤n≤4000,1≤m≤600001\leq n\leq 4000,1\leq m\leq 600001≤n≤4000,1≤m≤60000 解题思路 一些结论吧&#xff…

调试.NET CORE代码

前言core也用了很长一段时间了&#xff0c;发现很多小伙伴不知道如何调试core的代码。可想而知&#xff0c;以前使用mvc的时候&#xff0c;不需要发布代码&#xff0c;直接iis地址指向项目源码&#xff0c;然后附加到进程w3wp.exe就可以调试了。在core的项目里面已经不能这样玩…

牛客题霸 [二叉树中是否存在节点和为指定值的路径] C++题解/答案

牛客题霸 [二叉树中是否存在节点和为指定值的路径] C题解/答案 题目描述 给定一个二叉树和一个值\ sum sum&#xff0c;判断是否有从根节点到叶子节点的节点值之和等于\ sum sum 的路径&#xff0c; 例如&#xff1a; 给出如下的二叉树&#xff0c;\ sum22 sum22&#xff0c;…

P4292-[WC2010]重建计划【长链剖分,线段树,0/1分数规划】

正题 题目链接:https://www.luogu.com.cn/problem/P4292 题目大意 给出nnn个点的一棵树&#xff0c;然后求长度在[L,U][L,U][L,U]之间的一条路径的平均权值最大。 解题思路 先上二分0/10/10/1分数规划&#xff0c;然后变成求最长在[L,U][L,U][L,U]之间的路径。 很经典的点分…

HDU4035 Maze(树上期望)

Maze 状态表示&#xff1a;fuf_ufu​表示在uuu节点走出迷宫期望次数&#xff0c;dud_udu​表示度数 首先很容易想到下面式子fukuf1(1−ku−eu)∑u→vfv1duf_uk_uf_1(1-k_u-e_u)\frac{\sum _{u\to v}f_v1}{d_u}fu​ku​f1​(1−ku​−eu​)du​∑u→v​fv​1​ 每个节点有一个类…