2
0

HttpClient.cs 2.0 KB

12345678910111213141516171819202122232425262728293031323334353637383940414243444546474849505152535455565758
  1. using FastGithub.Configuration;
  2. using FastGithub.DomainResolve;
  3. using System.Net.Http;
  4. using System.Net.Http.Headers;
  5. using System.Threading;
  6. using System.Threading.Tasks;
  7. namespace FastGithub.Http
  8. {
  9. /// <summary>
  10. /// 表示http客户端
  11. /// </summary>
  12. public class HttpClient : HttpMessageInvoker
  13. {
  14. /// <summary>
  15. /// 插入的UserAgent标记
  16. /// </summary>
  17. private readonly static ProductInfoHeaderValue userAgent = new(new ProductHeaderValue(nameof(FastGithub), "1.0"));
  18. /// <summary>
  19. /// http客户端
  20. /// </summary>
  21. /// <param name="domainConfig"></param>
  22. /// <param name="domainResolver"></param>
  23. public HttpClient(DomainConfig domainConfig, IDomainResolver domainResolver)
  24. : this(new HttpClientHandler(domainConfig, domainResolver), disposeHandler: true)
  25. {
  26. }
  27. /// <summary>
  28. /// http客户端
  29. /// </summary>
  30. /// <param name="handler"></param>
  31. /// <param name="disposeHandler"></param>
  32. public HttpClient(HttpMessageHandler handler, bool disposeHandler)
  33. : base(handler, disposeHandler)
  34. {
  35. }
  36. /// <summary>
  37. /// 发送请求
  38. /// </summary>
  39. /// <param name="request"></param>
  40. /// <param name="cancellationToken"></param>
  41. /// <returns></returns>
  42. public override async Task<HttpResponseMessage> SendAsync(HttpRequestMessage request, CancellationToken cancellationToken)
  43. {
  44. if (request.Headers.UserAgent.Contains(userAgent))
  45. {
  46. throw new FastGithubException($"由于{request.RequestUri}实际指向了{nameof(FastGithub)}自身,{nameof(FastGithub)}已中断本次转发");
  47. }
  48. request.Headers.UserAgent.Add(userAgent);
  49. var response = await base.SendAsync(request, cancellationToken);
  50. response.Headers.Server.TryParseAdd(nameof(FastGithub));
  51. return response;
  52. }
  53. }
  54. }