zipkin原理

通過(guò)zipkin的表結(jié)構(gòu),理解dapper者冤;trace把多個(gè)span進(jìn)行串接肤视;
形成依賴鏈路。

結(jié)構(gòu)

zipkin主要包括:collector涉枫、storage邢滑、search、webui愿汰;
zipkin collector會(huì)對(duì)一個(gè)到來(lái)的被trace的數(shù)據(jù)(span)進(jìn)行驗(yàn)證困后、存儲(chǔ)并設(shè)置索引。
其中storage包括:內(nèi)存衬廷、mysql摇予、es、cassandra吗跋。

數(shù)據(jù)結(jié)構(gòu)

Annotation:用于定位一個(gè)request的開(kāi)始和結(jié)束侧戴,cs/sr/ss/cr含有額外的信息,比如說(shuō)時(shí)間點(diǎn),當(dāng)這個(gè)annotation被記錄了救鲤,這個(gè)RPC也被認(rèn)為完成了。

     cs:Client Start,表示客戶端發(fā)起請(qǐng)求 秩冈;一個(gè)span的開(kāi)始本缠;
     cr:Client Received,表示客戶端獲取到服務(wù)端返回信息;一個(gè)span的結(jié)束

     sr:Server Receive,表示服務(wù)端收到請(qǐng)求
     ss:Server Send,表示服務(wù)端完成處理入问,并將結(jié)果發(fā)送給客戶端

    sr-cs:網(wǎng)絡(luò)延遲
    ss-sr:邏輯處理時(shí)間
    cr-cs:整個(gè)流程時(shí)間

Span:一個(gè)請(qǐng)求(包含一組Annotation和BinaryAnnotation)丹锹;它是基本工作單元,一次鏈路調(diào)用(可以是RPC芬失,DB等沒(méi)有特定的限制)創(chuàng)建一個(gè)span楣黍,通過(guò)一個(gè)64位ID標(biāo)識(shí)它。span通過(guò)還有其他的數(shù)據(jù)棱烂,例如描述信息租漂,時(shí)間戳,key-value對(duì)的(Annotation)tag信息颊糜,parent-id等,其中parent-id 可以表示span調(diào)用鏈路來(lái)源哩治,通俗的理解span就是一次請(qǐng)求信息。

Trace:類似于樹(shù)結(jié)構(gòu)的Span集合衬鱼,表示一條調(diào)用鏈路业筏,存在唯一標(biāo)識(shí)
Traces are built by collecting all Spans that share a traceId。通過(guò)traceId鸟赫、spanId和parentId蒜胖,被收集到的span會(huì)匯聚成一個(gè)tree,從而提供出一個(gè)request的整體流程抛蚤。

流程圖

image.png

表設(shè)計(jì)

1.span表

CREATE TABLE IF NOT EXISTS zipkin_spans (
  `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;

一些約束

ALTER TABLE zipkin_spans ADD UNIQUE KEY(`trace_id`, `id`) 
COMMENT 'ignore insert on duplicate';
ALTER TABLE zipkin_spans ADD INDEX(`trace_id`, `id`) 
COMMENT 'for joining with zipkin_annotations';
ALTER TABLE zipkin_spans ADD INDEX(`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` 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;
ALTER TABLE zipkin_annotations ADD UNIQUE KEY(`trace_id`, `span_id`, `a_key`, `a_timestamp`)
 COMMENT 'Ignore insert on duplicate';
ALTER TABLE zipkin_annotations ADD INDEX(`trace_id`, `span_id`)
 COMMENT 'for joining with zipkin_spans';
ALTER TABLE zipkin_annotations ADD INDEX(`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';

3.依賴關(guān)系

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;

ALTER TABLE zipkin_dependencies ADD UNIQUE KEY(`day`, `parent`, `child`);

?著作權(quán)歸作者所有,轉(zhuǎn)載或內(nèi)容合作請(qǐng)聯(lián)系作者
  • 序言:七十年代末台谢,一起剝皮案震驚了整個(gè)濱河市,隨后出現(xiàn)的幾起案子霉颠,更是在濱河造成了極大的恐慌对碌,老刑警劉巖,帶你破解...
    沈念sama閱讀 211,884評(píng)論 6 492
  • 序言:濱河連續(xù)發(fā)生了三起死亡事件蒿偎,死亡現(xiàn)場(chǎng)離奇詭異朽们,居然都是意外死亡,警方通過(guò)查閱死者的電腦和手機(jī)诉位,發(fā)現(xiàn)死者居然都...
    沈念sama閱讀 90,347評(píng)論 3 385
  • 文/潘曉璐 我一進(jìn)店門(mén)骑脱,熙熙樓的掌柜王于貴愁眉苦臉地迎上來(lái),“玉大人苍糠,你說(shuō)我怎么就攤上這事叁丧。” “怎么了?”我有些...
    開(kāi)封第一講書(shū)人閱讀 157,435評(píng)論 0 348
  • 文/不壞的土叔 我叫張陵拥娄,是天一觀的道長(zhǎng)蚊锹。 經(jīng)常有香客問(wèn)我,道長(zhǎng)稚瘾,這世上最難降的妖魔是什么牡昆? 我笑而不...
    開(kāi)封第一講書(shū)人閱讀 56,509評(píng)論 1 284
  • 正文 為了忘掉前任,我火速辦了婚禮摊欠,結(jié)果婚禮上丢烘,老公的妹妹穿的比我還像新娘。我一直安慰自己些椒,他們只是感情好播瞳,可當(dāng)我...
    茶點(diǎn)故事閱讀 65,611評(píng)論 6 386
  • 文/花漫 我一把揭開(kāi)白布。 她就那樣靜靜地躺著免糕,像睡著了一般赢乓。 火紅的嫁衣襯著肌膚如雪。 梳的紋絲不亂的頭發(fā)上石窑,一...
    開(kāi)封第一講書(shū)人閱讀 49,837評(píng)論 1 290
  • 那天骏全,我揣著相機(jī)與錄音,去河邊找鬼尼斧。 笑死姜贡,一個(gè)胖子當(dāng)著我的面吹牛,可吹牛的內(nèi)容都是我干的棺棵。 我是一名探鬼主播楼咳,決...
    沈念sama閱讀 38,987評(píng)論 3 408
  • 文/蒼蘭香墨 我猛地睜開(kāi)眼,長(zhǎng)吁一口氣:“原來(lái)是場(chǎng)噩夢(mèng)啊……” “哼烛恤!你這毒婦竟也來(lái)了母怜?” 一聲冷哼從身側(cè)響起,我...
    開(kāi)封第一講書(shū)人閱讀 37,730評(píng)論 0 267
  • 序言:老撾萬(wàn)榮一對(duì)情侶失蹤缚柏,失蹤者是張志新(化名)和其女友劉穎苹熏,沒(méi)想到半個(gè)月后,有當(dāng)?shù)厝嗽跇?shù)林里發(fā)現(xiàn)了一具尸體币喧,經(jīng)...
    沈念sama閱讀 44,194評(píng)論 1 303
  • 正文 獨(dú)居荒郊野嶺守林人離奇死亡轨域,尸身上長(zhǎng)有42處帶血的膿包…… 初始之章·張勛 以下內(nèi)容為張勛視角 年9月15日...
    茶點(diǎn)故事閱讀 36,525評(píng)論 2 327
  • 正文 我和宋清朗相戀三年,在試婚紗的時(shí)候發(fā)現(xiàn)自己被綠了杀餐。 大學(xué)時(shí)的朋友給我發(fā)了我未婚夫和他白月光在一起吃飯的照片干发。...
    茶點(diǎn)故事閱讀 38,664評(píng)論 1 340
  • 序言:一個(gè)原本活蹦亂跳的男人離奇死亡,死狀恐怖史翘,靈堂內(nèi)的尸體忽然破棺而出枉长,到底是詐尸還是另有隱情冀续,我是刑警寧澤,帶...
    沈念sama閱讀 34,334評(píng)論 4 330
  • 正文 年R本政府宣布必峰,位于F島的核電站洪唐,受9級(jí)特大地震影響,放射性物質(zhì)發(fā)生泄漏吼蚁。R本人自食惡果不足惜桐罕,卻給世界環(huán)境...
    茶點(diǎn)故事閱讀 39,944評(píng)論 3 313
  • 文/蒙蒙 一、第九天 我趴在偏房一處隱蔽的房頂上張望桂敛。 院中可真熱鬧,春花似錦溅潜、人聲如沸术唬。這莊子的主人今日做“春日...
    開(kāi)封第一講書(shū)人閱讀 30,764評(píng)論 0 21
  • 文/蒼蘭香墨 我抬頭看了看天上的太陽(yáng)粗仓。三九已至,卻和暖如春设捐,著一層夾襖步出監(jiān)牢的瞬間借浊,已是汗流浹背。 一陣腳步聲響...
    開(kāi)封第一講書(shū)人閱讀 31,997評(píng)論 1 266
  • 我被黑心中介騙來(lái)泰國(guó)打工萝招, 沒(méi)想到剛下飛機(jī)就差點(diǎn)兒被人妖公主榨干…… 1. 我叫王不留蚂斤,地道東北人。 一個(gè)月前我還...
    沈念sama閱讀 46,389評(píng)論 2 360
  • 正文 我出身青樓槐沼,卻偏偏與公主長(zhǎng)得像曙蒸,于是被迫代替她去往敵國(guó)和親。 傳聞我的和親對(duì)象是個(gè)殘疾皇子岗钩,可洞房花燭夜當(dāng)晚...
    茶點(diǎn)故事閱讀 43,554評(píng)論 2 349

推薦閱讀更多精彩內(nèi)容

  • why: 1,微服務(wù)架構(gòu)微服務(wù)增多纽窟,一個(gè)客戶端請(qǐng)求形成一個(gè)復(fù)雜的分布式服務(wù)調(diào)用鏈路,如果任何一個(gè)服務(wù)延遲過(guò)高或...
    xiaoyang08閱讀 3,850評(píng)論 0 5
  • 在各大廠分布式鏈路跟蹤系統(tǒng)架構(gòu)對(duì)比中已經(jīng)介紹了幾大框架的對(duì)比兼吓,如果想用免費(fèi)的可以用zipkin和pinpoint還...
    歡醉閱讀 1,857評(píng)論 2 2
  • 0 問(wèn)題背景 隨著微服務(wù)架構(gòu)的流行臂港,服務(wù)按照不同的維度進(jìn)行拆分,一次請(qǐng)求往往需要涉及到多個(gè)服務(wù)视搏∩竽酰互聯(lián)網(wǎng)應(yīng)用構(gòu)建在不...
    七寸知架構(gòu)閱讀 39,256評(píng)論 8 91
  • Spring Cloud為開(kāi)發(fā)人員提供了快速構(gòu)建分布式系統(tǒng)中一些常見(jiàn)模式的工具(例如配置管理,服務(wù)發(fā)現(xiàn)浑娜,斷路器瓷胧,智...
    卡卡羅2017閱讀 134,633評(píng)論 18 139
  • 概述 我們現(xiàn)在所處的生產(chǎn)環(huán)境是一個(gè)集Nodejs, Go, Java, Ruby, Scala等多種語(yǔ)言程序的混合...
    Kungfu貓熊閱讀 6,232評(píng)論 2 49