使用 Tye 辅助开发 k8s 应用竟如此简单（五）

newbe36524

关注

发布于: 2021 年 02 月 23 日

续上篇，这篇我们来进一步探索 Tye 更多的使用方法。本篇我们来了解一下如何在 Tye 中实现对分布式链路追踪。

Newbe.Claptrap 是一个用于轻松应对并发问题的分布式开发框架。如果您是首次阅读本系列文章。建议可以先从本文末尾的入门文章开始了解。

我是谁？我在哪儿？我咋了？

分布式系统纷繁复杂，特别以现在微服务架构的出现，使得应用系统中的应用实例变得更加多变难以捉摸。

那么如何在如此繁杂的系统中找到一条业务调用链的上下游关系、性能细节、业务数据等等成为了一项开发者必然要面对的挑战。

使用分布式链路追踪系统无非是解决该问题的一个良好方法。目前市面上也有非常多可用的开源方案，其中不乏开箱即用的优秀用例：SkyWalking、Jaeger 和 Zipkin 等等。

本篇，我们将探索 Tye 中已经实现扩展的 Zipkin 来演示一下分布式链路追踪的简易效果。

创建测试应用

要测试分布式情况，那么至少需要两个应用实例才能够体现效果。因此，此处创建两个测试服务实例：

create-tye-zipkin-test.sh

dotnet new sln -n TyeTest
dotnet new webapi -n TyeTestdotnet add ./TyeTest/TyeTest.csproj package Microsoft.Tye.Extensions.Configuration --version 0.6.0-alpha.21070.5dotnet sln ./TyeTest.sln add ./TyeTest/TyeTest.csproj
dotnet new webapi -n TyeTest2dotnet sln ./TyeTest.sln add ./TyeTest2/TyeTest2.csprojtye init

复制代码

在 TyeTest 项目的 Startup.cs 增加对 HttpClientFactory 的注册。

  public void ConfigureServices(IServiceCollection services)  {+     services.AddHttpClient();      services.AddControllers();      services.AddSwaggerGen(c =>      {          c.SwaggerDoc("v1", new OpenApiInfo { Title = "TyeTest", Version = "v1" });      });  }

复制代码

进入 WeatherForecastController，我们使用 HttpClient 来调用下游服务，并且将得到的数据返回：

using System;using System.Collections.Generic;using System.Linq;using System.Net.Http;using System.Text.Json;using System.Threading.Tasks;using Microsoft.AspNetCore.Mvc;using Microsoft.Extensions.Configuration;using Microsoft.Extensions.Logging;
namespace TyeTest.Controllers{    [ApiController]    [Route("[controller]")]    public class WeatherForecastController : ControllerBase    {        private readonly ILogger<WeatherForecastController> _logger;        private readonly IConfiguration _configuration;        private readonly HttpClient _httpClient;
        public WeatherForecastController(ILogger<WeatherForecastController> logger,            IConfiguration configuration,            HttpClient httpClient)        {            _logger = logger;            _configuration = configuration;            _httpClient = httpClient;        }
        [HttpGet]        public async Task<string> Get()        {            var serviceUri = _configuration.GetServiceUri("tyetest2");            Console.WriteLine(serviceUri);            var httpResponseMessage = await _httpClient.GetAsync($"{serviceUri}WeatherForecast");            var json = await httpResponseMessage.Content.ReadAsStringAsync();            return json;        }    }}

复制代码

这样，我们就得到了一个在服务 TyeTest 中调用 TyeTest2 的一个服务间调用的示例。

这其实和使用 Tye 辅助开发 k8s 应用竟如此简单（二）中得到的测试用例是相同的。

然后使用 tye run 便可以启用测试应用。开发者可以在 swagger 页面中测试具体的效果。

但是！其实没完。此处我们还需要修改 Program.cs 变更默认的 Activity.DefaultIdFormat:

Program.cs

using System;using System.Collections.Generic;using System.Diagnostics;using System.Linq;using System.Threading.Tasks;using Microsoft.AspNetCore.Hosting;using Microsoft.Extensions.Configuration;using Microsoft.Extensions.Hosting;using Microsoft.Extensions.Logging;
namespace TyeTest{    public class Program    {        public static void Main(string[] args)        {            Activity.DefaultIdFormat = ActivityIdFormat.W3C;            CreateHostBuilder(args).Build().Run();        }
        public static IHostBuilder CreateHostBuilder(string[] args) =>            Host.CreateDefaultBuilder(args)                .ConfigureWebHostDefaults(webBuilder =>                {                    webBuilder.UseStartup<Startup>();                });    }}

复制代码

注意，两个应用都需要修改。

这将会在消息请求头中添加这是一种符合 W3C 标准追踪头信息。不过，如果开发者是 net5 应用，则不需要变更了，因为这已经是默认行为。有关此内容的详细信息，开发者可以参阅：

启用 Zipkin

接下来，我们修改 tye.yml 来启用 zipkin 以监控服务间的调用：

tye.yml

name: tyetestextensions:  - name: zipkinservices:  - name: tyetest    project: TyeTest/TyeTest.csproj  - name: tyetest2    project: TyeTest2/TyeTest2.csproj

复制代码

没错，其实只是加了 extensions 就完成了。

使用 tye run，启动应用，便可以在 dashboard 中查看到自动部署起来的 zipkin：

打开对应链接，便可以看到对应的 zipkin 查询界面：

然后，我们打开 tyetest 服务的 swagger 界面，进行一次调用。然后在回来查询，便可以查询到服务调用的情况：

点击其中的 Show 按钮，便可以查看到一次服务调用的详细过程信息：

这就是使用 zipkin 对 http 调用进行追踪的最简易示例。

自行部署 Zipkin

和 seq 一样，开发者可以使用已经部署好的 zipkin 以便重复利用，避免每次都要启动浪费时间。

docker-compose.yml

version: '3.3'
services:  zipkin:    image: openzipkin/zipkin    restart: always    container_name: zipkin    ports:      - 9411:9411

复制代码

tye.yml

name: tyetestextensions:  - name: zipkinservices:  - name: tyetest    project: TyeTest/TyeTest.csproj  - name: tyetest2    project: TyeTest2/TyeTest2.csproj  - name: zipkin    external: true    bindings:      - name: http        containerPort: 9411

复制代码

和 seq 一样，通过自行部署 zipkin 实例。然后修改 tye.yml 使得服务得以连接。预期效果与前面一节相同。但是节约了每次启动都需要启动 zipkin 实例的时间。

Jaeger 也可以

实际上，只要是 zipkin 协议兼容的收集端，那么都可以被这种方式集成。因此，我们该用 Jaeger 作为后端进行测试。

docker-compose.yml

version: '3.3'services:  jaeger:    image: jaegertracing/all-in-one:1.21    restart: always    ports:      - 9411:9411      - 16686:16686    environment:      COLLECTOR_ZIPKIN_HTTP_PORT: 9411

复制代码

tye.yml 和先前对比没有变化。

启用并测试应用。便可以在 jaeger dashboard 得到类似的结果：