zoukankan      html  css  js  c++  java
  • 【5min+】保持程序健康的秘诀!AspNetCore的HealthCheck

    系列介绍

    【五分钟的dotnet】是一个利用您的碎片化时间来学习和丰富.net知识的博文系列。它所包含了.net体系中可能会涉及到的方方面面,比如C#的小细节,AspnetCore,微服务中的.net知识等等。
    5min+不是超过5分钟的意思,"+"是知识的增加。so,它是让您花费5分钟以下的时间来提升您的知识储备量。

    正文

    在开发AspNet Core应用的时候,我们经常会为该应用公布一个特殊的检测接口出来。该接口的目的很简单,告诉某一些外界程序(比如docker,客户端等)这个程序现在是可以访问或者不能访问的,便于外界做出相应的操作,比如监控报警,页面通知用户稍作等待等。

    在AspNet Core 2.2 之前,如果我们要实现一个这样的检测接口,需要建立一个单独的controller,比如HealthController。然后为其实现一个简单的检测方法:

    [Route("working")]
    public ActionResult Working()
    {
        using (var connection = new SqlConnection(_connectionString))
        {
            try
            {
                connection.Open();
            }
            catch (SqlException)
            {
                return new HttpStatusCodeResult(503, "Generic error");
            }
        }
    
        return new EmptyResult();
    }
    

    该接口目的是检测应用与数据库的连接能否成功。如果成功连接,则返回状态码为200的空内容,如果失败则返回503。 外界程序可以通过定时访问 “working” 路径,根据返回的对应Code来做出相应的反应。

    运行状况检查

    但是在Aspnet Core 2.2 之后,我们有了新的解决方式。只需要简单的操作就可以进行程序运行状况的检查。

    x

    我们只需要在Startup.cs中添加两句话就OK了:

    public void ConfigureServices(IServiceCollection services)
    {
        //使用该扩展方法
        services.AddHealthChecks();
    }
    
    public void Configure(IApplicationBuilder app)
    {
        app.UseRouting();
    
        app.UseEndpoints(endpoints =>
        {
            //使用该扩展方法
            endpoints.MapHealthChecks("/health");
        });
    }
    

    默认情况是不需要在额外的引入其它nuget包的,因为AspNet Core自带了这些功能。

    此时我们可以访问 "/health" 路径,将会看到对应结果:

    x

    如果程序正常,则返回Http状态码为200,显示内容为"Healthy"的结果。如果程序不正常,则返回Http状态码为503,显示内容为"UnHealthy"的结果。

    这就是运行状况检查的初步使用。

    为什么要自检?

    看到这里,可能有些同学要问:“我引入一个检测到底有什么用?什么情况下我需要这么做呢?”

    其实,对咱们的应用程序来说,做运行情况检查是非常有必要的。

    就好比去医院看病的时候,医生往往会问病人:“你现在是感觉哪儿不舒服,对哪些药物过敏”等等问题。然后才能对症下药。

    更形象的一个例子是做体检:人们一般会自费花钱定期去医院做体检,如果发现哪一检查项有异常的时候,就会报告给医院并且去寻找对应的医生,向医生说明情况之后得到对应的治疗方案。

    所以咱们的应用程序也是一样的,“定期体检”有必要吗? 肯定是有必要的。如果不定期体检,我们很难知道现在程序运行状态到底是什么样子,或许它已经“濒临崩溃”了,需要立即释放内存。

    还有一点就是:需要如实的报告检查情况。就如同医生问病人:“您哪不舒服?”,病人说:“我没病。我哪儿都没问题” 。 那医生只会认为病人是来搞笑的,所以放弃对他的治疗。

    x

    始终要相信一点,没有人比你自己更懂你自己。虽然外界的程序也会有各种其它方式来判断应用程序是否正常,但是它只能知道大概,只有程序体本身才能更清楚的知道现在运行的情况。

    目的性的检查

    最初我们只是简单的引入了 AddHealthChecks 。 但是它并没有任何特定的逻辑在里面。而现实场景我们是需要对各种指标进行检查的,就好比体检单上有多个体检项一样。所以我们需要实现自定义的检查功能。

    比如咱们现在要实现一个对Sql Server 连接情况的检查。我们只需要实现 IHealthCheck 接口,实现CheckHealthAsync 方法就可以了:

    public class SqlServerHealthCheck : IHealthCheck
    {
        SqlConnection _connection;
    
        public string Name => "sql";
    
        public SqlServerHealthCheck(SqlConnection connection)
        {
            _connection = connection;
        }
    
        public Task<HealthCheckResult> CheckHealthAsync(
            HealthCheckContext context,
            CancellationToken cancellationToken = default)
        {
            try
            {
                _connection.Open();
            }
            catch (SqlException)
            {
                return Task.FromResult(HealthCheckResult.Unhealthy("From Sql Serve"));
            }
    
            return Task.FromResult(HealthCheckResult.Healthy());
        }
    }
    

    然后在Startup.csAddHealthChecks进行扩展:

    services.AddHealthChecks()
            .AddCheck<SqlServerHealthCheck>("sql_check");
    

    此时如果咱们再次访问"/health" 路径,就会发现应用会执行SqlServerHealthCheck里面的检查逻辑。

    但是实际情况,咱们往往都会有许许多多的检查项,比如增加一个叫做MemoryHealthCheck的检查项:

    public class MemoryHealthCheck : IHealthCheck
    {
        public Task<HealthCheckResult> CheckHealthAsync(HealthCheckContext context, CancellationToken cancellationToken = default)
        {
            //doing some memory check things.
            return Task.FromResult(HealthCheckResult.Healthy());
        }
    }
    
    // startup.cs
    public void ConfigureServices(IServiceCollection services)
    {
        services.AddHealthChecks()
                .AddCheck<SqlServerHealthCheck>("sql_check")
                .AddCheck<MemoryHealthCheck>("memory_check");  // add this line
    }
    

    或许还有许许多多的检查项:FileSizeHealthCheckRedisHealthCheck等等。当我们将它们都添加上之后,则只有当所有的检查器都返回为Healthy的时候,才会认为是健康

    但是某些情况我们又只想进行单项检查怎么办呢? 我们可以在 endpoints 的配置中新增另外的路由映射规则:

    // startup.cs
     app.UseEndpoints(endpoints =>
    {
        endpoints.MapHealthChecks("/health", new HealthCheckOptions()
        {
            Predicate = s => s.Name.Equals("sql_check"),
            ResponseWriter = WriteResponse
        });
    
        endpoints.MapHealthChecks("/healthy", new HealthCheckOptions()
        {
            Predicate = s => s.Name.Equals("memory_check"),
            ResponseWriter = WriteResponse
        });
    });
    
    //指定返回格式
    private static Task WriteResponse(HttpContext context, HealthReport result)
    {
        context.Response.ContentType = "application/json";
    
        var json = new JObject(
            new JProperty("status", result.Status.ToString()),
            new JProperty("results", new JObject(result.Entries.Select(pair =>
                new JProperty(pair.Key, new JObject(
                    new JProperty("status", pair.Value.Status.ToString()),
                    new JProperty("description", pair.Value.Description),
                    new JProperty("data", new JObject(pair.Value.Data.Select(
                        p => new JProperty(p.Key, p.Value))))))))));
    
        return context.Response.WriteAsync(
            json.ToString());
    }
    

    我们在原有的基础上增加了HealthCheckOptions的参数,该参数指定了关于状态检测的匹配规则,返回状态码,返回格式等信息。

    上面的代码我们指定了两个路由。当访问"health"路径的时候,则是对sql连接的检查(根据检查器名来匹配:Name.Equals("sql_check")),而访问"healthy"路径的时候,是对内存的检查。 最后还为他们指定了需要返回的内容(WriteResponse)。

    接下来我们再次进行请求"health"路径,就会得到下面的结果:

    x

    自定义返回内容对咱们定位错误和记录日志十分有用。(就像看病的例子,病人更清晰的描述病情,医生就能够更容易定位病因。)。

    第三方支持

    虽然官方为我们提供的运行检查库已经足够轻量和简单。但是为了避免重复造轮子,我们可以使用AspNetCore.Diagnostics.HealthChecks包,该项目包含了许多情况的检查,比如 Sql ServerMySqlElasticsearchRedisKafka等等。

    并且还为我们提供一个UI界面,可供查看。只需要在原有的基础上引入对应的代码就行了:

     public void ConfigureServices(IServiceCollection services)
    {
        services.AddHealthChecks()
                .AddCheck<SqlServerHealthCheck>("sql_check")
                .AddCheck<MemoryHealthCheck>("memory_check");
    
        // add this line
        services.AddHealthChecksUI();
    }
    
    app.UseEndpoints(endpoints =>
    {
        endpoints.MapHealthChecks("/health", new HealthCheckOptions()
        {
            Predicate = s => s.Name.Equals("sql_check"),
            ResponseWriter = WriteResponse
        });
        //add this line
        endpoints.MapHealthChecksUI();
    });
    

    当我们访问"/healthchecks-ui"路径时,就可以看到这样的UI:

    x

    默认是没有任何的检测配置项的,如果咱们需要可视化运行状态,需要在AddHealthChecksUI中进行配置:

    services.AddHealthChecksUI(setupSettings: setup =>
    {
        setup.AddHealthCheckEndpoint("endpoint1", "http://localhost:5001/health");
    });
    

    再次查看UI界面,就能看到对应的检查项:

    x

    总结

    本篇文章主要为大家介绍了 aspnet core 2.2之后所推出的“HealthCheck”,与使用传统的Controller 公开API进行检查不同,使用“IHealthCheck”能够更快速的进行访问(毕竟不需要进行模型绑定等操作),而且IHealthCheck接口能够更好的进行检查项扩展。让我们能够更快更清楚的了解到应用程序运行的情况。

    当然,由于篇幅有限,本来还想继续拓展IHealthCheckPublisher接口和健康检查的实现原理等内容,就放在以后再说吧。如果您对该功能感兴趣可以查看 《ASP.NET Core 中的运行状况检查》第三方HealthChecks扩展

    最后,偷偷说一句:创作不易,点个推荐吧.....

    x

  • 相关阅读:
    智能问答系统构思(持续更新)
    软件测试
    Android实现智能问答机器人(四) -----连接我们的系统
    软件架构模式---分层架构V2.0
    软件架构模式---分层架构
    PHP文件上传示例
    PHP文件上传常见类型checklist
    PHP操作Mysql数据库查询数据实例
    PHP操作Mysql数据库更新数据实例
    PHP 操作Mysql数据库删除数据示例
  • 原文地址:https://www.cnblogs.com/uoyo/p/12396644.html
Copyright © 2011-2022 走看看