1234567891011121314151617181920212223242526272829303132333435363738394041424344454647484950515253545556 |
- using Microsoft.Extensions.Hosting;
- using System;
- using System.Threading;
- using System.Threading.Tasks;
- namespace FastGithub.DomainResolve
- {
- /// <summary>
- /// 域名解析后台服务
- /// </summary>
- sealed class DomainResolveHostedService : BackgroundService
- {
- private readonly DnscryptProxy dnscryptProxy;
- private readonly IDomainResolver domainResolver;
- private readonly TimeSpan testPeriodTimeSpan = TimeSpan.FromSeconds (1d);
- /// <summary>
- /// 域名解析后台服务
- /// </summary>
- /// <param name="dnscryptProxy"></param>
- /// <param name="domainResolver"></param>
- public DomainResolveHostedService(
- DnscryptProxy dnscryptProxy,
- IDomainResolver domainResolver)
- {
- this.dnscryptProxy = dnscryptProxy;
- this.domainResolver = domainResolver;
- }
- /// <summary>
- /// 后台任务
- /// </summary>
- /// <param name="stoppingToken"></param>
- /// <returns></returns>
- protected override async Task ExecuteAsync(CancellationToken stoppingToken)
- {
- await this.dnscryptProxy.StartAsync(stoppingToken);
- while (stoppingToken.IsCancellationRequested == false)
- {
- await this.domainResolver.TestAllEndPointsAsync(stoppingToken);
- await Task.Delay(this.testPeriodTimeSpan, stoppingToken);
- }
- }
- /// <summary>
- /// 停止服务
- /// </summary>
- /// <param name="cancellationToken"></param>
- /// <returns></returns>
- public override Task StopAsync(CancellationToken cancellationToken)
- {
- this.dnscryptProxy.Stop();
- return base.StopAsync(cancellationToken);
- }
- }
- }
|