一、關於Spring Cloud Sleuth與Zipkin

　　在 SpringCloud 之中提供的 Sleuth 技術可以實現微服務的呼叫跟蹤，也就是說它可以自動的形成一個呼叫連線線，通過這個連線線使得開發者可以輕鬆的找到所有微服務間關係，同時也可以獲取微服務所耗費的時間， 這樣就可以進行微服務呼叫狀態的監控以及相應的資料分析。

　　Zipkin是一個分散式追蹤系統，它有助於收集解決微服務架構中延遲問題所需的時序資料。它管理這些資料的收集和查詢。

　　應用程式用於向Zipkin報告時間資料。Zipkin UI還提供了一個依賴關係圖，顯示每個應用程式有多少跟蹤請求。如果你正在解決延遲問題或錯誤問題，則可以根據應用程式，跟蹤長度，註釋或時間戳過濾或排序所有跟蹤。一旦選擇了一個跟蹤，你可以看到每個跨度所花費的總跟蹤時間的百分比，從而可以確定問題應用程式。

二、快速構建Zipkin Server

　　示例版本：Spring Boot 1.5.15.RELEASE，Spring Cloud Edgware.SR3

　　（1）pom.xml 新增相關依賴包

    <dependencies>
        <dependency>
            <groupId>org.springframework.boot</groupId>
            <artifactId>spring-boot-starter-web</artifactId>
        </dependency>

        <!-- 熱啟動，熱部署依賴包，為了除錯方便，加入此包 -->
        <dependency>
            <groupId>org.springframework.boot</groupId>
            <artifactId>spring-boot-devtools</artifactId>
            <optional>true
 
</optional>
        </dependency>

        <!-- zipkin -->
        <dependency>
            <groupId>io.zipkin.java</groupId>
            <artifactId>zipkin-autoconfigure-ui</artifactId>
        </dependency>
        <dependency>
            <groupId>io.zipkin.java</groupId>
            <artifactId>zipkin-server</artifactId>
        </dependency>
    </dependencies>

    <!-- spring cloud dependencies -->
    <dependencyManagement>
        <dependencies>
            <dependency>
                <groupId>org.springframework.cloud</groupId>
                <artifactId>spring-cloud-dependencies</artifactId>
                <version>Edgware.SR3</version>
                <type>pom</type>
                <scope>import
 
</scope>
            </dependency>
        </dependencies>
    </dependencyManagement>

　　（2）啟動類新增相關注解

@SpringBootApplication
@EnableZipkinServer
public class ZipkinServiceApplication {
    public static void main(String[] args) {
        SpringApplication.run(ZipkinServiceApplication.class, args);
    }
}

　　（3）配置檔案

server:
  port: 9411

spring:
  application:
    name: zipkin-service

　　最終啟動後，訪問zipkin主介面：

三、ASP.NET Core整合Zipkin

3.1 示例環境準備

　　這裡仍然基於第一篇的示例進行修改，各個專案的角色如下表所示：

　　所有相關服務（除zipkin-service外）註冊到Eureka之後的服務列表：

3.2 想要測試的服務呼叫鏈路

　　瀏覽器通過API閘道器（Zuul）呼叫Premium-Service的API，在這個API中會呼叫Client-Service的API，當然，會通過服務發現（Eureka）來獲取Client-Service的URL。

3.3 以PremiumService為例新增相關配置

　　這裡以PremiumService為例，其他幾個Service參照下面的步驟依次新增配置即可。

　　（1）新增相關NuGet包

PM> Install-Package Steeltoe.Extensions.Logging.DynamicLogger 

PM> Install-Package Steeltoe.Management.ExporterCore　　　　 

PM> Install-Package Steeltoe.Management.TracingCore

　　（2）Program類新增動態日誌Provider

    public class Program
    {
        ......

        public static IWebHostBuilder CreateWebHostBuilder(string[] args) =>
            WebHost.CreateDefaultBuilder(args)
                .UseUrls("http://*:8030")
                .UseStartup<Startup>()
                .ConfigureLogging((builderContext, loggingBuilder) =>
                {
                    loggingBuilder.AddConfiguration(builderContext.Configuration.GetSection("Logging"));
                    // Add Steeltoe Dynamic Logging Provider
                    loggingBuilder.AddDynamicConsole();
                });
    }

　　Steeltoe的日誌提供器是對ASP.NET Core自身日誌器的進一步封裝，其在原始資料基礎上增加了如Spring Cloud Sleuth中一樣的額外資訊。

　　（3）Starup啟動類中新增相關配置

    public class Startup
    {
        ......

        public void ConfigureServices(IServiceCollection services)
        {
            ......
            // Add Steeltoe Distributed Tracing
            services.AddDistributedTracing(Configuration);
            // Export traces to Zipkin
            services.AddZipkinExporter(Configuration);

            services.AddMvc().SetCompatibilityVersion(CompatibilityVersion.Version_2_1);

            // Add Hystrix Metrics to container
            services.AddHystrixMetricsStream(Configuration);
        }

        public void Configure(IApplicationBuilder app, IHostingEnvironment env)
        {
            ......

            app.UseMvc();
            
            // Start Hystrix metrics stream service
            app.UseHystrixMetricsStream();
            // Start up trace exporter
            app.UseTracingExporter();
        }
    }

　　（4）appSettings新增相關配置 => 主要是zipkin server的相關資訊

"management": {
    "tracing": {
      "alwaysSample": true,
      "egressIgnorePattern": "/api/v2/spans|/v2/apps/.*/permissions|/eureka/.*|/oauth/.*",
      "exporter": {
        "zipkin": {
          "endpoint": "http://localhost:9411/api/v2/spans",
          "validateCertificates": false
        }
      }
    }
  }

四、快速驗證測試

　　（1）啟動Eureka, Zuul, Zipkin以及Premium-Service和Client-Service

　　（2）通過Zuul呼叫API　

　　（3）通過Zipkin UI檢視Trace

　　點選具體的Trace檢視Details

　　（4）點選“依賴分析”按鈕檢視依賴圖

五、小結

　　本文簡單地介紹了一下Spring Cloud Seluth與Zipkin，然後通過Java快速地構建了一個Zipkin Server，通過在ASP.NET Core中整合Zipkin並做了一個基本的微服務呼叫追蹤Demo。本示例的Zipkin Server的追蹤資料是基於記憶體，實際中應該整合ELK進行持久化。當然，我們也可以直接通過Zipkin的.NET客戶端來做。

示例程式碼

參考資料

作者：周旭龍

本文版權歸作者和部落格園共有，歡迎轉載，但未經作者同意必須保留此段宣告，且在文章頁面明顯位置給出原文連結。