Teknologian jakaminen

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

1 Linkkien jäljittämisen esittely

  Suurten järjestelmien mikropalvelurakenteessa järjestelmä on jaettu useisiin moduuleihin. Nämä moduulit vastaavat erilaisista toiminnoista, ja ne yhdistetään järjestelmäksi, joka voi lopulta tarjota runsaasti toimintoja. Tässä arkkitehtuurissa pyyntö sisältää usein useita palveluita. Internet-sovellukset on rakennettu erilaisille ohjelmistomoduuleille. Näitä ohjelmistomoduuleja voivat kehittää eri työryhmät, ne voidaan toteuttaa eri ohjelmointikielillä ja ne voidaan jakaa tuhansille palvelimille useiden eri tietokeskusten kesken, mikä tarkoittaa, että niitä on myös olemassa. joitain ongelmia tässä arkkitehtonisessa muodossa:

• Kuinka löytää ongelmat nopeasti?
• Miten vian vaikutuksen laajuus määritetään?
• Kuinka selvittää palveluriippuvuudet ja riippuvuuksien rationaalisuus?
• Kuinka analysoida linkin suorituskykyongelmia ja reaaliaikaista kapasiteetin suunnittelua?

• kissa Avoimen lähdekoodin Dianping ja perustuuJava Kehitetty reaaliaikainen sovellustenvalvontaalusta sisältää reaaliaikaisen sovellusten seurannan ja liiketoiminnan seurannan. integroitu Ratkaisu on toteuttaa valvonta koodin hautaamisen avulla, kuten sieppaajat, suodattimet jne. Erittäin tunkeileva koodi, integraatio korkeammat kustannukset. Riski on suurempi.
• vetoketju RiippuaViserrysYrityksen avoimen lähdekoodin, avoimen lähdekoodin hajautettua seurantajärjestelmää käytetään palveluiden ajoitustietojen keräämiseen mikro- Palveluarkkitehtuurin latenssiongelmia ovat: tiedonkeruu, tallennus, haku ja esittäminen.Tämä tuote yhdistääkevät-pilvi-sleuthSe on suhteellisen yksinkertainen käyttää ja helppo integroida, mutta sen toiminnot ovat suhteellisen yksinkertaisia.
• täsmentää Tarkkaile Se on korealainen avoimen lähdekoodin puheluketjuanalyysi- ja sovellusvalvontaanalyysityökalu, joka perustuu tavukoodiinjektioon.ominaisuudetSe tukee useita laajennuksia.UITehokkaat toiminnot, ei koodin tunkeutumista pääsypäähän.
• skywalking
  SkyWalking Se on tavukoodiinjektioon perustuva paikallinen avoimen lähdekoodin puheluketjuanalyysi- ja sovellusvalvontaanalyysityökalu.Ominaisuus on, että se tukee moniaeräänlainen laajennus,UI Toiminto on vahva ja pääsypäässä ei ole koodin tunkeutumista.Jo liittynytApachehautomo.
• Salapoliisi
  SpringCloud Tarjoaa linkkien seurantaratkaisuja hajautetuissa järjestelmissä. 

2 Sleuthpäästä alkuun

2.1 Sleuthesitellä

• Jäljittää
  ryhmän toimestaJäljitystunnusidenttinenSpan Yhdistetty muodostamaan puurakenteen.Pyynnön seurannan toteuttamiseksi, kun pyyntö saapuu hajautettuun järjestelmäänpääsyn päätepisteeseen, palvelun seurantakehyksen tarvitsee vain luoda pyynnölle yksilöllinen tunniste (esim.TraceId), ollessaan hajautetussa järjestelmässä Järjestelmän sisällä kiertäessään kehys välittää aina tämän ainutlaatuisen arvon, kunnes koko pyyntö palautetaan.Sitten voimme käyttää vain tätäYksi tunniste yhdistää kaikki pyynnöt yhteen täydelliseksi pyyntölinkiksi.
• Span Edustaa perusjoukkoa työyksiköitä.Jotta voidaan laskea kunkin käsittely-yksikön viive, kun pyyntö saavuttaa jokaisen palvelukomponentinaika, myös yksilöllisen tunnisteen kautta (SpanId ) merkitsemään sen alkua, tiettyä prosessia ja loppua.kulkeaSpanIdalkua ja loppuaLopetuksen aikaleima, voit laskeajänneväli Soittoajan lisäksi saamme myös tapahtuman nimen.Pyydä tietoja jne.metatiedot.
• Annotaatio
  Käytä sitä tapahtumien tallentamiseen tietyn ajanjakson aikana. Tärkeitä huomautuksia sisäiseen käyttöön:
  cs（Asiakaslähetys) Asiakas lähettää pyynnön ja aloittaa pyynnön elinkaaren
  sr（Palvelin vastaanotettu) Palvelin vastaanottaa pyynnön ja alkaa käsitellä sitä, sr－cs = Verkon latenssi (huoltopuhelun aika)
  ss（Palvelin Lähetä) Palvelin on suorittanut käsittelyn ja on valmis lähetettäväksi asiakkaalle,ss - sr = Pyydä käsittelyaika palvelimella
  kr（Asiakas vastaanotettu) Asiakas saa vastauksen palvelimelta ja pyyntö päättyy. cr - sr =pyydetty kokonaisaika

2.2 Sleuthpäästä alkuun

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

[palvelutilaus,3977125f73391553,57547b5bf71f8242,false]

[palvelutuote,3977125f73391553,449f5b3f3ef8d5c5,false]

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

3 vetoketjuaLiittäminen

3.1 ZipKinesitellä

3.2 ZipKinPalvelimen asennus

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

 Siirry yllä olevaan URL-osoitteeseen saadaksesi apurkkiLaukku, tässä seZipKinpalvelimen puolellapurkkiLaukku

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

3.3 ZipkinAsiakasintegraatio

        <!--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 ZipKinTietojen pysyvyys

4.1 käyttäämysqlOta käyttöön tietojen pysyvyys

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

Käy: localhost: 9200

Jos tarvitset visualisointia, voit asentaa Kibanan

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

Mitä tulee elasticsearchin visuaaliseen käyttöön, voit viitata:Elasticsearchin asennus ja käyttö ikkunoiden alle sekä kibana_windowskibanna-CSDN-blogin asennus