2

利用 ASP.NET Core 中的标头传播实现分布式链路跟踪

 2 years ago
source link: https://blog.yuanpei.me/posts/asp-net-core-using-headerpropagation-for-distributed-tracking/
Go to the source link to view the article. You can view the picture content, updated content and better typesetting reading experience. If the link is broken, please click the button below to view the snapshot at that time.
利用 ASP.NET Core 中的标头传播实现分布式链路跟踪

在此之前，我曾写过一篇博客，《Envoy 集成 Jaeger 实现分布式链路跟踪》，主要分享了 ASP.NET Core 应用如何结合 Envoy 和 Jeager 来实现分布式链路跟踪，其核心思想是：生成一个全局唯一的x-request-id，并在不同的微服务或者子系统中传播该信息。进而，可以使得相关的信息像一条线上的珠子一样串联起来。在此基础上，社区主导并产生了 OpenTracing 规范，在这个 规范 中，一个 Trace，即调用链，是由多个 Span 组成的有向无环图，而每个 Span 则可以含有多个键值对组成的 Tag。不过，当时我们有一个非常尴尬的问题，那就是每个微服务必须显式地传递相关的 HTTP 请求头。那么，是否有一种更优雅的方案呢？而这就是我们今天要分享的内容。首先，我们来回头看看当初的方案，这是一个非常朴实无华的实现：

 1[HttpPost]
 2public async Task<IActionResult> Post([FromBody] OrderInfo orderInfo)
 3{
 4  var paymentInfo = new PaymentInfo()
 5  {
 6    OrderId = orderInfo.OrderId,
 7    PaymentId = Guid.NewGuid().ToString("N"),
 8    Remark = orderInfo.Remark,
 9  };
10
11  // 设置请求头
12  _httpClient.DefaultRequestHeaders.Add(
13      "x-request-id", Request.Headers["x-request-id"].ToString());
14  _httpClient.DefaultRequestHeaders.Add(
15      "x-b3-traceid", Request.Headers["x-b3-traceid"].ToString());
16  _httpClient.DefaultRequestHeaders.Add(
17      "x-b3-spanid", Request.Headers["x-b3-spanid"].ToString());
18  _httpClient.DefaultRequestHeaders.Add(
19      "x-b3-parentspanid", Request.Headers["x-b3-parentspanid"].ToString());
20  _httpClient.DefaultRequestHeaders.Add(
21      "x-b3-sampled", Request.Headers["x-b3-sampled"].ToString());
22  _httpClient.DefaultRequestHeaders.Add(
23      "x-b3-flags", Request.Headers["x-b3-flags"].ToString());
24  _httpClient.DefaultRequestHeaders.Add(
25      "x-ot-span-context", Request.Headers["x-ot-span-context"].ToString());
26
27  // 调用/Payment接口
28  var payload = JsonConvert.SerializeObject(paymentInfo)
29  var content = new StringContent(payload, Encoding.UTF8, "application/json");
30  var response = await _httpClient.PostAsync("/Payment", content);
31
32  var result = response.IsSuccessStatusCode ? "成功" : "失败";
33  return new JsonResult(new { Msg = $"订单创建{result}" });
34}

这里，最大的问题是，传递 HTTP 请求头的代码片段对正常的业务代码存在入侵，当别人调用某个微服务或者子系统的接口时，必须要加上这些代码片段，这实在是一件难受的事情。子曰，“己所不欲，勿施于人”，如果一段代码，你自己都感觉看不下去，那就说明这代码该重构啦！下面，我们考虑对其进行重构。首先，通过 NuGet 安装一个微软提供的包：

1dotnet add package Microsoft.AspNetCore.HeaderPropagation

接下来，我们在 Startup 中对 HeaderPropagation 进行简单配置：

 1services.AddHeaderPropagation(options =>
 2{
 3    // 如果请求头中含 X-BetaFeatures 字段，则传播该字段对应的值
 4    options.Headers.Add("X-BetaFeatures");
 5
 6    // 如果请求头中不含 X-BetaFeatures 字段，则生成一个新的值并进行传播
 7    // 注意，这里以 GUID 为例
 8    options.Headers.Add("X-BetaFeatures", context =>
 9    {
10        return Guid.NewGuid().ToString("N");
11    });
12});

那么，这些请求头会传播到哪里呢？答案是 HttpClient，所以，你可以想到，不管是 RESTful 风格的 API 还是 gRPC 都可以享受到这一便利：

 1// 传播所有注册过的请求头，如 X-BetaFeatures 
 2services
 3    .AddHttpClient("Ezio")
 4    .AddHeaderPropagation();
 5
 6// 仅传播指定的请求头，如 X-BetaFeatures、X-Experiments
 7services
 8    .AddHttpClient("Altaïr")
 9    .AddHeaderPropagation(options => {
10        options.Headers.Add("X-BetaFeatures", "X-Experiments");
11    });

最后，我们还需要在请求管道中启用相应的中间件：

1public void Configure(IApplicationBuilder app, IWebHostEnvironment env)
2{
3    // ...
4    // 注意：请放置在 app.UseRouting(); 前面
5    app.UseHeaderPropagation();
6
7    // ...
8}

对于我们而言，我们需要让 Jeager 相关的请求头传播下去，因此，我们只需要像下面这样改造即可。当然，这些请求头会由 Envoy 自动生成，所以，我们同样不需要考虑它不存在的情况：

 1services.AddHeaderPropagation(opt =>
 2{
 3    opt.Headers.Add("x-request-id");
 4    opt.Headers.Add("x-b3-traceid");
 5    opt.Headers.Add("x-b3-spanid");
 6    opt.Headers.Add("x-b3-parentspanid");
 7    opt.Headers.Add("x-b3-sampled");
 8    opt.Headers.Add("x-b3-flags");
 9    opt.Headers.Add("x-ot-span-context");
10});
11
12services.AddHttpClient("PaymentService", client =>
13{
14    client.BaseAddress = new Uri("http://127.0.0.1:9090");
15})
16.AddHeaderPropagation();

改造后的效果如何呢？博主表示，一切非常完美！

It’s Amazing！

关于这个中间件内部是如何运作的，大家可以阅读它的 源代码，博主这里画了一个简单的示意图来辅助说明：

HeaderPropagation 中间件示意图

可以注意到，这个中间件内部会维护一个叫做 HeaderPropagationValues 的对象实例，其生命周期为 Singleton，当有入站请求产生时，它会尝试从 HttpContext 中读取指定的请求头，并保存到 HeaderPropagationValues 实例的 Headers 属性中中。当我们注入 HttpClient 的时候，中间件内部会创建一个 HeaderPropagationMessageHandler 实例，它继承自 DelegatingHandler。如果你看过我以前的文章，《使用 HttpMessageHandler 实现 HttpClient 请求管道自定义》，相信你会在电光火石间明白我在说什么。总而言之，通过这个 Handler，你就可以把保存下来的请求头添加到 HttpClient 的实例上，相当于我们一开始手动设置请求头的这个环节，这样，这些请求头就可以“自动”传播下去啦！

通过 HeaderPropagation 中间件传递请求头字段

其实，除了这个分布式链路跟踪的场景，更一般的场景，或许是认证的场景。譬如，客户端通过认证服务拿到了一个令牌，它在向后端发起请求的时候，会把这个令牌添加到请求头中。此时，我们只需要确保所有后端服务都配置了这个中间件，令牌会随着调用链路一路传播下去，这样，是不是比每个服务间都相互协商如何传递身份信息要好的多呢？我想，这是毫无疑问的，做正确的事情永远比单纯的做事情要重要得多。好啦，以上就是这篇博客的全部内容啦，如果大家对博客内容有任何意见或者建议，欢迎大家在评论区留言，谢谢大家！


report

Recommend

About Joyk


Aggregate valuable and interesting links.
Joyk means Joy of geeK