src/Library/NetPro.Checker/UrlHealthCheck.cs

这里只显示每个文件的开头 60 行。登录后可以解锁完整代码。

微信扫码关注公众号，代码整理好后第一时间通知你。

using Microsoft.Extensions.DependencyInjection;
using Microsoft.Extensions.Diagnostics.HealthChecks;
using System;
using System.Collections.Generic;
using System.Linq;
using System.Net;
using System.Net.Http;
using System.Threading;
using System.Threading.Tasks;

namespace NetPro.Checker
{
    /// <summary>
    /// url health check
    /// </summary>
    public static class HealthChecksUrlExtensions
    {
        private static readonly string NAME = "urlcheck";

        /// <summary>
        /// 
        /// </summary>
        /// <param name="builder"></param>
        /// <param name="urls"></param>
        /// <param name="succeedtatusCodes">default is HttpStatusCode.OK </param>
        /// <param name="name"></param>
        /// <param name="failureStatus"></param>
        /// <param name="tags"></param>
        /// <param name="timeout"></param>
        /// <returns></returns>
        public static IHealthChecksBuilder AddUrl(this IHealthChecksBuilder builder, List<string> urls, List<HttpStatusCode> succeedtatusCodes = null, string name = default, HealthStatus? failureStatus = default, IEnumerable<string> tags = default, TimeSpan? timeout = default)
        {
            if (succeedtatusCodes == null)
            {
                succeedtatusCodes = new List<HttpStatusCode>() { HttpStatusCode.OK };
            }
            return builder.Add(new HealthCheckRegistration(
                name ?? NAME,
                sp => new UrlHealthCheck(urls, succeedtatusCodes),
                failureStatus,
                tags,
                timeout));
        }
    }

    /// <summary>
    /// 
    /// </summary>
    public class UrlHealthCheck : IHealthCheck
    {
        private readonly List<string> _urls;
        private static HttpClient _httpclient;
        private readonly List<HttpStatusCode> _statusCodes;
        /// <summary>
        /// 
        /// </summary>
        /// <param name="urls"></param>
        /// <param name="statusCodes"></param>
        public UrlHealthCheck(List<string> urls, List<HttpStatusCode> statusCodes)
        {