DomainResolveHostedService.cs 1.8 KB

1234567891011121314151617181920212223242526272829303132333435363738394041424344454647484950515253545556
  1. using Microsoft.Extensions.Hosting;
  2. using System;
  3. using System.Threading;
  4. using System.Threading.Tasks;
  5. namespace FastGithub.DomainResolve
  6. {
  7. /// <summary>
  8. /// 域名解析后台服务
  9. /// </summary>
  10. sealed class DomainResolveHostedService : BackgroundService
  11. {
  12. private readonly DnscryptProxy dnscryptProxy;
  13. private readonly IDomainResolver domainResolver;
  14. private readonly TimeSpan testPeriodTimeSpan = TimeSpan.FromSeconds (1d);
  15. /// <summary>
  16. /// 域名解析后台服务
  17. /// </summary>
  18. /// <param name="dnscryptProxy"></param>
  19. /// <param name="domainResolver"></param>
  20. public DomainResolveHostedService(
  21. DnscryptProxy dnscryptProxy,
  22. IDomainResolver domainResolver)
  23. {
  24. this.dnscryptProxy = dnscryptProxy;
  25. this.domainResolver = domainResolver;
  26. }
  27. /// <summary>
  28. /// 后台任务
  29. /// </summary>
  30. /// <param name="stoppingToken"></param>
  31. /// <returns></returns>
  32. protected override async Task ExecuteAsync(CancellationToken stoppingToken)
  33. {
  34. await this.dnscryptProxy.StartAsync(stoppingToken);
  35. while (stoppingToken.IsCancellationRequested == false)
  36. {
  37. await this.domainResolver.TestAllEndPointsAsync(stoppingToken);
  38. await Task.Delay(this.testPeriodTimeSpan, stoppingToken);
  39. }
  40. }
  41. /// <summary>
  42. /// 停止服务
  43. /// </summary>
  44. /// <param name="cancellationToken"></param>
  45. /// <returns></returns>
  46. public override Task StopAsync(CancellationToken cancellationToken)
  47. {
  48. this.dnscryptProxy.Stop();
  49. return base.StopAsync(cancellationToken);
  50. }
  51. }
  52. }