Partage de technologie

한어Русский языкEnglishFrançaisIndonesianSanskrit日本語DeutschPortuguêsΕλληνικάespañolItalianoSuomalainenLatina

1 Introduction au traçage des liens

  Dans la construction de microservices de grands systèmes, un système est divisé en plusieurs modules. Ces modules sont responsables de différentes fonctions et sont combinés en un système qui peut finalement fournir de riches fonctionnalités. Dans cette architecture, une requête implique souvent plusieurs services. Les applications Internet sont construites sur différents ensembles de modules logiciels. Ces modules logiciels peuvent être développés par différentes équipes, peuvent être implémentés à l'aide de différents langages de programmation et peuvent être distribués sur des milliers de serveurs dans plusieurs centres de données différents, ce qui signifie qu'il y aura également quelques problèmes avec cette forme architecturale :

• Comment trouver rapidement des problèmes ?
• Comment déterminer l’ampleur de l’impact de la panne ?
• Comment trier les dépendances de service et la rationalité des dépendances ?
• Comment analyser les problèmes de performances des liaisons et la planification de la capacité en temps réel ?

• chat Open source par Dianping et basé surJava La plateforme de surveillance des applications en temps réel développée comprend la surveillance des applications en temps réel et la surveillance des activités. intégré La solution consiste à mettre en œuvre une surveillance via l’enfouissement de code, comme des intercepteurs, des filtres, etc. Très intrusif dans le code, intégration coût plus élevé. Le risque est plus grand.
• zipkin Dépend deTwitterLe système de suivi distribué open source et open source de la société est utilisé pour collecter des données temporelles de services afin de résoudre les micro- Les problèmes de latence dans l'architecture de service incluent : la collecte, le stockage, la recherche et la présentation des données.Ce produit combinedétective des nuages ​​printaniersIl est relativement simple à utiliser et facile à intégrer, mais ses fonctions sont relativement simples.
• localiser Localiser Il s'agit d'un outil coréen d'analyse de la chaîne d'appels et de surveillance des applications open source basé sur l'injection de bytecode.CaractéristiquesIl prend en charge une variété de plug-ins.Interface utilisateurFonctions puissantes, aucune intrusion de code du côté de l'accès.
• marcher dans le ciel
  Randonnée dans le ciel Il s'agit d'un outil local d'analyse de la chaîne d'appels open source et de surveillance des applications basé sur l'injection de bytecode.La particularité est qu'il prend en charge de nombreuxune sorte de plug-in,Interface utilisateur La fonction est puissante et il n’y a aucune intrusion de code du côté de l’accès.Déjà rejointApacheincubateur.
• Détective
  Nuage de printemps Fournit des solutions de suivi des liens dans les systèmes distribués. 

2 Détectivecommencer

2.1 Détectiveintroduire

• Tracer
  par un groupeIdentifiant de traceidentiquePortée Concaténé pour former une structure arborescente.Afin de mettre en œuvre le suivi des demandes, lorsqu'une demande arrive au système distribuépoint de terminaison d'entrée, le cadre de suivi des services n'a besoin que de créer un identifiant unique pour la demande (c'est-à-direIdentifiant de trace), alors que dans le système distribué Lors de sa circulation dans le système, le framework continue toujours de transmettre cette valeur unique jusqu'à ce que la totalité de la requête soit renvoyée.Ensuite, nous pouvons utiliser ceci uniquementUn identifiant relie toutes les demandes entre elles pour former un lien de demande complet.
• Portée Représente un ensemble de base d’unités de travail.Afin de compter le délai de chaque unité de traitement, lorsque la requête atteint chaque composant du servicetemps, également via un identifiant unique (ID de la portée ) pour marquer son début, son processus spécifique et sa fin.passerID de la portéele début et la fin deHorodatage de fin, vous pouvez compter leportée En plus de l'heure d'appel, nous pouvons également obtenir le nom de l'événement.Demander des informations, etc.métadonnées.
• Annotation
  Utilisez-le pour enregistrer des événements sur une période donnée. Notes importantes à usage interne :
  cs（Envoi du client) Le client émet une requête et démarre la vie d'une requête
  sr（Serveur reçu) Le serveur reçoit la requête et commence à la traiter, sr－cs = Latence du réseau (durée de l'appel de service)
  ss（Envoi du serveur) Le serveur a terminé le traitement et est prêt à être envoyé au client,ss-sr = Temps de traitement des demandes sur le serveur
  cr（Client reçu) Le client reçoit la réponse du serveur et la requête se termine. cr-sr =temps total demandé

2.2 Détectivecommencer

[passerelle API,3977125f73391553,3977125f73391553,false]

[ordre de service,3977125f73391553,57547b5bf71f8242,false]

[service-produit,3977125f73391553,449f5b3f3ef8d5c5,false]

        <!--链路追踪 Sleuth-->
        <dependency>
            <groupId>org.springframework.cloud</groupId>
            <artifactId>spring-cloud-starter-sleuth</artifactId>
        </dependency>

3 ZipkinsL'intégration

3.1 ZipKinintroduire

3.2 ZipKinInstallation du serveur

https://search.maven.org/remote_content?g=io.zipkin.java&a=zipkin-server&v=LATEST&c=exec

 Visitez l'URL ci-dessus pour obtenir unpotSac, ça y estZipKindu côté serveurpotSac

java -jar zipkin-server-2.12.9-exec.jar

3.3 ZipkinIntégration client

        <!--zipkin-->
        <dependency>
            <groupId>org.springframework.cloud</groupId>
            <artifactId>spring-cloud-starter-zipkin</artifactId>
        </dependency>

  # sleuth 和 zipkin 相关配置
spring:
  zipkin:
    base-url: http://127.0.0.1:9411/ #zipkin server的请求地址
    discoveryClientEnabled: false #让nacos把它当成一个URL，而不要当做服务名
  sleuth:
    sampler:
      probability: 1.0 #采样的百分比

http://localhost:7000/order-serv/order/prod/1

4 ZipKinPersistance des données

4.1 utilisermysqlImplémenter la persistance des données

CREATE TABLE
IF
	NOT EXISTS zipkin_spans (
		`trace_id_high` BIGINT NOT NULL DEFAULT 0 COMMENT 'If non zero, this
		means the trace uses 128 bit traceIds instead of 64 bit',
		`trace_id` BIGINT NOT NULL,
		`id` BIGINT NOT NULL,
		`name` VARCHAR ( 255 ) NOT NULL,
		`parent_id` BIGINT,
		`debug` BIT ( 1 ),
		`start_ts` BIGINT COMMENT 'Span.timestamp(): epoch micros used for endTs
		query and to implement TTL',
		`duration` BIGINT COMMENT 'Span.duration(): micros used for minDuration
		and maxDuration query' 
	) ENGINE = INNODB ROW_FORMAT = COMPRESSED CHARACTER 
	SET = utf8 COLLATE utf8_general_ci;
ALTER TABLE zipkin_spans ADD UNIQUE KEY ( `trace_id_high`, `trace_id`, `id` ) COMMENT 'ignore insert on duplicate';
ALTER TABLE zipkin_spans ADD INDEX ( `trace_id_high`, `trace_id`, `id` ) COMMENT 'for joining with zipkin_annotations';
ALTER TABLE zipkin_spans ADD INDEX ( `trace_id_high`, `trace_id` ) COMMENT 'for
getTracesByIds';
ALTER TABLE zipkin_spans ADD INDEX ( `name` ) COMMENT 'for getTraces and
getSpanNames';
ALTER TABLE zipkin_spans ADD INDEX ( `start_ts` ) COMMENT 'for getTraces
ordering and range';
CREATE TABLE
IF
	NOT EXISTS zipkin_annotations (
		`trace_id_high` BIGINT NOT NULL DEFAULT 0 COMMENT 'If non zero, this
		means the trace uses 128 bit traceIds instead of 64 bit',
		`trace_id` BIGINT NOT NULL COMMENT 'coincides with
		zipkin_spans.trace_id',
		`span_id` BIGINT NOT NULL COMMENT 'coincides with zipkin_spans.id',
		`a_key` VARCHAR ( 255 ) NOT NULL COMMENT 'BinaryAnnotation.key or
		Annotation.value if type == -1',
		`a_value` BLOB COMMENT 'BinaryAnnotation.value(), which must be smaller
		than 64KB',
		`a_type` INT NOT NULL COMMENT 'BinaryAnnotation.type() or -1 if
		Annotation',
		`a_timestamp` BIGINT COMMENT 'Used to implement TTL;
	Annotation.timestamp or zipkin_spans.timestamp',
	`endpoint_ipv4` INT COMMENT 'Null when Binary/Annotation.endpoint is
	null',
	`endpoint_ipv6` BINARY ( 16 ) COMMENT 'Null when Binary/Annotation.endpoint
	is null, or no IPv6 address',
	`endpoint_port` SMALLINT COMMENT 'Null when Binary/Annotation.endpoint
	is null',
	`endpoint_service_name` VARCHAR ( 255 ) COMMENT 'Null when
	Binary/Annotation.endpoint is null' 
) ENGINE = INNODB ROW_FORMAT = COMPRESSED CHARACTER 
SET = utf8 COLLATE utf8_general_ci;
ALTER TABLE zipkin_annotations ADD UNIQUE KEY ( `trace_id_high`, `trace_id`, `span_id`, `a_key`, `a_timestamp` ) COMMENT 'Ignore insert on duplicate';
ALTER TABLE zipkin_annotations ADD INDEX ( `trace_id_high`, `trace_id`, `span_id` ) COMMENT 'for joining with zipkin_spans';
ALTER TABLE zipkin_annotations ADD INDEX ( `trace_id_high`, `trace_id` ) COMMENT 'for getTraces/ByIds';
ALTER TABLE zipkin_annotations ADD INDEX ( `endpoint_service_name` ) COMMENT 'for getTraces and getServiceNames';
ALTER TABLE zipkin_annotations ADD INDEX ( `a_type` ) COMMENT 'for getTraces';
ALTER TABLE zipkin_annotations ADD INDEX ( `a_key` ) COMMENT 'for getTraces';
ALTER TABLE zipkin_annotations ADD INDEX ( `trace_id`, `span_id`, `a_key` ) COMMENT 'for dependencies job';
CREATE TABLE
IF
	NOT EXISTS zipkin_dependencies ( `day` DATE NOT NULL, `parent` VARCHAR ( 255 ) NOT NULL, `child` VARCHAR ( 255 ) NOT NULL, `call_count` BIGINT ) ENGINE = INNODB ROW_FORMAT = COMPRESSED CHARACTER 
	SET = utf8 COLLATE utf8_general_ci;
ALTER TABLE zipkin_dependencies ADD UNIQUE KEY ( `day`, `parent`, `child` );

java -jar zipkin-server-2.12.9-exec.jar --STORAGE_TYPE=mysql --
MYSQL_HOST=127.0.0.1 --MYSQL_TCP_PORT=3306 --MYSQL_DB=zipkin --MYSQL_USER=root -
-MYSQL_PASS=root

Visite : localhost : 9200

Si vous avez besoin de visualisation, vous pouvez installer Kibana

java -jar zipkin-server-2.12.9-exec.jar --STORAGE_TYPE=elasticsearch --ESHOST=localhost:9200

Quant à l’utilisation visuelle d’elasticsearch, vous pouvez vous référer à :Installation et utilisation d'Elasticsearch sous Windows, et installation du blog kibana_windowskibanna-CSDN