Compartilhamento de tecnologia

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

1 Introdução ao rastreamento de links

  Na construção de microsserviços de grandes sistemas, um sistema é dividido em vários módulos. Esses módulos são responsáveis ​​por diferentes funções e são combinados em um sistema que pode fornecer funcionalidades ricas. Nesta arquitetura, uma solicitação geralmente envolve vários serviços. As aplicações da Internet são construídas em diferentes conjuntos de módulos de software. Esses módulos de software podem ser desenvolvidos por diferentes equipes, podem ser implementados usando diferentes linguagens de programação e podem ser distribuídos em milhares de servidores em vários centros de dados diferentes, o que significa que também haverá. alguns problemas com esta forma arquitetônica:

• Como encontrar problemas rapidamente?
• Como determinar o escopo do impacto da falha?
• Como resolver as dependências de serviço e a racionalidade das dependências?
• Como analisar problemas de desempenho de links e planejamento de capacidade em tempo real?

• gato Código aberto da Dianping e baseado emJava A plataforma de monitoramento de aplicativos em tempo real desenvolvida inclui monitoramento de aplicativos e monitoramento de negócios em tempo real. integrado A solução é implementar o monitoramento através de enterramento de códigos, como interceptadores, filtros, etc. Muito intrusivo ao código, integração custo mais elevado. O risco é maior.
• zíper Depende deTwitterO sistema de rastreamento distribuído de código aberto da empresa é usado para coletar dados de tempo de serviços para resolver micro- Os problemas de latência na arquitetura de serviços incluem: coleta, armazenamento, pesquisa e apresentação de dados.Este produto combinadetetive-de-nuvem-de-primaveraÉ relativamente simples de usar e fácil de integrar, mas suas funções são relativamente simples.
• apontar Localizar É uma ferramenta coreana de análise de cadeia de chamadas e monitoramento de aplicativos de código aberto baseada em injeção de bytecode.CaracterísticasEle suporta uma variedade de plug-ins.Interface do usuárioFunções poderosas, sem intrusão de código no final do acesso.
• caminhada no céu
  Caminhada no céu É uma ferramenta local de análise de cadeia de chamadas e monitoramento de aplicativos de código aberto baseada em injeção de bytecode.A característica é que suporta muitostipo de plug-in,Interface do usuário A função é forte e não há intrusão de código no final do acesso.Já aderiuApacheincubadora.
• investigar
  Nuvem de primavera Fornece soluções de rastreamento de links em sistemas distribuídos. 

2 Detetivecomeçando

2.1 Detetiveintroduzir

• Vestígio
  por um grupoIdentificação do rastreamentoidênticoPeríodo Concatenado para formar uma estrutura em árvore.Para implementar o rastreamento de solicitações, quando uma solicitação chega ao sistema distribuídoendpoint de entrada, a estrutura de rastreamento de serviço só precisa criar um identificador exclusivo para a solicitação (ou seja,Identificador de rastreamento), enquanto no sistema distribuído Ao circular dentro do sistema, o framework sempre fica passando esse valor único até que toda a requisição seja retornada.Então podemos usar isso apenasUm identificador conecta todas as solicitações para formar um link de solicitação completo.
• Período Representa um conjunto básico de unidades de trabalho.Para contar o atraso de cada unidade de processamento, quando a solicitação chega a cada componente do serviçotempo, também através de um identificador único (ID de extensão ) para marcar seu início, processo específico e fim.passarID de extensãoo começo e o fim deCarimbo de data e hora final, você pode contar operíodo Além do horário da chamada, também podemos obter o nome do evento.Solicitar informações, etc.metadados.
• Anotação
  Use-o para registrar eventos durante um período de tempo. Notas importantes para uso interno:
  cs（Cliente Envia) O cliente emite uma solicitação e inicia a vida de uma solicitação
  senhor（Servidor recebido) O servidor recebe a solicitação e começa a processá-la, senhor－cs = Latência da rede (tempo para chamada de serviço)
  sem（Servidor Enviar) O servidor concluiu o processamento e está pronto para ser enviado ao cliente,ss - sr = Solicitar tempo de processamento no servidor
  cr（Cliente recebido) O cliente recebe a resposta do servidor e a solicitação termina. cr - sr =tempo total solicitado

2.2 Detetivecomeçando

[api-gateway,3977125f73391553,3977125f73391553,falso]

[ordem de serviço,3977125f73391553,57547b5bf71f8242,falso]

[serviço-produto,3977125f73391553,449f5b3f3ef8d5c5,falso]

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

3 ZipkinIntegração

3.1 ZipKinintroduzir

3.2 ZipKinInstalação do servidor

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

 Visite o URL acima para obter umjarBolsa, é issoZipKinlado do servidorjarBolsa

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

3.3 ZipkinIntegração do cliente

        <!--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 ZipKinPersistência de dados

4.1 usarmysqlImplementar persistência de dados

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

Se precisar de visualização, você pode instalar o Kibana

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

Quanto ao uso visual do elasticsearch, você pode consultar:Instalação e uso do Elasticsearch no Windows e instalação do blog kibana_windowskibanna-CSDN