Condivisione della tecnologia

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

1 Introduzione al tracciamento dei collegamenti

  Nella costruzione di microservizi di sistemi di grandi dimensioni, un sistema è suddiviso in molti moduli. Questi moduli sono responsabili di diverse funzioni e sono combinati in un sistema che in definitiva può fornire ricche funzionalità. In questa architettura, una richiesta spesso coinvolge più servizi. Le applicazioni Internet sono costruite su diversi set di moduli software. Questi moduli software possono essere sviluppati da team diversi, possono essere implementati utilizzando linguaggi di programmazione diversi e possono essere distribuiti su migliaia di server in più data center diversi, il che significa che ce ne saranno anche. alcuni problemi con questa forma architettonica:

• Come trovare rapidamente i problemi?
• Come determinare la portata dell'impatto della colpa?
• Come risolvere le dipendenze del servizio e la razionalità delle dipendenze?
• Come analizzare i problemi relativi alle prestazioni dei collegamenti e la pianificazione della capacità in tempo reale?

• gatto Open source di Dianping e basato suGiava La piattaforma di monitoraggio delle applicazioni in tempo reale sviluppata include il monitoraggio delle applicazioni in tempo reale e il monitoraggio aziendale. integrato La soluzione è implementare il monitoraggio tramite code burying, come intercettori, filtri, ecc. Molto invadente per il codice, integrazione costo più elevato. Il rischio è maggiore.
• cerniera Dipende daCinguettioIl sistema di tracciamento distribuito open source e open source dell'azienda viene utilizzato per raccogliere dati temporali dei servizi per risolvere micro- I problemi di latenza nell'architettura del servizio includono: raccolta, archiviazione, ricerca e presentazione dei dati.Questo prodotto combinainvestigatore-nuvole-primaveriliÈ relativamente semplice da usare e facile da integrare, ma le sue funzioni sono relativamente semplici.
• individuare Individuare Si tratta di uno strumento coreano di analisi della catena di chiamate e di analisi del monitoraggio delle applicazioni open source basato sull'iniezione di bytecode.CaratteristicheSupporta una varietà di plug-in.Interfaccia utenteFunzioni potenti, nessuna intrusione di codice all'estremità di accesso.
• camminare nel cielo
  Camminare nel cielo Si tratta di uno strumento di analisi della catena di chiamate locale open source e di analisi del monitoraggio delle applicazioni basato sull'iniezione di bytecode.La caratteristica è che ne supporta moltitipo di plug-in,Interfaccia utente La funzione è potente e non vi è alcuna intrusione di codice all'estremità dell'accesso.Già iscrittoapacheincubatrice.
• Investigatore
  PrimaveraNuvola Fornisce soluzioni di tracciamento dei collegamenti nei sistemi distribuiti. 

2 Investigatoreiniziare

2.1 Investigatoreintrodurre

• Traccia
  da un gruppoID tracciaidenticoPortata Concatenati per formare una struttura ad albero.Per implementare il tracciamento delle richieste, quando una richiesta arriva al sistema distribuitoendpoint di ingresso, il framework di tracciamento del servizio deve solo creare un identificatore univoco per la richiesta (ad es.TracciaID), mentre nel sistema distribuito Quando circola all'interno del sistema, il framework continua sempre a trasmettere questo valore univoco finché non viene restituita l'intera richiesta.Quindi possiamo usare solo questoUn identificatore collega tutte le richieste insieme per formare un collegamento di richiesta completo.
• Portata Rappresenta un insieme base di unità di lavoro.Per contare il ritardo di ciascuna unità di elaborazione, quando la richiesta raggiunge ciascun componente del serviziotempo, anche attraverso un identificatore univoco (IDSpagnolo ) per segnarne l'inizio, il processo specifico e la fine.passaggioIDSpagnolol'inizio e la fine diFine timestamp, puoi contare ilcampata Oltre all'orario della chiamata possiamo ottenere anche il nome dell'evento.Richiedi informazioni, ecc.metadati.
• Annotazione
  Usalo per registrare eventi in un periodo di tempo Note importanti per uso interno:
  c.s.（Invia il cliente) Il client emette una richiesta e inizia la vita di una richiesta
  signore（Server ricevuto) Il server riceve la richiesta e inizia a elaborarla, signore－cs = Latenza di rete (tempo per la chiamata di servizio)
  ss（Invia server) Il server ha completato l'elaborazione ed è pronto per essere inviato al client,ss - sr = Richiedi il tempo di elaborazione sul server
  cretino（Cliente ricevuto) Il client riceve la risposta dal server e la richiesta termina. cr - sr =tempo totale richiesto

2.2 Investigatoreiniziare

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

[ordine-di-servizio,3977125f73391553,57547b5bf71f8242,falso]

[servizio-prodotto,3977125f73391553,449f5b3f3ef8d5c5,false]

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

3 CernieraIntegrazione

3.1 ZipKinintrodurre

3.2 ZipKinInstallazione del server

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

 Visita l'URL sopra per ottenere un filevasoBorsa, eccolaCernieralato servervasoBorsa

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

3.3 CernieraIntegrazione del 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 CernieraPersistenza dei dati

4.1 utilizzoil mio sqlImplementare la persistenza dei dati

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

Se hai bisogno di visualizzazione, puoi installare Kibana

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

Per quanto riguarda l’utilizzo visuale di elasticsearch si può fare riferimento a:Installazione e utilizzo di Elasticsearch sotto Windows e installazione del blog kibana_windowskibanna-CSDN