TcpInterceptHostedService.cs 1.1 KB

1234567891011121314151617181920212223242526272829303132333435363738
  1. using Microsoft.Extensions.Hosting;
  2. using System.Collections.Generic;
  3. using System.Linq;
  4. using System.Runtime.Versioning;
  5. using System.Threading;
  6. using System.Threading.Tasks;
  7. namespace FastGithub.PacketIntercept
  8. {
  9. /// <summary>
  10. /// tcp拦截后台服务
  11. /// </summary>
  12. [SupportedOSPlatform("windows")]
  13. sealed class TcpInterceptHostedService : BackgroundService
  14. {
  15. private readonly IEnumerable<ITcpInterceptor> tcpInterceptors;
  16. /// <summary>
  17. /// tcp拦截后台服务
  18. /// </summary>
  19. /// <param name="tcpInterceptors"></param>
  20. public TcpInterceptHostedService(IEnumerable<ITcpInterceptor> tcpInterceptors)
  21. {
  22. this.tcpInterceptors = tcpInterceptors;
  23. }
  24. /// <summary>
  25. /// https后台
  26. /// </summary>
  27. /// <param name="stoppingToken"></param>
  28. /// <returns></returns>
  29. protected override Task ExecuteAsync(CancellationToken stoppingToken)
  30. {
  31. var tasks = this.tcpInterceptors.Select(item => item.InterceptAsync(stoppingToken));
  32. return Task.WhenAll(tasks);
  33. }
  34. }
  35. }