讲解。net中使用DiagnosticSource的方法

　　介绍

本篇内容主要讲解“讲解。net中使用DiagnosticSource的方法”,感兴趣的朋友不妨来看看。本文介绍的方法操作简单快捷,实用性强。下面就让小编来带大家学习”讲解。net中使用DiagnosticSource的方法”吧!

<强>前言

DiagnosticSource是一个非常有意思的且非常有用的API,对于这些API它们允许不同的库发送命名事件,并且它们也允许应用程序订阅这些事件并处理它们,它使我们的消费者可以在运行时动态发现数据源并且订阅与其相关的数据源。

DiagnosticSource在AspNetCore, EntityFrameworkCore, HttpClient, SqlClient中被使用,在我们实际的开发过程中他使我们能够进行拦截请求与响应的http请求,数据库查询,对HttpContext, DbConnection, DbCommand, HttpRequestMessageand等对象的访问,甚至说在需要的时候我们可以进行修改这些对象来处理我们的业务。

下面我们将通过如下的简单示例来了解它。

<>强DiagnosticSource和EventSource区别

DiagnosticSource和EventSource在架构设计上很相似,他们的主要区别是EventSource它记录的数据是可序列化的数据,会被进程外消费,所以要求记录的对象必须是可以被序列化的。而DiagnosticSource被设计为在进程内处理数据,所以我们通过它拿到的数据信息会比较丰富一些,它支持非序列化的对象,比如HttpContext, HttpResponseMessage等。另外如果想在EventSource中获取DiagnosticSource中的事件数据,可以通过DiagnosticSourceEventSource这个对象来进行数据桥接。

<强>需求来了

为了更好的理解DiagnosticSource的工作方式,如下这个示例将拦截数据库请求,假设我们有一个简单的控制台应用程序,它向数据库发出请求并将结果输出到控制台。

class 程序 　　{ 　　public 才能;const  string  ConnectionString =,,,@"服务器=localhost;数据库=主;Trusted_Connection=True;“; 　　static 才能;async  Task  Main (string [], args) 　　{才能 　　,,,var  result =, await  (); 　　,,,Console.WriteLine(结果); 　　 　　,,} 　　public 才能static  async  Task,得到(),{ 　　,,,using  (var 连接=new  SqlConnection (ConnectionString)), 　　,,,{ 　　,,,,,return  await  connection.QuerySingleAsync (“SELECT  42;“); 　　,,,} 　　,,} 　　}

我们再来思考一下,假设来了一个需求:我们需要获取到所有数据库查询的执行时间,或者说我们要进行获取执行的一些sql语句或者数据进行存储作为记录我们该如何处理?
好了下面我们将尝试使用DiagnosticSource来实现该需求。

<强>使用System.Diagnostics。DiagnosticSource

来吧,我们先来创建一个类作为该事件的处理程序或者说作为该事件的消费者。

public  sealed  class  ExampleDiagnosticObserver 　　{}

下面我们将处理该事件,我们需要将这个类进行实例化,并且将它注册到静态对象中的观察器中DiagnosticListener。AllListeners,代码如下所示:

static  async  Task  Main (string [], args) 　　{ 　　var 才能;observer =, new  ExampleDiagnosticObserver (); 　　IDisposable 才能;subscription =, DiagnosticListener.AllListeners.Subscribe(观察者); 　　var 才能;result =, await  (); 　　Console.WriteLine才能(结果); 　　}

下面我们再来修改我们的ExampleDiagnosticObserver类,其实如上代码片段中编译器已经提醒我们要实现接口IObserver public  sealed  class  ExampleDiagnosticObserver :, IObserver 　　{ 　　public 才能;void  oncomplete () 　　,{大敌; 　　,,} 　　 　　public 才能;void  OnError (Exception 错误) 　　,{大敌; 　　,,} 　　 　　public 才能;void  OnNext (DiagnosticListener 价值) 　　{才能 　　,,,Console.WriteLine (value.Name); 　　,,} 　　}

接下来我们运行该程序,结果将在控制台进行打印如下所示:

SqlClientDiagnosticListener
SqlClientDiagnosticListener 42

看如上结果,这意味着在我们当前这个应用程序中的某个地方注册了两个类型为DiagnosticListener的对象,名字为SqlClientDiagnosticListener。

对于应用程序中创建的每个实例diagnosticsListener,在第一次使用时将调用IObserver .OnNext方法一次,现在我们只是将实例的名称输出到了控制台中,但实际情况中我们想一下,我们应该对这个实例名称做什么?对,没错,我们要对这些实例名称做检查,那么我们如果要对这个实例中某些事件,我们只需要使用订阅方法去订阅它。

讲解。net中使用DiagnosticSource的方法