Compartir tecnología

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

1 Introducción al seguimiento de enlaces

  En la construcción de microservicios de sistemas grandes, un sistema se divide en muchos módulos. Estos módulos son responsables de diferentes funciones y se combinan en un sistema que, en última instancia, puede proporcionar una rica funcionalidad. En esta arquitectura, una solicitud suele implicar varios servicios. Las aplicaciones de Internet se basan en diferentes conjuntos de módulos de software. Estos módulos de software pueden ser desarrollados por diferentes equipos, implementados utilizando diferentes lenguajes de programación y pueden distribuirse en miles de servidores en múltiples centros de datos diferentes, lo que significa que también habrá algunos problemas. con esta forma arquitectónica:

• ¿Cómo encontrar problemas rápidamente?
• ¿Cómo determinar el alcance del impacto de la falla?
• ¿Cómo clasificar las dependencias de servicios y la racionalidad de las dependencias?
• ¿Cómo analizar los problemas de rendimiento del enlace y la planificación de capacidad en tiempo real?

• gato De código abierto por Dianping y basado enJava La plataforma de monitoreo de aplicaciones en tiempo real desarrollada incluye monitoreo de aplicaciones en tiempo real y monitoreo comercial. integrado La solución es implementar el monitoreo mediante el enterramiento de código, como interceptores, filtros, etc. Muy intrusivo para el código, integración. mayor costo. El riesgo es mayor.
• cremallera Depender deGorjeoEl sistema de seguimiento distribuido de código abierto de la empresa se utiliza para recopilar datos de sincronización de servicios para resolver micro- Los problemas de latencia en la arquitectura de servicios incluyen: recopilación, almacenamiento, búsqueda y presentación de datos.Este producto combinadetective de nubes de primaveraEs relativamente sencillo de usar y de integrar, pero sus funciones son relativamente sencillas.
• determinar con precisión Determinar con precisión Es una herramienta coreana de análisis de cadena de llamadas y monitoreo de aplicaciones de código abierto basada en inyección de código de bytes.CaracterísticasAdmite una variedad de complementos.Interfaz de usuarioFunciones potentes, sin intrusión de código en el extremo del acceso.
• Caminar por el cielo
  Caminar por el cielo Es una herramienta local de análisis de cadena de llamadas y monitoreo de aplicaciones de código abierto basada en la inyección de código de bytes.La característica es que soporta muchostipo de complemento,Interfaz de usuario La función es sólida y no hay intrusión de código en el extremo del acceso.Ya me uníapacheincubadora.
• Detective
  Nube de primavera Proporciona soluciones de seguimiento de enlaces en sistemas distribuidos. 

2 detectiveempezando

2.1 Detectiveintroducir

• Rastro
  por un grupoIdentificación de seguimientoidénticoDurar Concatenados para formar una estructura de árbol.Para implementar el seguimiento de solicitudes, cuando llega una solicitud al sistema distribuidopunto final de entrada, el marco de seguimiento de servicios solo necesita crear un identificador único para la solicitud (es decir,Identificación de seguimiento), mientras que en el sistema distribuido Cuando circula dentro del sistema, el marco siempre sigue pasando este valor único hasta que se devuelve la solicitud completa.Entonces podemos usar esto soloUn identificador conecta todas las solicitudes para formar un enlace de solicitud completo.
• Durar Representa un conjunto básico de unidades de trabajo.Para contar el retraso de cada unidad de procesamiento, cuando la solicitud llega a cada componente del serviciotiempo, también a través de un identificador único (Identificación de Span ) para marcar su inicio, proceso específico y final.aprobarIdentificación de Spanel principio y el final deMarca de tiempo final, puede contar ladurar Además de la hora de llamada, también podemos obtener el nombre del evento.Solicitar información, etc.metadatos.
• Anotación
  Úselo para registrar eventos durante un período de tiempo. Notas importantes para uso interno:
  cs（Cliente Envía) El cliente emite una solicitud y comienza la vida de una solicitud.
  Sr.（Servidor recibido) El servidor recibe la solicitud y comienza a procesarla, Sr.－cs = Latencia de red (tiempo de llamada de servicio)
  es（Servidor Enviar) El servidor ha completado el procesamiento y está listo para ser enviado al cliente,ss-sr= Solicitar tiempo de procesamiento en el servidor
  Cr（Cliente recibido) El cliente recibe la respuesta del servidor y la solicitud finaliza. cr - sr =tiempo total solicitado

2.2 Detectiveempezando

[puerta de enlace de API,3977125f73391553,3977125f73391553,falso]

[orden de servicio,3977125f73391553,57547b5bf71f8242,false]

[servicio-producto,3977125f73391553,449f5b3f3ef8d5c5,false]

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

3 cremallerasIntegración

3.1 ZipKinintroducir

3.2 ZipKinInstalación del servidor

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

 Visite la URL anterior para obtener unafrascoBolsa, esto es todoZipkinlado del servidorfrascoBolsa

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

3.3 CremalleraIntegración de clientes

        <!--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 ZipkinPersistencia de datos

4.1 usarMySQLImplementar la persistencia de datos

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

Visita: localhost:9200

Si necesita visualización, puede instalar Kibana

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

En cuanto al uso visual de elasticsearch, puede consultar:Instalación y uso de Elasticsearch en Windows e instalación del blog kibana_windowskibanna-CSDN