代理网站哪个好,网络安全管理系统,可信赖的做pc端网站,开个网站做一、基础准备1. 安装依赖这里可以通过nuget或使用命令行进行安装#xff0c;具体需要安装的类库如下#xff08;注意版本#xff09;#xff1a;Install-Package App.Metrics.AspNetCore.Mvc -Version 2.0.0由于我们需要兼容Prometheus进行监控#xff0c;所以我们还需要安… 一、基础准备1. 安装依赖这里可以通过nuget或使用命令行进行安装具体需要安装的类库如下注意版本Install-Package App.Metrics.AspNetCore.Mvc -Version 2.0.0由于我们需要兼容Prometheus进行监控所以我们还需要安装对应的格式化库具体如下Install-Package App.Metrics.Formatters.Prometheus -Version 2.0.0以上就是需要的类库接下来我们开始进行其他初始化部分。2. 初始配置为了保证其能够正常工作我们需要根据不同的环境设定对应的appsettings.json文件从而让度量指标可以根据不同的环境进行输出这里考虑到实际情况尚未存在不同的配置可能性故统一配置即可打开appsettings.json输入下配置项{MetricsOptions: {DefaultContextLabel: MetricsApplication,Enabled: true},MetricsWebTrackingOptions: {ApdexTrackingEnabled: true,ApdexTSeconds: 0.3,IgnoredHttpStatusCodes: [ 404 ],IgnoreRoutesRegexPatterns: [],OAuth2TrackingEnabled: false},MetricEndpointsOptions: {MetricsEndpointEnabled: true,MetricsTextEndpointEnabled: true,EnvironmentInfoEndpointEnabled: true}
}参数DefaultContextLabel可以设定为我们期望其他名称这里建议采用项目的简写名称保证项目之间不存在冲突即可。参数ApdexTSeconds用于设定应用的响应能力标准其采用了当前流行的Apdex标准这里使用者可以根据自身应用的实际情况调整对应的参数其他相关参数建议默认即可。3. 启用度量指标因为我们的数据需要符合Promethues格式所以后续教程我们会替换默认的格式采用符合的格式。首先我们需要Program.cs里输入以下内容 public static IWebHost BuildWebHost(string[] args){Metrics AppMetrics.CreateDefaultBuilder().OutputMetrics.AsPrometheusPlainText().OutputMetrics.AsPrometheusProtobuf().Build();return WebHost.CreateDefaultBuilder(args).ConfigureMetrics(Metrics).UseMetrics(options {options.EndpointOptions endpointsOptions {endpointsOptions.MetricsTextEndpointOutputFormatter Metrics.OutputMetricsFormatters.OfTypeMetricsPrometheusTextOutputFormatter().First();endpointsOptions.MetricsEndpointOutputFormatter Metrics.OutputMetricsFormatters.OfTypeMetricsPrometheusProtobufOutputFormatter().First();};}).UseStartupStartup().Build();}其中为了能够支持其他格式我们需要手动实例化Metrics对象完成相关初始化然后将其注入到asp.net core中其中相关格式的代码主要是由以下这几部分组成OutputMetrics.AsPrometheusPlainText()
OutputMetrics.AsPrometheusProtobuf()endpointsOptions.MetricsTextEndpointOutputFormatter Metrics.OutputMetricsFormatters.OfTypeMetricsPrometheusTextOutputFormatter().First();
endpointsOptions.MetricsEndpointOutputFormatter Metrics.OutputMetricsFormatters.OfTypeMetricsPrometheusProtobufOutputFormatter().First();
完成以上操作后我们最后还需要进行其他配置打开Startup.cs文件增加如下内容services.AddMvc().AddMetrics();至此我们就完成了基本的初始化了通过启动程序并访问localhost:5000/metrics-text即可查看最终的输出内容。二、自定义指标由于其内部已经默认提供了若干的指标但是并不能符合实际业务的需求故以下将对常用的度量指标类型以及用法进行介绍这里这里大家通过注入IMetrics接口对象即可访问所以下面这部分代码不在阐述。1. 仪表盘Gauge最常见的类型主要是用于直接反应当前的指标情况比如我们常见的CPU和内存基本都是使用这种方式进行显示的可以直观的看到当前的实际的状态情况。对于所有的指标我们都需要定义对应的Options当然这可以完成携程静态变量供应用程序全局使用。比如下面我们定义一个表示当前发生错误次数的指标GaugeOptions Errors new GaugeOptions()
{Name Errors
};完成指标的定义后我们就可以在需要使用的地方进行指标数据的修改比如下面我们将错误数量设置为10metrics.Measure.Gauge.SetValue(MyMetricsRegistry.Errors, 10);这样我们就完成了指标的设定但是有时候我们还想却分具体的Error是那个层面发起的这个时候我们需要使用到Tag了下面我们在设定值的同时设定指标当然也可以在新建指标的时候通过Tags变量并且通用于其他所有指标var tags new MetricTags(fromt, db);
metrics.Measure.Gauge.SetValue(MyMetricsRegistry.Errors, tags, 10);至此我们就完成了一个基本的指标下面我们继续其他类型指标。2. 计数值Counter对于HTTP类型的网站来说存在非常多的数量需要统计记录所以计数值此时就特别适合这类情况比如我们需要统计请求数量就可以利用这类指标类型下面我们就以请求数来定义这个指标var requestCounter new CounterOptions()
{Name httpRequest,MeasurementUnit Unit.Calls
};以上我们定义了一个计数指标其中我们可以看到我们这里使用了一个新变量MeasurementUnit主要是用于定义指标单位的当然这个只是辅助信息会一同输出到结果下面我们需要进行增加和减少考虑到大多数情况都是减1和增1的情况metrics.Measure.Counter.Increment(requestCounter);实际情况可能我们都是统计请求但是期望还能单独统计特定接口的请求这个时候我们在原本调用方式基础上增加额外的参数metrics.Measure.Counter.Increment(requestCounter, api);如果嫌每次增长1比较慢我们通过其函数的重载形式填写我们希望增长的具体值。3. 计量值Meter有点类似于计数值但是相比来说它可以提供更加丰富的信息比如每1、5、15分钟的增长率等所以对于一些需要通过增长率观察的数据特别时候这里我们以请求的反应状态码进行记录来体现其用途var httpStatusMeter new MeterOptions()
{Name Http Status,MeasurementUnit Unit.Calls
};以上我们完成了一个指标的定义下面我们开始使用其并且定义不同的状态的码的发生情况具体如下metrics.Measure.Meter.Mark(httpStatusMeter, 200);
metrics.Measure.Meter.Mark(httpStatusMeter, 500);
metrics.Measure.Meter.Mark(httpStatusMeter, 401);当然如果希望增加的数量自定控制也可以使用其提供的重载形式进行。4. 柱状图Histogram顾名思义主要反应数据的分布情况所以这里不在重复阐述大家对于这种数据表现形式还是比较了解的所以下面就直接以实际代码的实列进行介绍便于大家的理解var postAndPutRequestSize new HistogramOptions()
{Name Web Request Post Put Size,MeasurementUnit Unit.Bytes
};以上我们定义一个体现Post和Put请求的数据尺寸的指标下面我们利用随机数来进行数据的模拟对其进行数据填充便于显示数据var rnd new Random();foreach (var i in Enumerable.Range(0, 50))
{var t rnd.Next(0, 10);metrics.Measure.Histogram.Update(postAndPutRequestSize, t);
}5. 时间线Timer对应指标的监控闭然少不了对于时间的记录特别对于HTTP来说直接影响到用户的体验就是响应时间素以我们也需要时刻关于这类指标的变化情况及时做出反应下面我们就以数据库的响应时间的情况作为指标进行监控TimerOptions DatabaseTimer new TimerOptions()
{Name Database Timer,MeasurementUnit Unit.Items,DurationUnit TimeUnit.Milliseconds,RateUnit TimeUnit.Milliseconds
};上面我们通过特别的属性指定了改指标记录时间的单位下面我们使用其指标进行数据的记录using(metrics.Measure.Timer.Time(DatabaseTimer))
{//to do sonmething
}我们可以看到为了方便的记录请求的时间我们使用using进行涵括并将需要记录耗时的请求操作放入其中在请求完成操作后就可以正确的记录其需要的时间。6. apdex采用了一种标准的性能指标计算方式用法类似与上述这里仅仅列举用法ApdexOptions SampleApdex new ApdexOptions
{Name Sample Apdex
};using(metrics.Measure.Apdex.Track(SampleApdex))
{Thread.Sleep(100);
}三、高级指标1. 平均响应很多时候我们仅仅依靠一个指标很难完成一个实际的需求是所以我们就需要将多个指标进行组合进行比如我们期望得到请求次数同时还有请求的总时间和平均响应时间等为此我们可以特殊的指标将多个指标进行组合具体操作如下var cacheHitRatioGauge new GaugeOptions
{Name Cache Gauge,MeasurementUnit Unit.Calls
};var cacheHitsMeter new MeterOptions
{Name Cache Hits Meter,MeasurementUnit Unit.Calls
};var databaseQueryTimer new TimerOptions
{Name Database Query Timer,MeasurementUnit Unit.Calls,DurationUnit TimeUnit.Milliseconds,RateUnit TimeUnit.Milliseconds
};var cacheHits metrics.Provider.Meter.Instance(cacheHitsMeter);
var calls metrics.Provider.Timer.Instance(databaseQueryTimer);var cacheHit new Random().Next(0, 2) 0;using(calls.NewContext())
{if (cacheHit){cacheHits.Mark(5);}Thread.Sleep(cacheHit ? 10 : 100);
}metrics.Measure.Gauge.SetValue(cacheHitRatioGauge, () new HitRatioGauge(cacheHits, calls, m m.OneMinuteRate));四、利用Promethues和Grafana进行监控1. 环境准备这里需要使用到Prometheus和Grafana为了避免版本导致的区别这里提供了对应百度云的下载地址大家可以自行进行下载。Prometheus对应提取码为2b1rGrafana对应提取码为mjym完成以上下载后需要解压到对应文件夹下即可。2. 配置服务首先我们需要针对Prometheus进行配置我们打开prometheus.yml文件新增基于AppMetrics的监控指标。 - job_name: appwebscrape_interval: 5smetrics_path: /metrics-textstatic_configs:- targets: [localhost:5000]完成之后我们可以先打开采集让其在后台持续采集后面我们需要针对AppMetrics暴露的数据进行调整。3. 应用指标输出通过实际的测试发现基于2.0.0版本的Prometheus存在问题因为指标类型被大写了导致Prometheus无法正确读取所以我们需要将源码复制出来进行操作这里直接给出了对应的源码文件主要的工作就是将AsciiFormatter.cs中的HELP和TYPE进行了小写而已对应文件如下。PS考虑到很多基于2.0的所以这里保留了基于HTTP的文本实现方式发布了一个对应的版本库Install-Package Sino.Metrics.Formatters.Prometheus -Version 0.1.2AsciiFormatter.cs internal static class AsciiFormatter{public static void Format(Stream destination, IEnumerableMetricFamily metrics){var metricFamilys metrics.ToArray();using (var streamWriter new StreamWriter(destination, Encoding.UTF8)){streamWriter.NewLine \n;foreach (var metricFamily in metricFamilys){WriteFamily(streamWriter, metricFamily);}}}internal static string Format(IEnumerableMetricFamily metrics, NewLineFormat newLine){var newLineChar GetNewLineChar(newLine);var metricFamilys metrics.ToArray();var s new StringBuilder();foreach (var metricFamily in metricFamilys){s.Append(WriteFamily(metricFamily, newLineChar));}return s.ToString();}private static void WriteFamily(StreamWriter streamWriter, MetricFamily metricFamily){streamWriter.WriteLine(# HELP {0} {1}, metricFamily.name, metricFamily.help.ToLower());streamWriter.WriteLine(# TYPE {0} {1}, metricFamily.name, metricFamily.type.ToString().ToLower());foreach (var metric in metricFamily.metric){WriteMetric(streamWriter, metricFamily, metric);}}private static string WriteFamily(MetricFamily metricFamily, string newLine){var s new StringBuilder();s.Append(string.Format(# HELP {0} {1}, metricFamily.name, metricFamily.help.ToLower()), newLine);s.Append(string.Format(# TYPE {0} {1}, metricFamily.name, metricFamily.type.ToString().ToLower()), newLine);foreach (var metric in metricFamily.metric){s.Append(WriteMetric(metricFamily, metric, newLine), newLine);}return s.ToString();}private static void WriteMetric(StreamWriter streamWriter, MetricFamily family, Metric metric){var familyName family.name;if (metric.gauge ! null){streamWriter.WriteLine(SimpleValue(familyName, metric.gauge.value, metric.label));}else if (metric.counter ! null){streamWriter.WriteLine(SimpleValue(familyName, metric.counter.value, metric.label));}else if (metric.summary ! null){streamWriter.WriteLine(SimpleValue(familyName, metric.summary.sample_sum, metric.label, _sum));streamWriter.WriteLine(SimpleValue(familyName, metric.summary.sample_count, metric.label, _count));foreach (var quantileValuePair in metric.summary.quantile){var quantile double.IsPositiveInfinity(quantileValuePair.quantile)? Inf: quantileValuePair.quantile.ToString(CultureInfo.InvariantCulture);streamWriter.WriteLine(SimpleValue(familyName,quantileValuePair.value,metric.label.Concat(new[] { new LabelPair { name quantile, value quantile } })));}}else if (metric.histogram ! null){streamWriter.WriteLine(SimpleValue(familyName, metric.histogram.sample_sum, metric.label, _sum));streamWriter.WriteLine(SimpleValue(familyName, metric.histogram.sample_count, metric.label, _count));foreach (var bucket in metric.histogram.bucket){var value double.IsPositiveInfinity(bucket.upper_bound) ? Inf : bucket.upper_bound.ToString(CultureInfo.InvariantCulture);streamWriter.WriteLine(SimpleValue(familyName,bucket.cumulative_count,metric.label.Concat(new[] { new LabelPair { name le, value value } }),_bucket));}}else{// not supported}}private static string WriteMetric(MetricFamily family, Metric metric, string newLine){var s new StringBuilder();var familyName family.name;if (metric.gauge ! null){s.Append(SimpleValue(familyName, metric.gauge.value, metric.label), newLine);}else if (metric.counter ! null){s.Append(SimpleValue(familyName, metric.counter.value, metric.label), newLine);}else if (metric.summary ! null){s.Append(SimpleValue(familyName, metric.summary.sample_sum, metric.label, _sum), newLine);s.Append(SimpleValue(familyName, metric.summary.sample_count, metric.label, _count), newLine);foreach (var quantileValuePair in metric.summary.quantile){var quantile double.IsPositiveInfinity(quantileValuePair.quantile)? Inf: quantileValuePair.quantile.ToString(CultureInfo.InvariantCulture);s.Append(SimpleValue(familyName,quantileValuePair.value,metric.label.Concat(new[] { new LabelPair { name quantile, value quantile } })), newLine);}}else if (metric.histogram ! null){s.Append(SimpleValue(familyName, metric.histogram.sample_sum, metric.label, _sum), newLine);s.Append(SimpleValue(familyName, metric.histogram.sample_count, metric.label, _count), newLine);foreach (var bucket in metric.histogram.bucket){var value double.IsPositiveInfinity(bucket.upper_bound) ? Inf : bucket.upper_bound.ToString(CultureInfo.InvariantCulture);s.Append(SimpleValue(familyName,bucket.cumulative_count,metric.label.Concat(new[] { new LabelPair { name le, value value } }),_bucket), newLine);}}else{// not supported}return s.ToString();}private static string WithLabels(string familyName, IEnumerableLabelPair labels){var labelPairs labels as LabelPair[] ?? labels.ToArray();if (labelPairs.Length 0){return familyName;}return string.Format({0}{{{1}}}, familyName, string.Join(,, labelPairs.Select(l string.Format({0}\{1}\, l.name, l.value))));}private static string SimpleValue(string family, double value, IEnumerableLabelPair labels, string namePostfix null){return string.Format({0} {1}, WithLabels(family (namePostfix ?? string.Empty), labels), value.ToString(CultureInfo.InvariantCulture));}private static string GetNewLineChar(NewLineFormat newLine){switch (newLine){case NewLineFormat.Auto:return Environment.NewLine;case NewLineFormat.Windows:return \r\n;case NewLineFormat.Unix:case NewLineFormat.Default:return \n;default:throw new ArgumentOutOfRangeException(nameof(newLine), newLine, null);}}private static void Append(this StringBuilder sb, string line, string newLineChar){sb.Append(line newLineChar);}}MetricsPrometheusTextOutputFormatter.cs public class MetricsPrometheusTextOutputFormatter : IMetricsOutputFormatter{private readonly MetricsPrometheusOptions _options;public MetricsPrometheusTextOutputFormatter(){_options new MetricsPrometheusOptions();}public MetricsPrometheusTextOutputFormatter(MetricsPrometheusOptions options) { _options options ?? throw new ArgumentNullException(nameof(options)); }/// inheritdoc/public MetricsMediaTypeValue MediaType new MetricsMediaTypeValue(text, vnd.appmetrics.metrics.prometheus, v1, plain);/// inheritdoc/public async Task WriteAsync(Stream output,MetricsDataValueSource metricsData,CancellationToken cancellationToken default(CancellationToken)){if (output null){throw new ArgumentNullException(nameof(output));}using (var streamWriter new StreamWriter(output)){await streamWriter.WriteAsync(AsciiFormatter.Format(metricsData.GetPrometheusMetricsSnapshot(_options.MetricNameFormatter), _options.NewLineFormat));}}}新建好以上两个文件后我们接着需要修改Program.cs文件具体内容如下 public static IWebHost BuildWebHost(string[] args){Metrics AppMetrics.CreateDefaultBuilder().OutputMetrics.AsPrometheusPlainText().Build();return WebHost.CreateDefaultBuilder(args).ConfigureMetrics(Metrics).UseMetrics(options {options.EndpointOptions endpointsOptions {endpointsOptions.MetricsTextEndpointOutputFormatter new MetricsPrometheusTextOutputFormatter();};}).UseStartupStartup().Build();}完成以上操作后我们可以启用应用此时可以看到不断用请求到/metrics-text表示已经开始采集指标了。4. 指标可视化此时我们打开Grafana文件夹通过其中的bin目录下的grafana-server.exe启动服务然后访问localhost:3000利用初始账户密码进行登录admin/admin。进入后添加Prometheus数据源。由于AppMetrics已经提供了对应的看板所以我们可以通过ID2204直接导入并选择正确的数据源就可以看到最终的效果了。
