Comment implémenter la fonction de suivi des journaux distribués dans les microservices PHP

Comment implémenter la fonction de suivi des journaux distribués dans les microservices PHP

Présentation :

Avec le développement des systèmes distribués, l'architecture des microservices est devenue une solution populaire. Dans cette architecture, une application est divisée en plusieurs petits services qui peuvent être déployés, mis à l'échelle et gérés indépendamment. Cependant, à mesure que le nombre de services augmente, la gestion des journaux devient de plus en plus difficile. Dans une architecture de microservices complexe, il est nécessaire de pouvoir suivre le flux de demandes et regrouper les informations des journaux pour une analyse et une surveillance ultérieures. Dans cet article, je présenterai comment implémenter la fonction de suivi des journaux distribués dans les microservices PHP et fournirai des exemples de code spécifiques.

Étapes de mise en œuvre :

1. Installer et configurer Zipkin

Zipkin est un système de traçage distribué qui peut être utilisé pour collecter, stocker et afficher les données de traçage des systèmes distribués. Tout d’abord, Zipkin doit être installé et configuré sur le système. Vous pouvez utiliser Docker pour créer rapidement un serveur Zipkin. Pour les étapes d'installation spécifiques, veuillez vous référer à la documentation officielle de Zipkin.

2. Ajouter une bibliothèque client Zipkin PHP

Zipkin fournit des bibliothèques client pour plusieurs langages de programmation, dont PHP. Vous pouvez utiliser Composer pour installer la bibliothèque client Zipkin PHP. La commande d'installation spécifique est la suivante :

composer require openzipkin/zipkin

3. Modifier le code du service

Dans le code de chaque microservice, les demandes doivent être suivies et les informations de suivi enregistrées. Voici un exemple de code de microservice PHP :

<?php

use ZipkinInstrumentationHttpClientPsr18Client;
use ZipkinInstrumentationHttpClientPsr18HttpMiddleware;
use ZipkinSamplerBinarySampler;
use ZipkinSpan;
use ZipkinTimestamp;
use ZipkinTracingBuilder;
use ZipkinOpenTracingSpanContext;
use ZipkinOpenTracingTracer;


// 初始化Zipkin追踪器
$tracing = TracingBuilder::create()
    ->havingLocalEndpoint('your_service_name') // 这里填写当前服务的名称
    ->havingSampler(BinarySampler::createAsAlwaysSample())
    ->build();

// 创建一个Zipkin追踪器，用于记录追踪信息
$tracer = new Tracer($tracing);

// 定义一个中间件，用于追踪请求
$middleware = new Psr18HttpMiddleware($tracer);

// 创建一个HTTP客户端，使用Zipkin中间件处理请求
$client = new Psr18Client($middleware);

// 发送HTTP请求
$request = new GuzzleHttpPsr7Request('GET', 'http://example.com');
$response = $client->sendRequest($request);

// 创建一个Zipkin span，记录该请求的追踪信息
$span = $tracer->startActiveSpan('my_span');
$spanContext = new SpanContext($tracer->getTracer(), $span->getContext());

// 添加追踪信息到请求头
$request = $request->withHeader('X-B3-TraceId', $spanContext->getTraceId());
$request = $request->withHeader('X-B3-SpanId', $spanContext->getSpanId());
$request = $request->withHeader('X-B3-ParentSpanId', $spanContext->getParentId());
$request = $request->withHeader('X-B3-Sampled', $spanContext->isSampled() ? '1' : '0');
$request = $request->withHeader('X-B3-Flags', $spanContext->getFlags());

// 发送带有追踪信息的HTTP请求
$response = $client->sendRequest($request);

// 结束span
$span->addEvent($timestamp, 'sent');

// 输出收到的响应
echo $response->getBody();

// 关闭Zipkin追踪器
$tracing->close();

Grâce au code ci-dessus, nous pouvons enregistrer les informations de suivi de chaque demande, les ajouter à l'en-tête de la demande et les envoyer au service suivant. De cette manière, chaque service enregistrera ses propres informations de suivi, les regroupera et les analysera via Zipkin.

4. Afficher les données de suivi

Après avoir terminé les étapes ci-dessus, vous pouvez accéder à l'interface Web de Zipkin via votre navigateur pour afficher les données de suivi. Dans l'interface Web, vous pouvez voir le chemin de suivi, la consommation de temps et d'autres informations de chaque demande. Vous pouvez utiliser la fonction de recherche pour trouver des demandes spécifiques de dépannage et d'analyse.

Résumé :

Dans une architecture de microservices complexe, il est très important de mettre en œuvre une fonction de suivi des journaux distribués. En utilisant Zipkin et la bibliothèque client Zipkin PHP, nous pouvons facilement implémenter des fonctions de suivi des journaux distribués dans les microservices PHP. En enregistrant les informations de suivi de chaque demande et en les envoyant au service suivant, nous pouvons suivre le flux des demandes et regrouper les informations du journal pour une analyse et une surveillance ultérieures. J'espère que cet article vous sera utile pour implémenter la fonction de suivi des journaux distribués dans les microservices PHP !

Ce qui précède est le contenu détaillé de. pour plus d'informations, suivez d'autres articles connexes sur le site Web de PHP en chinois!