在自定義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計算出來的，可以按自己收集指標的算法，算每次采集到的值并返回

總結

以上是生活随笔為你收集整理的自定义EventSource（二）PollingCounter的全部內容，希望文章能夠幫你解決所遇到的問題。

如果覺得生活随笔網站內容還不錯，歡迎將生活随笔推薦給好友。