Technologieaustausch

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

1 Einführung in die Linkverfolgung

  Beim Microservice-Aufbau großer Systeme wird ein System in viele Module aufgeteilt. Diese Module sind für unterschiedliche Funktionen verantwortlich und werden zu einem System kombiniert, das letztendlich umfangreiche Funktionalität bieten kann. In dieser Architektur umfasst eine Anfrage häufig mehrere Dienste. Internetanwendungen basieren auf verschiedenen Sätzen von Softwaremodulen. Diese Softwaremodule können von verschiedenen Teams entwickelt, mit unterschiedlichen Programmiersprachen implementiert und auf Tausenden von Servern in mehreren verschiedenen Rechenzentren verteilt sein, was bedeutet, dass es auch einige Probleme geben wird mit dieser architektonischen Form:

• Wie findet man Probleme schnell?
• Wie kann der Umfang der Auswirkungen des Fehlers ermittelt werden?
• Wie kann man Dienstabhängigkeiten und die Rationalität von Abhängigkeiten klären?
• Wie lassen sich Verbindungsleistungsprobleme und die Kapazitätsplanung in Echtzeit analysieren?

• Katze Open Source von Dianping und basierend aufJava Die entwickelte Echtzeit-Anwendungsüberwachungsplattform umfasst Echtzeit-Anwendungsüberwachung und Geschäftsüberwachung. integriert Die Lösung besteht darin, die Überwachung durch das Vergraben von Code zu implementieren, z. B. durch Interceptoren, Filter usw. Sehr aufdringlich für den Code, Integration höhere Kosten. Das Risiko ist größer.
• zipkin Darauf ankommenÞjórsárdenDas Open-Source-Distributed-Tracking-System des Unternehmens wird verwendet, um Zeitdaten von Diensten zu sammeln, um Mikro- zu lösen. Zu den Latenzproblemen in der Servicearchitektur gehören: Datenerfassung, -speicherung, -suche und -präsentation.Dieses Produkt vereintFrühlingswolken-DetektivEs ist relativ einfach zu bedienen und leicht zu integrieren, seine Funktionen sind jedoch relativ einfach.
• genau lokalisieren Genau lokalisieren Es handelt sich um ein koreanisches Open-Source-Tool zur Anrufkettenanalyse und Anwendungsüberwachung, das auf Bytecode-Injection basiert.MerkmaleEs unterstützt eine Vielzahl von Plug-Ins.BenutzeroberflächeLeistungsstarke Funktionen, kein Code-Einbruch auf der Zugriffsseite.
• Himmelsspaziergang
  SkyWalking Es handelt sich um ein lokales Open-Source-Tool zur Anrufkettenanalyse und Anwendungsüberwachung, das auf Bytecode-Injection basiert.Das Merkmal ist, dass es viele unterstütztArt Plug-in,Benutzeroberfläche Die Funktion ist stark und es gibt keinen Codeeinbruch auf der Zugriffsseite.Bereits beigetretenApacheInkubator.
• Detektiv
  SpringCloud Bietet Link-Tracking-Lösungen in verteilten Systemen. 

2 DetektivErste Schritte

2.1 Detektiveinführen

• Verfolgen
  von einer GruppeTrace-IDidentischSpanne Zu einer Baumstruktur verkettet.Um die Anforderungsverfolgung zu implementieren, wenn eine Anforderung im verteilten System eintrifftFür den Eingabeendpunkt muss das Service-Tracking-Framework lediglich eine eindeutige Kennung für die Anforderung erstellen (d. h.Trace-ID), während im verteilten System Bei der Zirkulation innerhalb des Systems übergibt das Framework diesen eindeutigen Wert immer so lange, bis die gesamte Anfrage zurückgegeben wird.Dann können wir dies nur verwendenEine Kennung verbindet alle Anfragen zu einem vollständigen Anfragelink.
• Spanne Stellt einen grundlegenden Satz von Arbeitseinheiten dar.Um die Verzögerung jeder Verarbeitungseinheit zu zählen, wenn die Anforderung jede Dienstkomponente erreichtZeit, auch durch eine eindeutige Kennung (SpanId ), um seinen Anfang, seinen spezifischen Prozess und sein Ende zu markieren.passierenSpanIdder Anfang und das Ende vonEndzeitstempel, den Sie zählen könnenSpanne Zusätzlich zur Aufrufzeit können wir auch den Namen der Veranstaltung erfahren.Informationen anfordern usw.Metadaten.
• Anmerkung
  Verwenden Sie es, um Ereignisse über einen bestimmten Zeitraum aufzuzeichnen. Wichtige Hinweise für den internen Gebrauch:
  cs（Client senden) Der Client gibt eine Anfrage aus und startet die Lebensdauer einer Anfrage
  Herr（Server empfangen) Der Server empfängt die Anfrage und beginnt mit der Verarbeitung. Herr－cs = Netzwerklatenz (Zeit für Serviceanruf)
  ss（Server Senden) Der Server hat die Verarbeitung abgeschlossen und kann an den Client gesendet werden.ss - sr = Bearbeitungszeit auf dem Server anfordern
  cr（Kunde erhalten) Der Client erhält die Antwort vom Server und die Anfrage endet. cr - sr =Gesamtzeit angefordert

2.2 DetektivErste Schritte

[API-Gateway,3977125f73391553,3977125f73391553,false]

[Service-Bestellung,3977125f73391553,57547b5bf71f8242,falsch]

[Dienstleistungsprodukt,3977125f73391553,449f5b3f3ef8d5c5,false]

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

3 ZipkinIntegration

3.1 ZipKineinführen

3.2 ZipKinServerinstallation

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

 Besuchen Sie die URL oben, um eine zu erhaltenKrugTasche, das ist esZipKinserverseitigKrugTasche

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

3.3 ZipkinClient-Integration

        <!--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 ZipKinDatenpersistenz

4.1 verwendenMySQLImplementieren Sie Datenpersistenz

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

Besuchen Sie: localhost:9200

Wenn Sie eine Visualisierung benötigen, können Sie Kibana installieren

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

Zur visuellen Verwendung von Elasticsearch können Sie sich auf Folgendes beziehen:Installation und Verwendung von Elasticsearch unter Windows sowie Installation des kibana_windowskibanna-CSDN-Blogs