前言
最近我們公司的部分.NET Core的項(xiàng)目接入了Jaeger，也算是稍微完善了一下.NET團(tuán)隊(duì)的技術(shù)棧。
至于為什么選擇Jaeger而不是Skywalking，這個(gè)問(wèn)題我只能回答，大佬們說(shuō)了算。
前段時(shí)間也在CSharpCorner寫(xiě)過(guò)一篇類似的介紹
Exploring Distributed Tracing Using ASP.NET Core And Jaeger。
下面回到正題，我們先看一下Jaeger的簡(jiǎn)介
Jaeger的簡(jiǎn)單介紹
Jaeger是Uber開(kāi)源的一個(gè)分布式追蹤的工具，主要為基于微服務(wù)的分布式系統(tǒng)提供監(jiān)測(cè)和故障診斷。包含了下面的內(nèi)容
- Distributed context propagation
- Distributed transaction monitoring
- Root cause analysis
- Service dependency analysis
- Performance / latency optimization
下面就通過(guò)一個(gè)簡(jiǎn)單的例子來(lái)體驗(yàn)一下。
示例
在這個(gè)示例的話，我們只用了jaegertracing/all-in-one這個(gè)docker的鏡像來(lái)搭建，因?yàn)槭潜镜氐拈_(kāi)發(fā)測(cè)試環(huán)境，不需要搭建額外的存儲(chǔ)，這個(gè)感覺(jué)還是比較貼心的。
我們會(huì)用到兩個(gè)主要的nuget包
- Jaeger 這個(gè)是官方的client
- OpenTracing.Contrib.NetCore.Unofficial 這個(gè)是對(duì).NET Core探針的處理，從opentracing-contrib/csharp-netcore這個(gè)項(xiàng)目移植過(guò)來(lái)的(這個(gè)項(xiàng)目并不活躍，只能自己做擴(kuò)展)
然后我們會(huì)建兩個(gè)API的項(xiàng)目，一個(gè)是AService，一個(gè)是BService。
其中BService會(huì)提供一個(gè)接口，從緩存中讀數(shù)據(jù)，如果讀不到就通過(guò)EF Core去從sqlite中讀，然后寫(xiě)入緩存，最后再返回結(jié)果。
AService 會(huì)通過(guò)HttpClient去調(diào)用BService的接口，從而會(huì)形成調(diào)用鏈。
開(kāi)始之前，我們先把docker-compose.yml配置一下
|
1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27
28
29
30
31
32
33
34
35
36
37
38
39
40
41
42
43
44
45
46
|
version: '3.4'services: aservice: image: ${DOCKER_REGISTRY-}aservice build: context: . dockerfile: AService/Dockerfile ports: - "9898:80" depends_on: - jagerservice - bservice networks: backend: bservice: image: ${DOCKER_REGISTRY-}bservice build: context: . dockerfile: BService/Dockerfile ports: - "9899:80" depends_on: - jagerservice networks: backend: jagerservice: image: jaegertracing/all-in-one:latest environment: - COLLECTOR_ZIPKIN_HTTP_PORT=9411 ports: - "5775:5775/udp" - "6831:6831/udp" - "6832:6832/udp" - "5778:5778" - "16686:16686" - "14268:14268" - "9411:9411" networks: backend: networks: backend: driver: bridge |
然后就在兩個(gè)項(xiàng)目的Startup加入下面的一些配置，主要是和Jaeger相關(guān)的。
|
1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27
28
29
30
|
public void ConfigureServices(IServiceCollection services){ // others .... // Adds opentracing services.AddOpenTracing(); // Adds the Jaeger Tracer. services.AddSingleton<ITracer>(serviceProvider => { string serviceName = serviceProvider.GetRequiredService<IHostingEnvironment>().ApplicationName; var loggerFactory = serviceProvider.GetRequiredService<ILoggerFactory>(); var sampler = new ConstSampler(sample: true); var reporter = new RemoteReporter.Builder() .WithLoggerFactory(loggerFactory) .WithSender(new UdpSender("jagerservice", 6831, 0)) .Build(); var tracer = new Tracer.Builder(serviceName) .WithLoggerFactory(loggerFactory) .WithSampler(sampler) .WithReporter(reporter) .Build(); GlobalTracer.Register(tracer); return tracer; });} |
這里需要注意的是我們要根據(jù)情況來(lái)選擇sampler，演示這里用了最簡(jiǎn)單的ConstSampler。
回到BService這個(gè)項(xiàng)目，我們添加SQLite和EasyCaching的相關(guān)支持。
|
1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27
|
public void ConfigureServices(IServiceCollection services){ // Adds an InMemory-Sqlite DB to show EFCore traces. services .AddEntityFrameworkSqlite() .AddDbContext<BDbContext>(options => { var connectionStringBuilder = new SqliteConnectionStringBuilder { DataSource = ":memory:", Mode = SqliteOpenMode.Memory, Cache = SqliteCacheMode.Shared }; var connection = new SqliteConnection(connectionStringBuilder.ConnectionString); connection.Open(); connection.EnableExtensions(true); options.UseSqlite(connection); }); // Add EasyCaching Inmemory provider. services.AddEasyCaching(options => { options.UseInMemory("m1"); });} |
然后控制器上面就比較簡(jiǎn)單了。
|
1
2
3
4
5
6
7
8
9
10
|
// GET api/values[HttpGet]public async Task<IActionResult> GetAsync(){ var provider = _providerFactory.GetCachingProvider("m1"); var obj = await provider.GetAsync("mykey", async () => await _dbContext.DemoObjs.ToListAsync(), TimeSpan.FromSeconds(30)); return Ok(obj);} |
AService就是通過(guò)HttpClient去調(diào)用上面的這個(gè)接口即可。
|
1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
|
// GET api/values[HttpGet]public async Task<string> GetAsync(){ var res = await GetDemoAsync(); return res;} private async Task<string> GetDemoAsync(){ var client = _clientFactory.CreateClient(); var request = new HttpRequestMessage { Method = HttpMethod.Get, }; var response = await client.SendAsync(request); response.EnsureSuccessStatusCode(); var body = await response.Content.ReadAsStringAsync(); return body;} |
到這里的話，代碼這塊是ok了，下面就來(lái)看看效果。
先通過(guò)http://localhost:9898/api/values/訪問(wèn)幾次AService
大概能得到一個(gè)這樣的結(jié)果
然后去Jaeger的界面上我們可以看到，兩個(gè)服務(wù)已經(jīng)注冊(cè)上來(lái)了。
選A，B其中一個(gè)去搜索，就可以看到下面的結(jié)果
這個(gè)就最外層，能看到這些請(qǐng)求一些宏觀的信息。
我們選界面上最后一個(gè)，也就是第一個(gè)請(qǐng)求，進(jìn)去看看細(xì)節(jié)
從上面這個(gè)圖大概也能看出來(lái)，做了一些什么操作，請(qǐng)求來(lái)到AService，它就發(fā)起了HTTP請(qǐng)求到BService，BService則是先通過(guò)EasyCaching去取緩存，顯然緩存中沒(méi)數(shù)據(jù)，它就去讀數(shù)據(jù)庫(kù)了。
和另外的請(qǐng)求對(duì)比一下，可以發(fā)現(xiàn)是少了查數(shù)據(jù)庫(kù)這一步操作的。這也是為什么上面的是10個(gè)span，而下面的才8個(gè)。
再來(lái)看看兩個(gè)請(qǐng)求的對(duì)比圖。
上圖中那些紅色和綠色的塊就是兩個(gè)請(qǐng)求的差異點(diǎn)了。
回去看看其他細(xì)節(jié)，可以發(fā)現(xiàn)類似下面的內(nèi)容
有很多日志相關(guān)的東西，這些東西在這里可能沒(méi)有太多實(shí)際的作用，我們可以通過(guò)調(diào)整日志的級(jí)別來(lái)不讓它寫(xiě)入到Jaeger中。
或者是通過(guò)下面的方法來(lái)過(guò)濾
|
1
2
3
4
|
services.AddOpenTracing(new System.Collections.Generic.Dictionary<string,LogLevel>{ {"AService", LogLevel.Information}}); |
最后就是依賴圖了。
寫(xiě)在最后
雖說(shuō)Jaeger用起來(lái)挺簡(jiǎn)單的，但是也是有點(diǎn)美中不足的，不過(guò)這個(gè)鍋不應(yīng)該是Jaeger來(lái)背的，主要還是很多我們常用的庫(kù)沒(méi)有直接的支持Diagnostic，所以能監(jiān)控到的東西還是略少。
不過(guò)在github發(fā)現(xiàn)了ClrProfiler.Trace這個(gè)項(xiàng)目，可以通過(guò)clrprofiler來(lái)解決上面的問(wèn)題。
最后是本文的示例代碼
總結(jié)
以上就是這篇文章的全部?jī)?nèi)容了，希望本文的內(nèi)容對(duì)大家的學(xué)習(xí)或者工作具有一定的參考學(xué)習(xí)價(jià)值，謝謝大家對(duì)服務(wù)器之家的支持。
原文鏈接：https://www.cnblogs.com/catcher1994/p/10662999.html
