重学c#系列——DiagnosticListener [三十五]

Posted 2023-05-31 程序员其实就是一个写文档的工作,代码只是文档的一部分,一切皆

前言

简单介绍一下DiagnosticListener，一个比较常见的事件通知模型，可以说是事件发布订阅模型，常用于监控。

正文

直接编写代码:

using System.Diagnostics;

public class program

    public static void Main(string[] args)
    
        // 创建一个DiagnosticListener实例
        DiagnosticListener listener = new DiagnosticListener("MyListener");

        // 在启动和停止事件上记录信息
        listener.Subscribe(new MyListenerObserver());

        // 发出事件并记录
        listener.Write("MyEvent", new  Message = "Hello World" );

        Console.Read();
    


class MyListenerObserver : IObserver<KeyValuePair<string, object>>

    public void OnCompleted()
    
    

    public void OnError(Exception error)
    
        Console.WriteLine($"Error: error.Message");
    

    public void OnNext(KeyValuePair<string, object> value)
    
        Console.WriteLine($"EventName: value.Key - Payload: value.Value");
    

结果:

但是一般情况下，不这么写。

一般这样写:

public class program

    public static void Main(string[] args)
    
        DiagnosticListener.AllListeners.Subscribe(new MyObserver());

        Test test = new Test();
        test.Run();

        Console.Read();
    


class Test

    static DiagnosticListener listener = new DiagnosticListener("MyListener");

    public Test()
    
        
    

    public void Run()
    
        // 发出事件并记录
        listener.Write("MyEvent", new  Message = "Hello World" );
    


class MyObserver : IObserver<DiagnosticListener>

    private IDisposable subscription;

    public void OnCompleted()
    
        subscription.Dispose();
    

    public void OnError(Exception error)
    
        Console.WriteLine($"Error: error.Message");
    

    public void OnNext(DiagnosticListener listener)
    
        if (listener.Name == "MyListener")
        
            subscription = listener.Subscribe(new MyListenerObserver());
        
    


class MyListenerObserver : IObserver<KeyValuePair<string, object>>

    public void OnCompleted()
    
    

    public void OnError(Exception error)
    
        Console.WriteLine($"Error: error.Message");
    

    public void OnNext(KeyValuePair<string, object> value)
    
        Console.WriteLine($"EventName: value.Key - Payload: value.Value");
    

这样做的好处就是：比如Test 只需要关注自己的业务实现和事件发送，其他的外部监控订阅即可。

结

此系列逐步更新，这个用的比较多，但是还有人没用过所以写下。

重学C#之路

从毕业到现在也蛮久了，一直在用C#编程，但是长久以来从事的都是跟业务相关的功能，技术方面并不是太强，有些东西模棱两可掌握的并不牢固，甚至实现方式也有点老旧了，不过还是有必要重新学习一遍。

业务处理过程循环过程中经常会用到return、break、continue,具体功能如下：

static void Main(string[] args)
{
for (int i = 5; i > 0; i--)
{
if (i == 1)
{
return;//直接结束本方法，到1的位置
}
if (i == 2)
{
break;//直接结束循环，到2的位置
}
if (i == 3)
{
continue;//结束当前，继续执行循环
}
Console.WriteLine(i);
}//2
Console.ReadLine();
}//1

foreach循环中作用和for一致，这里不比较foreach与for的效率与优劣，具体使用还是要看具体的业务场景。

日常过程中还有另外一种循环方式forEach,只支持return，与for循环的continue作用类似，都是结束当前继续执行循环。PS：不支持break以及continue

List<int> intList = new List<int>() { 1, 2, 3, 4, 5, 6, 7, 8, 9 };

            intList.ForEach(c =>

            {

 

                if (c == 3)

                {

                    return;

                }

                else

                {

                    Console.WriteLine("c=:" + c);

                }

            });