可信网站验证服务证书,员工入职 在哪个网站做招工,一个网站开发小组,做网站的费用进什么科目目录
托管服务的异常问题
托管服务中使用DI
托管服务案例#xff1a;数据的定时导出 场景#xff0c;代码运行在后台。比如服务器启动的时候在后台预先加载数据到缓存#xff0c;每天凌晨3点把数据导出到备份数据库#xff0c;每隔5秒钟在两张表之间同步一次数据。托管服…目录
托管服务的异常问题
托管服务中使用DI
托管服务案例数据的定时导出 场景代码运行在后台。比如服务器启动的时候在后台预先加载数据到缓存每天凌晨3点把数据导出到备份数据库每隔5秒钟在两张表之间同步一次数据。托管服务实现IHostedService接口一般编写从BackgroundService继承的类。如需定时操作可使用Hangfire框架。
builder.Services.AddHostedServiceHostedService();
托管服务的异常问题
从.NET 6开始当托管服务中发生未处理异常的时候程序就会自动停止并退出。可以把HostOptions.BackgroundServiceExceptionBehavior设置为Ignore程序会忽略异常而不是停止程序。不过推荐采用默认的设置因为“异常应该被妥善的处理而不是被忽略”。要在ExecuteAsync方法中把代码用try……catch包裹起来当发生异常的时候记录日志中或发警报等。
托管服务中使用DI
托管服务是以单例的生命周期注册到依赖注入容器中的。因此不能注入生命周期为范围或者瞬态的服务。比如注入EF Core的上下文的话程序就会抛出异常。可以通过构造方法注入一个IServiceScopeFactory服务它可以用来创建一个IServiceScope对象这样我们就可以通过IServiceScope来创建短生命周期的服务了。记得在Dispose中释放IServiceScope。
public class HostedService : BackgroundService
{private IServiceScope serviceScope;public HostedService(IServiceScopeFactory serviceScopeFactory){this.serviceScope serviceScopeFactory.CreateScope();}public override void Dispose(){this.serviceScope.Dispose();base.Dispose();}protected override async Task ExecuteAsync(CancellationToken stoppingToken){try{var testService serviceScope.ServiceProvider.GetRequiredServiceTestService();Console.WriteLine(HostService1启动 testService.Add(1, 1));await Task.Delay(3000);string txt await File.ReadAllTextAsync(f:/1.txt);Console.WriteLine(文件读取完成);string s null;s.ToString();await Task.Delay(3000);Console.WriteLine(txt);}catch (Exception ex){Console.WriteLine(服务中出现未处理异常 ex);}}
}
public class TestService
{public int Add(int a, int b){return a b;}
}
builder.Services.AddHostedServiceHostedService();
builder.Services.AddScopedTestService();
托管服务案例数据的定时导出
常驻后台的托管服务并不需要特殊的技术我们只要让ExecuteAsync中的代码一直执行不结束就行了。实现的功能就是每隔五秒钟统计一次数据库中的数据将数据写入文本。
builder.Services.AddHostedServiceScheduledService();public class ScheduledService : BackgroundService
{private readonly IServiceScope serviceScope;public ScheduledService(IServiceScopeFactory serviceScopeFactory){this.serviceScope serviceScopeFactory.CreateScope();}public override void Dispose(){this.serviceScope.Dispose();base.Dispose();}protected override async Task ExecuteAsync(CancellationToken stoppingToken){try{var dbCtx serviceScope.ServiceProvider.GetRequiredServiceMyDbContext();while (!stoppingToken.IsCancellationRequested){var count dbCtx.Users.LongCount();await File.WriteAllTextAsync(F:/1.txt, count.ToString());await Task.Delay(5000);}Console.WriteLine(导出成功 DateTime.Now);}catch (Exception ex){Console.WriteLine(ex);}}
}
