自定义EventSource(二)PollingCounter

在自定义EventSource时,可以使用四种EventCounter:

  • EventCounter:统计指标收集器,比如平均值,最大值,最小值

  • PollingCounter:自定义统计指标收集器,通过自定义统计方法的方式实现对指标的统计

  • IncrementingEventCounter:累加指标收集器,采集一定时间段内的指标汇总

  • IncrementingPollingCounter:自定义累加指标收集器,通过自定义累函数,实现指标收集


本例先说一下用PollingCounter实现自定义EventSource。

本例是定义了一个WorkingEventSouce事件源,定义了WorkingEventListener监听器,和发送指标采集指标的类型PollingCounterDemo。

WorkingEventSouce事件源

/// <summary>
/// Working业务事件源
/// </summary>
[EventSource(Name = "WorkingEventSource")]
public sealed class WorkingEventSource : EventSource
{public static readonly WorkingEventSource Instance = new WorkingEventSource();private PollingCounter _workingCounter;//间隔内总时间private double _elapsedMilliseconds = 0;//间隔内次数private int _times = 0;/// <summary>/// working-time 是dotnet-counters  --counters的参数/// </summary>private WorkingEventSource() =>_workingCounter = new PollingCounter("working-time", this, MetricProvider){DisplayName = "Working Time",DisplayUnits = "ms"};/// <summary>/// 自定义函数,来计算指标,本例模拟EventCounter的计算方式/// </summary>/// <returns></returns>double MetricProvider(){var value = _elapsedMilliseconds / _times;_elapsedMilliseconds = 0;_times = 0;return value;}/// <summary>/// Working发送业务指标/// </summary>/// <param name="elapsedMilliseconds"></param>public void Working(long elapsedMilliseconds){_times++;_elapsedMilliseconds += elapsedMilliseconds;}protected override void Dispose(bool disposing){_workingCounter?.Dispose();_workingCounter = null;base.Dispose(disposing);}
}

WorkingEventListener监听器

/// <summary>
/// 指标输出委托
/// </summary>
/// <param name="key"></param>
/// <param name="value"></param>
public delegate void WriteContent(string key, string value);
/// <summary>
/// 指标监听器
/// </summary>
public class WorkingEventListener : EventListener
{protected readonly string[] _countersName = new string[] { "WorkingEventSource" };public event WriteContent WriteEvent;protected override void OnEventSourceCreated(EventSource source){if (_countersName.Contains(source.Name)){EnableEvents(source, EventLevel.Verbose, EventKeywords.All, new Dictionary<string, string>(){["EventCounterIntervalSec"] = "1"});}}protected override void OnEventWritten(EventWrittenEventArgs eventData){if (eventData.EventName.Equals("EventCounters")){for (int i = 0; i < eventData.Payload.Count; ++i){if (eventData.Payload[i] is IDictionary<string, object> eventPayload){var counterName = "";var counterValue = "";if (eventPayload.TryGetValue("DisplayName", out object displayValue)){counterName = displayValue.ToString();}if (eventPayload.TryGetValue("Mean", out object value) ||eventPayload.TryGetValue("Increment", out value)){counterValue = value.ToString();}WriteEvent(counterName, counterValue);}}}}
}

发送指标采集指标的类型PollingCounterDemo

public class PollingCounterDemo
{public static void Run(){var listener = new WorkingEventListener();listener.WriteEvent += Listener_WriteEvent;new Thread(Working).Start();}//以控制台方式展示采集到的指标private static void Listener_WriteEvent(string key, string value){Console.WriteLine($"{key}:{value}");}/// <summary>/// 模拟写业务指标,每秒写两次,i递增/// </summary>static void Working(){int i = 0;while (true){var count = i;Console.WriteLine(count);WorkingEventSource.Instance.Working(count);System.Threading.Thread.Sleep(500);i += 1;}}
}

运行结果如下,当然这个值是MetricProvider计算出来的,可以按自己收集指标的算法,算每次采集到的值并返回

本文来自互联网用户投稿,该文观点仅代表作者本人,不代表本站立场。本站仅提供信息存储空间服务,不拥有所有权,不承担相关法律责任。如若转载,请注明出处:http://www.mzph.cn/news/300100.shtml

如若内容造成侵权/违法违规/事实不符,请联系多彩编程网进行投诉反馈email:809451989@qq.com,一经查实,立即删除!

相关文章

这9个人气超高的公众号,你还没关注吗?

有些人&#xff0c;生活离不开朋友圈朋友圈是他们展示自我、观察世界的一扇窗户而有些人&#xff0c;从来也不点开朋友圈他们更愿意利用地铁上的零散化时间看点有意义、有知识的公众号推送完成对自我知识库的更新今天为大家推荐以下优质订阅号Kindle杂志公社ID&#xff1a;Mag1…

客户要求ASP.NET Core API返回特定格式,怎么办?

当ASP.NET Core API提供给到外部系统使用时&#xff0c;在某些情况下&#xff0c;可能需要根据这些外部系统的要求来格式化数据。比如&#xff0c;客户就要求API的返回值属性名必须是PascalCase&#xff08;如UserName&#xff09;&#xff0c;但是这些API需要同时提供给内部系…

Ubuntu 12.04 x64 下安装 GStreamer+FFmpeg+Opencv

Ubuntu 12.04 x64 下安装 GStreamerFFmpegOpencv近期&#xff0c;因为安装这三个开发软件&#xff0c;搞编译环境&#xff0c;上网找方法&#xff0c;足足耗费了我一个多星期的时间&#xff0c;现在将经验记录一下&#xff0c;在虚拟机和实体机上亲测成功安装。总流程&#xff…

html试题及答案,HTML试题及答案

A&#xff0e;照片、油画和一些细腻、讲求色彩浓淡的图片常采用JPEG格式B&#xff0e;JPEG支持很高的压缩率&#xff0c;因此其图像的下载速度非常快C&#xff0e;最高只能以256色显示的用户可能无法观看JPEG图像D&#xff0e;采用JPEG格式对图片进行压缩后&#xff0c;还能再打…

(转)程序员的十层楼11层(上帝)

第11层 上帝 看了上面的小标题&#xff0c;你可能会觉得奇怪&#xff0c;这篇文章不是讲“程序员的十层楼”吗&#xff1f;怎么冒出了第11层来了&#xff1f;其实这并不矛盾&#xff0c;程序员确实只有十层楼&#xff0c;因为爬到第11层时&#xff0c;已经变成上帝&#xff0c;…

史上最神奇的公式,竟然藏着这么多秘密!

全世界只有3.14 % 的人关注了青少年数学之旅前两天&#xff0c;我们的【欧拉公式—数学史上最强公式】数学经典文化衫首发众筹&#xff01;没想到短短几天时间文化衫就售罄了&#xff0c;其火爆程度远远超出了超模君的预期&#xff0c;甚至连不少“白嫖党”遇上这款文化衫后都情…

HiccDS共享音乐列表

Donet 第七组共享音乐列表200.7.7.18

html插入图片和文字,HTML第三课文字图片插入

HTML学习班第三课文字与图片的插入朋友们这一课我们一起来学习一下“文字与图片”的插入&#xff1a;一&#xff1a;首先我们先看一下插入文字的语法&#xff1a;例1&#xff1a;“朋友们好”这几个字的代码&#xff1a;朋友们好朋友们好说明&#xff1a;朋友们不难看出“朋友们…

Linux操作系统下Sudo命令的使用方法说明

“Sudo” 是Unix/Linux平台上的一个非常有用的工具&#xff0c;它允许系统管理员分配给普通用户一些合理的“权利”&#xff0c;让他们执行一些只有超级用户或其他特许用户才能完成的任务&#xff0c;比如&#xff1a;运行一些像mount&#xff0c;halt&#xff0c;su之类的命令…

Object C学习笔记11-数组

在Object C也提供了类似C#中的Array数组对象&#xff0c;在Object C中使用NSArray 来创建数组&#xff1b;但是在Object C中NSArray 只能存放对象类型的指针&#xff0c;不能存放int&#xff0c;char,double等基本数据类型。 一. 不可变数组对象 这个和之前的NSString有些类似&…

社区 正式发布了跨平台的 CoreWCF 0.2.0

在发布 CoreWCF 0.1.0 GA版本的半年之后&#xff0c;今天正式发布了0.2.0 版本&#xff0c;具体说明参看 https://github.com/CoreWCF/CoreWCF/releases/tag/v0.2.0 .NET 兼容性此版本依赖于 .NET Standard 2.0&#xff0c;可在支持 .NET Standard 2.0 的任何 .NET 版本上运行。…

你是不是在混日子,看着一点就知道了

全世界只有3.14 % 的人关注了青少年数学之旅2019已经进入倒计时了&#xff0c;年初立下的flag倒了几个&#xff1f;史蒂夫马丁有一句话&#xff1a;“所有的人生谜语都可以从阅读中找到答案。”无论是读影评、读好书&#xff0c;亦或者涉猎趣闻轶事、汲取犀利观点&#xff0c;总…

寻找网络高手

亲爱的朋友&#xff1a;您好&#xff01;寻找网络高手做行业门户网站<?xml:namespace prefix o ns "urn:schemas-microsoft-com:office:office" />我不熟悉电脑&#xff0c;却想成功一个行业网站。知道网络高手创办的网站成功率为 6 %&#xff0c;但坚信不撞…

新编计算机英语第六章,新编计算机英语-电子教案.ppt

《新编计算机英语-电子教案.ppt》由会员分享&#xff0c;可在线阅读&#xff0c;更多相关《新编计算机英语-电子教案.ppt(23页珍藏版)》请在装配图网上搜索。1、Unit1MyComputer,SectionAComputeroverviewIntroductionHistory1.theanalyticalengine2.earlycomputers3.electroni…

client copy sap论坛上看到的

关于client copy 请教问题目前这里生产系统数据大概300G不到&#xff0c;但是要从生产机到测试机做client copy 要很长时间&#xff0c;一 次用scc3开启任务&#xff0c;足足copy了3天才copy了17%的表数据&#xff0c;这个是什么原因阿&#xff1f;哪位大侠说说看, 谢谢啦&am…

Apache Member、ALC Beijing 发起人姜宁:一个人走的很快,但是一群人能走得更远

一个人走的很快&#xff0c;但是一群人能走得更远——姜宁ApacheCon 是 Apache 软件基金会&#xff08;ASF&#xff09;的官方全球系列大会。作为久负盛名的开源盛宴&#xff0c;ApacheCon 在开源界备受关注&#xff0c;也是开源运动早期的知名活动之一。早在 1998 年&#xff…

如何把朋友升级成情侣?| 今日最佳

全世界只有3.14 % 的人关注了青少年数学之旅

java 多线程原理(一)

2019独角兽企业重金招聘Python工程师标准>>> 要说Java的多线程&#xff0c;首先要明白什么是多线程。 多线程&#xff0c;线程是程序中一个单一的顺序控制流程.在单个程序中同时运行多个线程完成不同的工作,称为多线程. 我勒个擦&#xff0c;定义好官方啊&#xf…

discuz!5.5.0安装方法及常见问题解决

今下午在前几天刚组好的windows xp sp2apache2.2.4mysql6.0php5.2.3&#xff08;下一次做成LAMP——Linux ApacheMysqlPHP&#xff09;的环境下装了discuz&#xff01;5.5.0。安装之前到网上下了一个ZendOptimizer-3.2.6-Windows-i386.zip&#xff08;最新版&#xff09;&#…