在 ASP.NET Core 中使用托管服务实现后台任务

在 ASP.NET Core 中,后台任务作为托管服务实现。托管服务是一个类,具有实现 IHostedService 接口的后台任务逻辑。

ASP.NET Core 辅助角色服务模板可作为编写长期服务应用的起点。通过辅助角色服务模板创建的应用将在其项目文件中指定 Worker SDK:

<Project Sdk="Microsoft.NET.Sdk.Worker">

要使用该模板作为编写托管服务应用的基础:

创建新项目。

选择“辅助角色服务”。选择“下一步”。

在“项目名称”字段提供项目名称,或接受默认项目名称。选择“下一页”。

在“其他信息”对话框中,选择“框架” 。选择“创建”。

Package

基于辅助角色服务模板的应用使用 Microsoft.NET.Sdk.Worker SDK,并且具有对 Microsoft.Extensions.Hosting 包的显式包引用。有关示例,请参阅示例应用的项目文件 (BackgroundTasksSample.csproj)。

对于使用 Microsoft.NET.Sdk.Web SDK 的 Web 应用,通过共享框架隐式引用 Microsoft.Extensions.Hosting 包。在应用的项目文件中不需要显式包引用。

IHostedService 接口

IHostedService 接口为主机托管的对象定义了两种方法:

StartAsync(CancellationToken)
StopAsync(CancellationToken)

StartAsync

StartAsync 包含启动后台任务的逻辑。在以下操作之前调用 StartAsync:

已配置应用的请求处理管道。

已启动服务器且已触发 IApplicationLifetime.ApplicationStarted。可以更改默认行为,以便在配置应用的管道并调用 ApplicationStarted 之后,运行托管服务的 StartAsync。若要更改默认行为,请在调用 CreateBuilder 后添加托管服务(以下示例中的 VideosWatcher):

var builder = WebApplication.CreateBuilder(args);// Add services to the container.
builder.Services.AddHostedService<VideosWatcher>();}

StopAsync

StopAsync(CancellationToken) 在主机执行正常关闭时触发。StopAsync 包含结束后台任务的逻辑。实现 IDisposable 和终结器(析构函数)以处置任何非托管资源。

默认情况下,取消令牌会有五秒超时,以指示关闭进程不再正常。在令牌上请求取消时:

应中止应用正在执行的任何剩余后台操作。

StopAsync 中调用的任何方法都应及时返回。

但是,在请求取消后,将不会放弃任务 — 调用方等待所有任务完成。

如果应用意外关闭(例如,应用的进程失败),则可能不会调用 StopAsync。因此,在 StopAsync 中执行的任何方法或操作都可能不会发生。

若要延长默认值为 5 秒的关闭超时值,请设置:

ShutdownTimeout(当使用通用主机时)。有关详细信息,请参阅 ASP.NET Core 中的 .NET 通用主机。使用 Web 主机时为关闭超时值主机配置设置。有关详细信息,请参阅 ASP.NET Core Web 主机。托管服务在应用启动时激活一次,在应用关闭时正常关闭。如果在执行后台任务期间引发错误,即使未调用 StopAsync,也应调用 Dispose。

BackgroundService 基类

BackgroundService 是用于实现长时间运行的 IHostedService 的基类。

调用 ExecuteAsync(CancellationToken) 来运行后台服务。实现返回一个 Task,其表示后台服务的整个生存期。在 ExecuteAsync 变为异步(例如通过调用 await)之前,不会启动任何其他服务。避免在 ExecuteAsync 中执行长时间的阻塞初始化工作。StopAsync(CancellationToken) 中的主机块等待完成 ExecuteAsync。

调用 IHostedService.StopAsync 时,将触发取消令牌。当激发取消令牌以便正常关闭服务时,ExecuteAsync 的实现应立即完成。否则,服务将在关闭超时后不正常关闭。有关更多信息,请参阅 IHostedService interface 部分。

StartAsync 应仅限于短期任务,因为托管服务是按顺序运行的,在 StartAsync 运行完成之前不会启动其他服务。长期任务应放置在 ExecuteAsync 中。有关详细信息,请参阅 BackgroundService 数据源。

计时的后台任务

定时后台任务使用 System.Threading.Timer 类。计时器触发任务的 DoWork 方法。在 StopAsync 上禁用计时器,并在 Dispose 上处置服务容器时处置计时器:

public class TimedHostedService : IHostedService, IDisposable
{private int executionCount = 0;private readonly ILogger<TimedHostedService> _logger;private Timer _timer = null!;public TimedHostedService(ILogger<TimedHostedService> logger){_logger = logger;}public Task StartAsync(CancellationToken stoppingToken){_logger.LogInformation("Timed Hosted Service running.");_timer = new Timer(DoWork, null, TimeSpan.Zero, TimeSpan.FromSeconds(5));return Task.CompletedTask;}private void DoWork(object? state){var count = Interlocked.Increment(ref executionCount);_logger.LogInformation("Timed Hosted Service is working. Count: {Count}", count);}public Task StopAsync(CancellationToken stoppingToken){_logger.LogInformation("Timed Hosted Service is stopping.");_timer?.Change(Timeout.Infinite, 0);return Task.CompletedTask;}public void Dispose(){_timer?.Dispose();}
}

Timer 不等待先前的 DoWork 执行完成,因此所介绍的方法可能并不适用于所有场景。使用 Interlocked.Increment 以原子操作的形式将执行计数器递增,这可确保多个线程不会并行更新 executionCount。

已使用 AddHostedService 扩展方法在 IHostBuilder.ConfigureServices (Program.cs) 中注册该服务:

services.AddHostedService<TimedHostedService>();

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

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

相关文章

Framer – 将视觉搞转换为更真实的动态原型

Framer 是一个 JavaScript 框架&#xff0c;简化了创建现实原型&#xff0c;实现完整的3D效果。以一种简单&#xff0c;可读的和强大的方式定义交互和创建动画。 另外还有 Framer Generator 是一个桌面应用程序&#xff0c;从 Photoshop 文件导入资源和和文件夹层次结构。你的…

《SAS编程与数据挖掘商业案例》学习笔记之四

5.双set语句的应用(2个指针&#xff0c;一个pdv) libname chapt3 f:\data_model\book_data\chapt3; data percent; if _n_ 1 then set chapt3.summary(keep cargosum); set chapt3.empcount; pctemps numemps / cargosum; run; 解读&#xff1a;编译后&#xff0c;内存中会出…

现在相亲还要体检报告了?

1 伤害性极大&#xff08;素材来源网络&#xff0c;侵删&#xff09;▼2 相亲还要看体检报告&#xff1f;&#xff08;素材来源网络&#xff0c;侵删&#xff09;▼3 难以启齿的地名&#xff08;素材来源网络&#xff0c;侵删&#xff09;▼4 当知道你不回家之后&#xff08…

.NET 6新特性试用 | System.Text.Json序列化代码自动生成

前言几乎所有.NET序列化程序的实现基础都是反射。下列代码是Newtonsoft.Json的实现&#xff1a;protected virtual JsonProperty CreateProperty(MemberInfo member, MemberSerialization memberSerialization) {JsonProperty property new JsonProperty();property.PropertyT…

js去除左右空格

function yanzheng(val) {return val.replace(/(^\s*)|(\s*$)/g, "");}function Inputchecking() {var account document.getElementById("txt_ACCOUNT");if (yanzheng(account.value) "") {alert(请输入账号);account.focus();return false;}…

UVa 264 - Count on Cantor

《算法竞赛入门经典》5.4.1的题目&#xff0c;大意是&#xff0c;给出一个数表&#xff0c;如下&#xff1a; 第一项是1/1&#xff0c; 第二项是1/2&#xff0c; 第三项是2/1&#xff0c; 第四项是3/1&#xff0c; 第五项是2/2.....给一个正整数n&#xff0c;求第n项。 设第n个…

《SAS编程与数据挖掘商业案例》学习笔记之五

六&#xff1a;merge语句的使用(一个指针&#xff0c;一个pdv) merge语句是横向合并数据集&#xff0c;合并前必须两个数据集都要按照合并变量进行排序&#xff1b; proc sort datachapt3.merge_a;by x;run; proc sort datachapt3.merge_b;by bx;run; data ed; merge chapt3.me…

他解决了物理学千年争端,成就肩比牛顿、爱因斯坦,但却鲜有人知......

全世界只有3.14 % 的人关注了爆炸吧知识电磁学是经典物理学的一部分&#xff0c;提到电磁学就不得不提经典电动力学创始人-麦克斯韦。麦克斯韦的名气好像并不如牛顿、爱因斯坦那样家喻户晓&#xff0c;毕竟当提到牛顿的时候&#xff0c;这个公式就如同条件反射似得浮现出来&…

Windows 11 全新 4K 壁纸发布

微软近日发布 Windows 11 全新主题包 「Pantone Color of the Year 2022」&#xff0c;包含 4 张经重塑的壁纸。微软表示&#xff1a;通过这四张使用 Pantone Color of the Year 2022,&#xff0c;PANTONE 17-3938 Very Peri 颜色&#xff0c;重新定制的 Windows 11 Bloom 壁纸…

android之在view中内嵌浏览器的方法

我要做的一个东西是在一个页面的中间嵌入浏览器&#xff0c;一开始不知道从哪里开始&#xff0c;因为以前用的都是Textveiw或者editVeiw之类的控件&#xff0c;而它们并不能用来显示网页的内容&#xff0c;怎么办呢&#xff1f; 首先想到的是&#xff1a;是不是有一个用来显示网…

CCNA综合实验(一):实验拓扑与要求

一、实验拓扑 屏幕剪辑的捕获时间: 2013/5/5 星期日 16:49 IP地址分配 IP地址为192.168.1.0/24 ,&#xff0c;根据本地网络的需求制定子网划分方案。要求如下&#xff1a; R2&#xff08;带有WIC-2T模块&#xff09;上开启环回接口loopback 0 地址为 192.168.X.20&#xff1b;R…

《SAS编程与数据挖掘商业案例》学习笔记之六

八&#xff1a;modify语句&#xff08;(一个指针&#xff0c;两个pdv)&#xff09; merge语句和update语句对数据集横向合并的主要功能还只能体现在匹配访问上&#xff0c;如通过by语句&#xff0c;对每个by组中的匹配数据集进行修改或更新&#xff0c;对于非常庞大的数据集需要…

C#开发微信门户及应用(10)--在管理系统中同步微信用户分组信息

在前面几篇文章中&#xff0c;逐步从原有微信的API封装的基础上过渡到微信应用平台管理系统里面&#xff0c;逐步介绍管理系统中的微信数据的界面设计&#xff0c;以及相关的处理操作过程的逻辑和代码&#xff0c;希望从更高一个层次&#xff0c;向大家介绍微信的应用开发过程。…

ASP.NET Web API中实现版本

一般来说&#xff0c;api 接口是提供给其他系统或是其他公司使用&#xff0c;不能随意频繁的变更。然而&#xff0c;需求和业务不断变化&#xff0c;接口和参数也会发生相应的变化。如果直接对原来的接口进行修改&#xff0c;势必会影响线其他系统的正常运行。这就必须对api 接…

一个娃娃竟然拍出50万......

1 瞎说什么大实话&#xff08;素材来源网络&#xff0c;侵删&#xff09;▼2 这个娃娃50万用来求婚用&#xff08;素材来源网络&#xff0c;侵删&#xff09;▼3 当代年轻人的特别祝福▼4 在福字底下加一横&#xff08;素材来源网络&#xff0c;侵删&#xff09;▼5 冰激凌…

切图崽的自我修养-规范CSS元素命名

前言 为什么我刚才写的样式乱了&#xff1f;&#xff01;如何给变量&#xff0c;文件命名是程序员的老大难问题。命名为什么会这么难&#xff0c;因为它太重要了。可以这么说&#xff0c;准确的命名可以提高代码的可读性&#xff0c;让人容易理解&#xff0c;方便调试&#xff…

批量获取域名解析地址socketthread

import threadimport socketdef getIP(name,lock):print [%s]:%s\n%(name,socket.gethostbyname(name))lock.release() #释放线程锁def main():#读取存放域名的文件&#xff0c;文件是按一行一个域名的方式记录的files open(rC:\Users\Administrator\Desktop\python_script\na…

《SAS编程与数据挖掘商业案例》学习笔记之七

九&#xff1a;put语句 可以输出变量信息到指定地点&#xff0c;包括输出到sas系统的日志窗口&#xff1b; 输出到file语句规定的外部文件 输出到sas系统的output窗口 单尾操作符&#xff0c;多用于input语句中&#xff0c;双尾操作符&#xff0c;多用于put语句中。 Data a; In…