rabbitmq+sleuth+zinkip 分布式鏈路追蹤

我們都知道,微服務(wù)之間通過(guò)feign傳遞堕阔,在復(fù)雜的微服務(wù)架構(gòu)系統(tǒng)中,幾乎每一個(gè)前端請(qǐng)求都會(huì)形成一個(gè)復(fù)雜的分布式服務(wù)調(diào)用鏈路,在每條鏈路中任何一個(gè)依賴服務(wù)出現(xiàn)延遲超時(shí)或者錯(cuò)誤都有可能引起整個(gè)請(qǐng)求最后的失敗士聪。當(dāng)業(yè)務(wù)流程足夠復(fù)雜時(shí),一個(gè)完整的HTTP請(qǐng)求調(diào)用鏈一般會(huì)經(jīng)過(guò)多個(gè)微服務(wù)系統(tǒng)柿菩,要通過(guò)日志來(lái)跟蹤一整個(gè)調(diào)用鏈變得不再那么簡(jiǎn)單戚嗅。通過(guò)sleuth可以很方便的看出每個(gè)采集請(qǐng)求的耗時(shí)情況,分析出哪些服務(wù)調(diào)用比較耗時(shí),當(dāng)服務(wù)調(diào)用的耗時(shí)隨著請(qǐng)求量的增大而增大時(shí)懦胞,可以針對(duì)業(yè)務(wù)做一些優(yōu)化措施替久。所以我們可以通過(guò)我們可以通過(guò)Spring Cloud Sleuth來(lái)解決這個(gè)問題。這里我們將演示如何通過(guò)Spring Cloud Sleuth來(lái)追蹤這個(gè)過(guò)程躏尉,并借助Zipkin以圖形化界面的方式展示蚯根。 展示之前,分別介紹一下rabbitmq胀糜、sleuth颅拦、zinkip。

  1. rabbitmq

    • RabbitMQ是實(shí)現(xiàn)了高級(jí)消息隊(duì)列協(xié)議(AMQP)的開源消息代理軟件(亦稱面向消息的中間件)教藻。RabbitMQ服務(wù)器是用Erlang語(yǔ)言編寫的距帅,而群集和故障轉(zhuǎn)移是構(gòu)建在開放電信平臺(tái)框架上的。所有主要的編程語(yǔ)言均有與代理接口通訊的客戶端庫(kù)括堤。
  2. sleuth和zinkip

    • sleuth 是spring cloud的組成部分之一碌秸,為springcloud應(yīng)用實(shí)現(xiàn)了一種分布式追蹤解決方案,其兼容了zinkip,HTrace和log-based追蹤
    • Zipkin 是一款開源的分布式實(shí)時(shí)數(shù)據(jù)追蹤系統(tǒng)(Distributed Tracking System)悄窃,基于 Google Dapper 的論文設(shè)計(jì)而來(lái)讥电,由 Twitter公司開發(fā)貢獻(xiàn)。其主要功能是聚集來(lái)自各個(gè)異構(gòu)系統(tǒng)的實(shí)時(shí)監(jiān)控?cái)?shù)據(jù)轧抗,用來(lái)追蹤微服務(wù)架構(gòu)下的系統(tǒng)延時(shí)問題恩敌。Zipkin 的用戶界面可以呈現(xiàn)一幅關(guān)聯(lián)圖表,以顯示有多少被追蹤的請(qǐng)求通過(guò)了每一層應(yīng)用横媚。Zipkin 以 Trace 結(jié)構(gòu)表示對(duì)一次請(qǐng)求的追蹤纠炮,又把每個(gè) Trace 拆分為若干個(gè)有依賴關(guān)系的 Span。在微服務(wù)架構(gòu)中分唾,一次用戶請(qǐng)求可能會(huì)由后臺(tái)若干個(gè)服務(wù)負(fù)責(zé)處理抗碰,那么每個(gè)處理請(qǐng)求的服務(wù)就可以理解為一個(gè) Span(可以包括 API 服務(wù),緩存服務(wù)绽乔,數(shù)據(jù)庫(kù)服務(wù)以及報(bào)表服務(wù)等)弧蝇。當(dāng)然這個(gè)服務(wù)也可能繼續(xù)請(qǐng)求其他的服務(wù),因此 Span 是一個(gè)樹形結(jié)構(gòu)折砸,以體現(xiàn)服務(wù)之間的調(diào)用關(guān)系看疗。Zipkin 的用戶界面除了可以查看 Span 的依賴關(guān)系之外,還以瀑布圖的形式顯示了每個(gè) Span 的耗時(shí)情況睦授,可以一目了然的看到各個(gè)服務(wù)的性能狀況两芳。

sleuth中的一些術(shù)語(yǔ)

  1. Span:基本工作單元,例如去枷,在一個(gè)新建的span中發(fā)送一個(gè)RPC等同于發(fā)送一個(gè)回應(yīng)請(qǐng)求給RPC怖辆,span通過(guò)一個(gè)64位ID唯一標(biāo)識(shí)是复,trace以另一個(gè)64位ID表示,span還有其他數(shù)據(jù)信息竖螃,比如摘要淑廊、時(shí)間戳事件、關(guān)鍵值注釋(tags)特咆、span的ID季惩、以及進(jìn)度ID(通常是IP地址) ,span在不斷的啟動(dòng)和停止,同時(shí)記錄了時(shí)間信息腻格,當(dāng)你創(chuàng)建了一個(gè)span画拾,你必須在未來(lái)的某個(gè)時(shí)刻停止它。
  2. Trace:一系列spans組成的一個(gè)樹狀結(jié)構(gòu)菜职,例如青抛,如果你正在跑一個(gè)分布式工程,你可能需要?jiǎng)?chuàng)建一個(gè)trace些楣。
  3. Annotation:用來(lái)及時(shí)記錄一個(gè)事件的存在脂凶,一些核心annotations用來(lái)定義一個(gè)請(qǐng)求的開始和結(jié)束
  • cs - Client Sent -客戶端發(fā)起一個(gè)請(qǐng)求宪睹,這個(gè)annotion描述了這個(gè)span的開始
  • sr - Server Received -服務(wù)端獲得請(qǐng)求并準(zhǔn)備開始處理它愁茁,如果將其sr減去cs時(shí)間戳便可得到網(wǎng)絡(luò)延遲
  • ss - Server Sent -注解表明請(qǐng)求處理的完成(當(dāng)請(qǐng)求返回客戶端),如果ss減去sr時(shí)間戳便可得到服務(wù)端需要的處理請(qǐng)求時(shí)間
  • cr - Client Received -表明span的結(jié)束亭病,客戶端成功接收到服務(wù)端的回復(fù)鹅很,如果cr減去cs時(shí)間戳便可得到客戶端從服務(wù)端獲取回復(fù)的所有所需時(shí)間

接下來(lái)就開始搭建
這里cloud版本用的Greenwich.SR1,boot使用的是2.1.6

1.在pom.xml中 引入sleuth依賴

<dependency>
    <groupId>org.springframework.cloud</groupId>
    <artifactId>spring-cloud-starter-sleuth</artifactId>
</dependency> 

2.模擬兩個(gè)日志 這兩個(gè)服務(wù)之間通過(guò)feign調(diào)用罪帖,由test調(diào)用system促煮,這里本來(lái)有一個(gè)注冊(cè)中心,這里就不在演示了

test模塊

@Slf4j
@RestController
public class TestController {

    @Autowired
    private IHelloService helloService;

    @GetMapping("hello")
    public String hello(String name) {
    log.info("Feign調(diào)用system的/hello服務(wù)");
    return this.helloService.hello(name);
   }
}    

在test模塊的service包下創(chuàng)建IHelloService

@FeignClient(value = "system",contextId = "helloServiceClient")
public interface IHelloService {
    @GetMapping("hello")
    String hello(@RequestParam("name") String name);
}

system 模塊

@Slf4j
@RestController
public class TestController {

    @GetMapping("hello")
    public String hello(String name) {
        log.info("/hello服務(wù)被調(diào)用");
        return "hello" + name;
    }
}

3.訪問接口 localhost:8202/test/hello?name=sleuth:會(huì)出現(xiàn)兩個(gè)我們自定義的日志

啟動(dòng)的時(shí)候查看test模塊產(chǎn)生的

2019-08-23 14:22:51.774  INFO [test,72bb0469bee07104,72bb0469bee07104,false] 22728 --- [nio-8202-exec-1] c.m.f.s.test.controller.TestController   : Feign調(diào)用system的/hello服務(wù)

啟動(dòng)的時(shí)候查看system模塊產(chǎn)生的

2019-08-23 14:22:52.469  INFO [system,72bb0469bee07104,43597a6edded6f2e,false] 812 --- [nio-8201-exec-2] c.m.f.s.s.controller.TestController      : /hello服務(wù)被調(diào)用

可以看到整袁,日志里出現(xiàn)了[Test,72bb0469bee07104,72bb0469bee07104,false]信息菠齿,這些信息由Spring Cloud Sleuth生成,用于跟蹤微服務(wù)請(qǐng)求鏈路坐昙。這些信息包含了4個(gè)部分的值绳匀,它們的含義如下:

  1. system微服務(wù)的名稱,與spring.application.name對(duì)應(yīng)炸客;
  2. 72bb0469bee07104稱為Trace ID疾棵,在一條完整的請(qǐng)求鏈路中,這個(gè)值是固定的痹仙。觀察上面的日志即可證實(shí)這一點(diǎn)是尔;
  3. 43597a6edded6f2e稱為Span ID,它表示一個(gè)基本的工作單元开仰;
  4. false表示是否要將該信息輸出到Zipkin等服務(wù)中來(lái)收集和展示拟枚,這里我們還沒有集成Zipkin薪铜,所以為false。

下面我們來(lái)整合Zipkin

在整合Zipkin之前恩溅,我們需要先搭建RabbitMQ痕囱。RabbitMQ用于收集Sleuth提供的追蹤信息,然后Zipkin Server從RabbitMQ里獲取暴匠,這樣可以提升性能鞍恢。

在安裝RabbitMQ之前,需要先安裝Erlang/OTP每窖,下載地址為:http://www.erlang.org/downloads/帮掉,下載exe文件安裝即可。
安裝完畢后窒典,下載RabbitMQ蟆炊,下載地址為 :
http://www.rabbitmq.com/install-windows.html,下載exe文件安裝即可瀑志。

安裝完RabbitMQ之后涩搓,我們到RabbitMQ安裝目錄的sbin下執(zhí)行如下命令

rabbitmq-plugins enable rabbitmq_management

然后在瀏覽器中輸入http://localhost:15672,默認(rèn)用戶名和密碼都是guest劈猪,登錄后可看到:

image

點(diǎn)擊Admin Tab頁(yè)面昧甘,新增一個(gè)用戶:

image

用戶名為febs,密碼為123456战得,角色為管理員充边。新添加的用戶還是No access狀態(tài),需要進(jìn)一步對(duì)該用戶進(jìn)行授權(quán)后常侦,方可以遠(yuǎn)程通過(guò)該用戶名訪問浇冰。點(diǎn)擊該新增用戶名。進(jìn)入授權(quán)頁(yè)面聋亡,點(diǎn)擊Set permission按鈕肘习,進(jìn)行用戶授權(quán)操作。
安裝好RabbitMQ后坡倔,我們開始整合Zipkin漂佩。在較低版本的Spring Cloud中,我們可以自己搭建Zipkin Server致讥,現(xiàn)在我們只能使用官方搭建好的Zipkin Server仅仆,地址為:https://github.com/openzipkin/zipkin

在cmd窗口下運(yùn)行下面這條命令(windows下沒有curl環(huán)境的話,可以在git bash中運(yùn)行這條命令)垢袱,下載zipkin.jar:

curl -sSL https://zipkin.io/quickstart.sh | bash -s

如果下載速度極慢墓拜,可以復(fù)制鏈接到迅雷下載中下載,下載后重命名為zipkin.jar即可请契。

zipkin支持將追蹤信息保存到MySQL數(shù)據(jù)庫(kù)咳榜,所以在運(yùn)行zipkin.jar之前夏醉,我們先準(zhǔn)備好相關(guān)庫(kù)表,SQL腳本地址為:

https://github.com/openzipkin/zipkin/blob/master/zipkin-storage/mysql-v1/src/main/resources/mysql.sql涌韩。

庫(kù)表準(zhǔn)備好后畔柔,運(yùn)行下面這條命令啟動(dòng)zipkin.jar:

java -jar zipkin.jar --server.port=8402 --zipkin.storage.type=mysql --zipkin.storage.mysql.db=febs_cloud_base --zipkin.storage.mysql.username=root --zipkin.storage.mysql.password=123456 --zipkin.storage.mysql.host=localhost --zipkin.storage.mysql.port=3306 --zipkin.collector.rabbitmq.addresses=localhost:5672 --zipkin.collector.rabbitmq.username=febs --zipkin.collector.rabbitmq.password=123456

上面命令指定了數(shù)據(jù)庫(kù)鏈接和RabbitMQ鏈接信息。更多可選配置可以解壓zipkin.jar臣樱,查看zipkin\BOOT-INF\classes路徑下的zipkin-server-shared.yml配置類源碼靶擦。

啟動(dòng)好zipkin.jar后,在對(duì)應(yīng)模塊的pom里引入如下依賴:

<dependency>
    <groupId>org.springframework.cloud</groupId>
    <artifactId>spring-cloud-starter-zipkin</artifactId>
</dependency>
<dependency>
    <groupId>org.springframework.amqp</groupId>
    <artifactId>spring-rabbit</artifactId>
</dependency>

修改對(duì)應(yīng)模塊的application.yml

spring:
  zipkin:
    sender:
      type: rabbit
  sleuth:
    sampler:
      probability: 1
  rabbitmq:
    host: localhost
    port: 5672
    username: febs
    password: 123456

spring.zipkin.sender.type指定了使用RabbitMQ收集追蹤信息雇毫;

spring.sleuth.sampler.probability默認(rèn)值為0.1玄捕,即采樣率才1/10,發(fā)送10筆請(qǐng)求只有一筆會(huì)被采集棚放。為了測(cè)試方便枚粘,我們可以將它設(shè)置為1,即100%采樣飘蚯;

spring.rabbitmq用于配置RabbitMQ連接信息馍迄,你可能會(huì)問,為什么剛剛RabbitMQ端口是15672局骤,這里卻配置為5672攀圈,是不是寫錯(cuò)了呢?其實(shí)不是庄涡,15672是RabbitMQ的管理頁(yè)面端口量承,5672是AMPQ端口。

添加好配置后穴店,啟動(dòng)system和test模塊,發(fā)送一筆localhost:8202/test/hello?name=夏天請(qǐng)求后拿穴,使用瀏覽器訪問http://localhost:8402/zipkin/鏈接,然后點(diǎn)擊圖中所示

image
image
image

查看依賴關(guān)系:

image

查看數(shù)據(jù)表泣洞,看是否存儲(chǔ)了信息:

image

最后,最近很多小伙伴找我要Linux學(xué)習(xí)路線圖默色,于是我根據(jù)自己的經(jīng)驗(yàn)球凰,利用業(yè)余時(shí)間熬夜肝了一個(gè)月,整理了一份電子書腿宰。無(wú)論你是面試還是自我提升呕诉,相信都會(huì)對(duì)你有幫助!目錄如下:

免費(fèi)送給大家吃度,只求大家金指給我點(diǎn)個(gè)贊甩挫!

電子書 | Linux開發(fā)學(xué)習(xí)路線圖

也希望有小伙伴能加入我,把這份電子書做得更完美椿每!

有收獲伊者?希望老鐵們來(lái)個(gè)三連擊英遭,給更多的人看到這篇文章

推薦閱讀:

?著作權(quán)歸作者所有,轉(zhuǎn)載或內(nèi)容合作請(qǐng)聯(lián)系作者
  • 序言:七十年代末,一起剝皮案震驚了整個(gè)濱河市亦渗,隨后出現(xiàn)的幾起案子挖诸,更是在濱河造成了極大的恐慌,老刑警劉巖法精,帶你破解...
    沈念sama閱讀 217,185評(píng)論 6 503
  • 序言:濱河連續(xù)發(fā)生了三起死亡事件多律,死亡現(xiàn)場(chǎng)離奇詭異,居然都是意外死亡搂蜓,警方通過(guò)查閱死者的電腦和手機(jī)菱涤,發(fā)現(xiàn)死者居然都...
    沈念sama閱讀 92,652評(píng)論 3 393
  • 文/潘曉璐 我一進(jìn)店門,熙熙樓的掌柜王于貴愁眉苦臉地迎上來(lái)洛勉,“玉大人粘秆,你說(shuō)我怎么就攤上這事∈蘸粒” “怎么了攻走?”我有些...
    開封第一講書人閱讀 163,524評(píng)論 0 353
  • 文/不壞的土叔 我叫張陵,是天一觀的道長(zhǎng)此再。 經(jīng)常有香客問我昔搂,道長(zhǎng),這世上最難降的妖魔是什么输拇? 我笑而不...
    開封第一講書人閱讀 58,339評(píng)論 1 293
  • 正文 為了忘掉前任摘符,我火速辦了婚禮,結(jié)果婚禮上策吠,老公的妹妹穿的比我還像新娘逛裤。我一直安慰自己,他們只是感情好猴抹,可當(dāng)我...
    茶點(diǎn)故事閱讀 67,387評(píng)論 6 391
  • 文/花漫 我一把揭開白布带族。 她就那樣靜靜地躺著,像睡著了一般蟀给。 火紅的嫁衣襯著肌膚如雪蝙砌。 梳的紋絲不亂的頭發(fā)上,一...
    開封第一講書人閱讀 51,287評(píng)論 1 301
  • 那天跋理,我揣著相機(jī)與錄音择克,去河邊找鬼。 笑死前普,一個(gè)胖子當(dāng)著我的面吹牛肚邢,可吹牛的內(nèi)容都是我干的。 我是一名探鬼主播汁政,決...
    沈念sama閱讀 40,130評(píng)論 3 418
  • 文/蒼蘭香墨 我猛地睜開眼道偷,長(zhǎng)吁一口氣:“原來(lái)是場(chǎng)噩夢(mèng)啊……” “哼缀旁!你這毒婦竟也來(lái)了?” 一聲冷哼從身側(cè)響起勺鸦,我...
    開封第一講書人閱讀 38,985評(píng)論 0 275
  • 序言:老撾萬(wàn)榮一對(duì)情侶失蹤并巍,失蹤者是張志新(化名)和其女友劉穎,沒想到半個(gè)月后换途,有當(dāng)?shù)厝嗽跇淞掷锇l(fā)現(xiàn)了一具尸體懊渡,經(jīng)...
    沈念sama閱讀 45,420評(píng)論 1 313
  • 正文 獨(dú)居荒郊野嶺守林人離奇死亡,尸身上長(zhǎng)有42處帶血的膿包…… 初始之章·張勛 以下內(nèi)容為張勛視角 年9月15日...
    茶點(diǎn)故事閱讀 37,617評(píng)論 3 334
  • 正文 我和宋清朗相戀三年军拟,在試婚紗的時(shí)候發(fā)現(xiàn)自己被綠了剃执。 大學(xué)時(shí)的朋友給我發(fā)了我未婚夫和他白月光在一起吃飯的照片。...
    茶點(diǎn)故事閱讀 39,779評(píng)論 1 348
  • 序言:一個(gè)原本活蹦亂跳的男人離奇死亡懈息,死狀恐怖肾档,靈堂內(nèi)的尸體忽然破棺而出,到底是詐尸還是另有隱情辫继,我是刑警寧澤怒见,帶...
    沈念sama閱讀 35,477評(píng)論 5 345
  • 正文 年R本政府宣布,位于F島的核電站姑宽,受9級(jí)特大地震影響遣耍,放射性物質(zhì)發(fā)生泄漏。R本人自食惡果不足惜炮车,卻給世界環(huán)境...
    茶點(diǎn)故事閱讀 41,088評(píng)論 3 328
  • 文/蒙蒙 一舵变、第九天 我趴在偏房一處隱蔽的房頂上張望。 院中可真熱鬧瘦穆,春花似錦纪隙、人聲如沸。這莊子的主人今日做“春日...
    開封第一講書人閱讀 31,716評(píng)論 0 22
  • 文/蒼蘭香墨 我抬頭看了看天上的太陽(yáng)。三九已至告喊,卻和暖如春,著一層夾襖步出監(jiān)牢的瞬間派昧,已是汗流浹背黔姜。 一陣腳步聲響...
    開封第一講書人閱讀 32,857評(píng)論 1 269
  • 我被黑心中介騙來(lái)泰國(guó)打工, 沒想到剛下飛機(jī)就差點(diǎn)兒被人妖公主榨干…… 1. 我叫王不留蒂萎,地道東北人秆吵。 一個(gè)月前我還...
    沈念sama閱讀 47,876評(píng)論 2 370
  • 正文 我出身青樓,卻偏偏與公主長(zhǎng)得像五慈,于是被迫代替她去往敵國(guó)和親纳寂。 傳聞我的和親對(duì)象是個(gè)殘疾皇子主穗,可洞房花燭夜當(dāng)晚...
    茶點(diǎn)故事閱讀 44,700評(píng)論 2 354