Spring Cloud はマイクロサービス アーキテクチャを構築します: 分散サービス トラッキング (はじめに)

これまでの N 回のブログ投稿の紹介を通じて、実際にそれらを使用してビジネス ニーズを満たす基本的なマイクロサービス アーキテクチャ システムを構築することができました。しかし、ビジネスが発展するにつれて、システムの規模はどんどん大きくなり、マイクロサービス間の呼び出し関係はどんどん複雑になっていきます。

通常、クライアントによって開始されたリクエストは、バックエンド システム内の複数の異なるマイクロサービス呼び出しを経て、最終的なリクエスト結果が共同で生成されます。複雑なマイクロサービス アーキテクチャ システムでは、ほぼすべてのフロントエンド要求が複雑な分散サービス呼び出しリンクを形成します。各リンク内の依存サービスに過度の遅延またはエラーが発生すると、最終的なリクエストが失敗する可能性があります。この時点で、各リクエストのリンク全体を追跡することがますます重要になります。リクエスト呼び出しを追跡すると、エラーの根本原因を迅速に見つけ、各リクエスト リンクのパフォーマンスのボトルネックを監視および分析するのに役立ちます。

[[221306]]

Spring Cloud Sleuth は、上記の分散サービス追跡問題に対する完全なソリューションを提供します。この章では、Spring Cloud Sleuth を使用してマイクロサービス アーキテクチャに分散サービス トレース機能を追加する方法について詳しく説明します。

クイックスタート

さまざまな概念と原則を紹介する前に、まず簡単な例を実装して、サービス呼び出しを使用してアプリケーションにいくつかの Sleuth 構成を追加し、基本的なサービス追跡機能を実装します。これにより、Spring Cloud Sleuth を事前に理解し、その後、実装プロセスの詳細を徐々に紹介します。

準備

Sleuth を導入する前に、まず前の章で学んだ内容に従って準備作業を行い、いくつかの基本的な機能とアプリケーションを構築します。

• サービス登録センター: eureka-server。ここでは詳細には触れず、以前に構築したプロジェクトを直接使用します。または、次の例で使用されている私の公共福祉ユーレカ レジストリを直接使用することもできます。
• マイクロサービス アプリケーション: trace-1 は REST インターフェイス /trace-1 を実装し、このインターフェイスを呼び出すと trace-2 アプリケーションへの呼び出しがトリガーされます。具体的な実装は以下のとおりです。
• 基本的な Spring Boot アプリケーションを作成し、pom.xml に次の依存関係を追加します。

 <親>
    <groupId>org.springframework.boot</groupId>
    <artifactId>spring-boot-starter-parent</artifactId>
    <バージョン>1.5.10.RELEASE</バージョン>
    <相対パス/>
 </親>
 <依存関係>
    <groupId>org.springframework.boot</groupId>
    <artifactId>spring-boot-starter-web</artifactId>
 </依存関係>
 <依存関係>
    <groupId>org.springframework.cloud</groupId>
    <artifactId>spring-cloud-starter-eureka</artifactId>
 </依存関係>
 <依存関係>
    <groupId>org.springframework.cloud</groupId>
    <artifactId>スプリングクラウドスターターリボン</artifactId>
 </依存関係>
 <依存関係管理>
    <依存関係>
        <依存関係>
            <groupId>org.springframework.cloud</groupId>
            <artifactId>spring-cloud-dependencies</artifactId>
            <version>ダルストン.SR5</version>
            <type>ポンポン</type>
            <scope>インポート</scope>
        </依存関係>
    </依存関係>
 </依存関係管理>

• メイン アプリケーション クラスを作成し、/trace-1 インターフェイスを実装し、RestTemplate を使用して trace-2 アプリケーションのインターフェイスを呼び出します。詳細は以下の通りです。

 @レストコントローラ
@EnableDiscoveryClient
 @SpringBootアプリケーション
パブリッククラスTraceApplication { 
 
    プライベート最終ロガー logger = Logger.getLogger(getClass()); 
 
    @ビーン
    @負荷バランス
    レストテンプレートrestTemplate() {
新しい RestTemplate()を返します。
    } 
 
    @RequestMapping(値 = "/trace-1" 、メソッド = RequestMethod.GET)
パブリック文字列トレース() {
        logger.info( "===呼び出しトレース-1===" );
 restTemplate().getForEntity( "http://trace-2/trace-2" 、 String.class).getBody();を返します。
    } 
 
公共 静的void main(String[] args) {
        SpringApplication.run(TraceApplication.class、引数);
    } 
 
 }

• application.properties で、次のように eureka.client.serviceUrl.defaultZone パラメータを eureka-server のアドレスに指定します。

 spring.application.name =トレース-1
サーバーポート=9101 
 
 eureka.client.serviceUrl.defaultZone=http://eureka.didispace.com/eureka/

• マイクロサービス アプリケーション: trace-2 は、trace-1 が呼び出す REST インターフェイス /trace-2 を実装します。具体的な実装は以下のとおりです。
• pom.xml に trace-1 と同じ依存関係を持つ基本的な Spring Boot アプリケーションを作成します。
• メイン アプリケーション クラスを作成し、/trace-2 インターフェイスを実装します。具体的な実装は以下のとおりです。

 @レストコントローラ
@EnableDiscoveryClient
 @SpringBootアプリケーション
パブリッククラスTraceApplication { 
 
    プライベート最終ロガー logger = Logger.getLogger(getClass()); 
 
    @RequestMapping(値 = "/trace-2" 、メソッド = RequestMethod.GET)
パブリック文字列トレース() {
        logger.info( "===<呼び出しトレース-2>===" );
戻る  「トレース」 ;
    } 
 
公共 静的void main(String[] args) {
        SpringApplication.run(TraceApplication.class、引数);
    } 
 
 }

• application.properties で、eureka.client.serviceUrl.defaultZone パラメータを eureka-server のアドレスに指定します。さらに、次のように異なるアプリケーション名とポート番号を設定する必要があります。

 spring.application.name =トレース 2
サーバーポート=9102
 eureka.client.serviceUrl.defaultZone=http://eureka.didispace.com/eureka/

上記の内容を実装すると、eureka-server、trace-1、trace-2 の 3 つのアプリケーションを起動し、postman や curl などのツールを通じて trace-1 のインターフェース http://localhost:9101/trace-1 にリクエストを送信できるようになります。戻り値 Trace と次の出力をコンソールで取得できます。

 --トレース-1  
 INFO 25272 --- [nio-9101-exec-2] ication$$EnhancerBySpringCGLIB$$36e12c68 : ===<呼び出しトレース-1>===   
 
 --トレース-2  
 INFO 7136 --- [nio-9102-exec-1] ication$$EnhancerBySpringCGLIB$$52a02f0b : ===<呼び出しトレース-2>===  

追跡の実装

準備作業が完了したら、この章のメインコンテンツを開始し、上記の trace-1 と trace-2 にサービス追跡機能を追加します。 Spring Cloud Sleuth のカプセル化により、アプリケーションにサービス トレース機能を追加するのは非常に簡単になります。次のように、trace-1 と trace-2 の pom.xml 依存関係管理に spring-cloud-starter-sleuth 依存関係を追加するだけです。

 <依存関係>
    <groupId>org.springframework.cloud</groupId>
    <artifactId>spring-cloud-starter-sleuth</artifactId>
 </依存関係>

この時点で、実際にサービス トレースを実装するための trace-1 と trace-2 の基本的な準備が完了しました。 trace-1 と trace-2 を再起動した後、http://localhost:9101/trace-1 にある trace-1 のインターフェースにリクエストを送信します。この時点で、コンソール出力から sleuth に関するいくつかの手がかりを得ることができます。

 --トレース-1  
 INFO [trace-1,f410ab57afd5c145,a9f2118fa2019684, false ] 25028 --- [nio-9101-exec-1] ication$$EnhancerBySpringCGLIB$$d8228493 : ===<call tr​​ace-1>===   
 
 --トレース-2  
 INFO [trace-2,f410ab57afd5c145,e9a377dc2268bc29, false ] 23112 --- [nio-9102-exec-1] ication$$EnhancerBySpringCGLIB$$e6cb4078 : ===<call tr​​ace-2>===  

上記のコンソール出力から、[trace-1,f410ab57afd5c145,a9f2118fa2019684,false] の形式で追加のログ情報を確認できます。これらの要素は、分散サービス トレースを実装するための重要なコンポーネントです。各値の意味は次のとおりです。

• 最初の値: trace-1。これは、application.properties の spring.application.name パラメータによって構成されるプロパティであるアプリケーションの名前を記録します。
• 2 番目の値: f410ab57afd5c145。これは Spring Cloud Sleuth によって生成される ID で、Trace ID と呼ばれ、リクエスト リンクを識別するために使用されます。リクエスト リンクには、1 つの Trace ID と複数の Span ID が含まれます。
• 3 番目の値: a9f2118fa2019684 は、Spring Cloud Sleuth によって生成される別の ID で、Span ID と呼ばれ、HTTP リクエストの送信などの基本的な作業単位を表します。
• 4 番目の値: false は、収集および表示のために Zipkin などのサービスに情報を出力するかどうかを示します。

上記 4 つの値のうち、Trace ID と Span ID は、分散サービス トレースを実現するための Spring Cloud Sleuth の中核です。サービス要求リンクの呼び出し中は、同じトレース ID が維持され渡されるため、異なるマイクロサービス プロセスに分散された要求トレース情報全体が接続されます。上記の出力内容を例にとると、trace-1 と trace-2 は同じフロントエンド サービス要求ソースに属しているため、それらの Trace ID は同じであり、同じ要求リンク内にあります。

この記事の完全な例:

読者は、自分の好みに応じて、次の 2 つのリポジトリで trace-1 プロジェクトと trace-2 プロジェクトを表示することを選択できます。

ギットハブ

ギティー

【この記事は51CTOコラムニスト「Zhai Yongchao」によるオリジナル記事です。転載の許可を得るには、51CTO を通じて著者に連絡してください。

この著者の他の記事を読むにはここをクリックしてください