DiagnosticSource DiagnosticListener 无侵入式分布式跟踪

ASP.NET Core 中的框架中发出大量诊断变乱，包罗当前请求进入请求完成变乱，HttpClient发出收到与响应，EFCore查询等等。
我们可以利用DiagnosticListener来选择性地监听这些变乱，然后通过自己的方式构造这些日志，实现无侵入的分布式跟踪。
下面我们通过DiagnosticSource监听EFCore，与HTTPClient，实现链路追踪。
创建监听
现在我们将配置一个DiagnosticListener来监听全部变乱。 
首先，我们需要一个IObserver，我们将使用它来订阅全部变乱。

1. public class TestDiagnosticObserver : IObserver<DiagnosticListener>
2. {
3.     public void OnNext(DiagnosticListener value)
4.     {
5.         value.Subscribe(new TestKeyValueObserver());
6.     }
7.     public void OnCompleted() { }
8.     public void OnError(Exception error) { }
9. }

复制代码

 此中重要的方法是OnNext。然后我们传入另一个自定义类型TestKeyValueObserver，这是实际接收实例发出的变乱的类DiagnosticListener。该变乱会接受KeyValuePair参数，我们后续可针对此参数做业务相关的筛选。

1. public class TestKeyValueObserver : IObserver<KeyValuePair<string, object?>>
2. {
3.     public void OnNext(KeyValuePair<string, object?> value)
4.     {
5.         var activity = Activity.Current;
7.         Console.WriteLine($"traceId {activity?.TraceId} Received event: {value.Key}");
8.     }
9.     public void OnCompleted() { }
10.     public void OnError(Exception error) { }
11. }

复制代码

 
最后一步是在应用步伐中注册我们的步伐TestDiagnosticObserver。

1. DiagnosticListener.AllListeners.Subscribe(new TestDiagnosticObserver());

复制代码

 
创建HTTP请求与EFCore查询
我们新建一个接口，用来集成EF与HttpClient。并调用这个接口检察DiagnosticListener 监听到的内容

1. [HttpGet]
2. public async Task<string> GetAsync()
3. {
4.     //HTTP
5.     await _httpClient.GetAsync("https://www.baidu.com");
7.     //EF
8.     Item item = new Item()
9.     {
10.         Barcode = Guid.NewGuid().ToString(),
11.         Brand = "Milky Way",
12.         Name = "Milk",
13.         PruchasePrice = 20.5,
14.         SellingPrice = 25.5
15.     };
16.     _productsContext.Items.Add(item);
17.     _productsContext.SaveChanges();
18.     return "OK";
19. }

复制代码

 
调用此接口来看看我们的DiagnosticListener的效果。
可以看到收到了很多Event，包罗当前请求的各个阶段，HttpClient的各个阶段，与EFCore查询的各个阶段。

 
剖析Event
然后修改TestKeyValueObserver，我们从中挑选我们需要的HTTPClient与EFCore相关的变乱。

1. public class TestKeyValueObserver : IObserver<KeyValuePair<string, object?>>
2. {
3.     public void OnNext(KeyValuePair<string, object?> value)
4.     {
5.         var activity = Activity.Current;
7.         //Console.WriteLine($"traceId {activity?.TraceId} Received event: {value.Key}");
8.         if (value.Key.StartsWith("System.Net.Http.Request"))
9.         {
10.             var cEventStr = JsonConvert.SerializeObject(value.Value);
11.             var cEvent = JsonConvert.DeserializeAnonymousType(cEventStr, new { Request = new { RequestUri = ""} , Timestamp = 2879029490722 });
12.             Console.WriteLine($"traceId {activity?.TraceId} Request.Start: {cEvent.Timestamp} ");
13.             Console.WriteLine($"traceId {activity?.TraceId} Request.Uri: {cEvent.Request.RequestUri} ");
14.         }
15.         if (value.Key.StartsWith("System.Net.Http.Response"))
16.         {
17.             var cEventStr = JsonConvert.SerializeObject(value.Value);
18.             var cEvent = JsonConvert.DeserializeAnonymousType(cEventStr, new { Request = new { RequestUri = "" }, Timestamp = 2879029490722 });
19.             Console.WriteLine($"traceId {activity?.TraceId} Http.Response: {cEvent.Timestamp} ");
20.         }
23.         if (value.Key.StartsWith("Microsoft.EntityFrameworkCore.Database.Connection.ConnectionOpening"))
24.         {
25.             var cEvent = (Microsoft.EntityFrameworkCore.Diagnostics.ConnectionEventData)value.Value;
26.             Console.WriteLine($"traceId {activity?.TraceId} Connection.ConnectionOpening: {cEvent?.StartTime.ToString("yyyy-MM-dd HH:mm:ss:fff")} ");
27.         }
28.         if (value.Key.StartsWith("Microsoft.EntityFrameworkCore.Database.Command.CommandExecuting"))
29.         {
30.             var cEvent = (Microsoft.EntityFrameworkCore.Diagnostics.CommandEventData)value.Value;
31.             Console.WriteLine($"traceId {activity?.TraceId}  {cEvent?.Command.CommandText} ");
32.         }
33.         if (value.Key.StartsWith("Microsoft.EntityFrameworkCore.Database.Connection.ConnectionClosed"))
34.         {
35.             var cEvent = (Microsoft.EntityFrameworkCore.Diagnostics.ConnectionEventData)value.Value;
36.             Console.WriteLine($"traceId {activity?.TraceId} Connection.ConnectionClosed: {cEvent?.StartTime.ToString("yyyy-MM-dd HH:mm:ss:fff")} ");
37.         }
38.     }
39.     public void OnCompleted() { }
40.     public void OnError(Exception error) { }
41. }

复制代码

 
再次启动，检察效果，可以看到已经获取到了http请求的开始竣事变乱，EF的查询语句，开始变乱等。

 
最后我们可以布局化这些数据，并将其持久化到自己的监控体系中，实现链路跟踪。

免责声明：如果侵犯了您的权益，请联系站长，我们会及时删除侵权内容，谢谢合作！更多信息从访问主页：qidao123.com:ToB企服之家，中国第一个企服评测及商务社交产业平台。