摘要：注本文首發(fā)于公眾號(hào)，可長(zhǎng)按或掃描下面的小心心來(lái)訂閱擴(kuò)展組件是在微服務(wù)調(diào)用鏈追蹤中心搭建一文中編寫(xiě)的與通信的工具組件，利用其追蹤微服務(wù)調(diào)用鏈的，現(xiàn)在我們想追蹤數(shù)據(jù)庫(kù)調(diào)用鏈的話，可以擴(kuò)展一下其功能。

在前面：微服務(wù)調(diào)用鏈追蹤中心搭建 一文中我們利用Zipkin搭建了一個(gè)微服務(wù)調(diào)用鏈的追蹤中心，并且模擬了微服務(wù)調(diào)用的實(shí)驗(yàn)場(chǎng)景。利用Zipkin的庫(kù)Brave，我們可以收集一個(gè)客戶端請(qǐng)求從發(fā)出到被響應(yīng) 經(jīng)歷了哪些組件、哪些微服務(wù)、請(qǐng)求總時(shí)長(zhǎng)、每個(gè)組件所花時(shí)長(zhǎng) 等信息。

本文將講述如何利用Zipkin對(duì)Mysql數(shù)據(jù)庫(kù)的調(diào)用進(jìn)行追蹤，這里同樣借助OpenZipkin庫(kù)Brave來(lái)完成。

注： 本文首發(fā)于 My 公眾號(hào) CodeSheep ，可 長(zhǎng)按 或 掃描 下面的 小心心 來(lái)訂閱 ↓ ↓ ↓

ZipkinTool是在《微服務(wù)調(diào)用鏈追蹤中心搭建》一文中編寫(xiě)的與Zipkin通信的工具組件，利用其追蹤微服務(wù)調(diào)用鏈的，現(xiàn)在我們想追蹤Mysql數(shù)據(jù)庫(kù)調(diào)用鏈的話，可以擴(kuò)展一下其功能。

pom.xml添加依賴：

        io.zipkin.brave
        brave-mysql
        4.0.6

在ZipkinConfiguration類中添加MySQLStatementInterceptorManagementBean

    @Bean
    public MySQLStatementInterceptorManagementBean mySQLStatementInterceptorManagementBean() {
        return new MySQLStatementInterceptorManagementBean(brave().clientTracer());
    }

依然繼承前文：《微服務(wù)調(diào)用鏈追蹤中心搭建》，我們改造一下文中的ServiceC這個(gè)微服務(wù)，在其中添加與Mysql數(shù)據(jù)庫(kù)的交互。

pom.xml中添加JDBC和Mysql依賴

        
            org.springframework.boot
            spring-boot-starter-jdbc
        
        
            mysql
            mysql-connector-java
            runtime
        

application.properties中添加Mysql連接的配置

spring.datasource.driver-class-name=com.mysql.jdbc.Driver
spring.datasource.url=jdbc:mysql://你的Mysql服務(wù)所在IP:3307/test?useSSL=false
  &statementInterceptors=com.github.kristofa.brave.mysql.MySQLStatementInterceptor
  &zipkinServiceName=mysqlService
spring.datasource.username=root
spring.datasource.password=XXXXXX

Controller中添加JdbcTemplate訪問(wèn)數(shù)據(jù)庫(kù)的代碼

    @GetMapping("/mysqltest”)
    public String mysqlTest() {
        String name = jdbcTemplate.queryForObject( "SELECT name FROM user WHERE id = 1", String.class );
        return "Welcome " + name;
    }

1. 啟動(dòng)Mysql容器

docker run -d -p 3307:3306 
-v ~/mysql/data:/var/lib/mysql 
-v ~/mysql/conf:/etc/mysql/conf.d 
-e MYSQL_ROOT_PASSWORD=XXXXXX 
--name mysql mysql

2. 再啟動(dòng)一個(gè)Mysql容器，接入其中做一些設(shè)置

首先進(jìn)入mysql命令行

docker run -it --rm 
--link mysql:mysql mysql 
mysql -hmysql -u root -p

接下來(lái)創(chuàng)建數(shù)據(jù)庫(kù)zipkin： 用于存放Zipkin所收集的數(shù)據(jù)

CREATE DATABASE `zipkin`

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,
  `error_count` BIGINT
) ENGINE=InnoDB ROW_FORMAT=COMPRESSED CHARACTER SET=utf8 COLLATE utf8_general_ci;

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

這里創(chuàng)建了三個(gè)數(shù)據(jù)表。

該Sql文件可以從以下鏈接獲得：https://github.com/openzipkin...

Sql腳本執(zhí)行完成后，可以看到zipkin相關(guān)的三個(gè)表已經(jīng)建成：

創(chuàng)建數(shù)據(jù)庫(kù)test：用作測(cè)試數(shù)據(jù)庫(kù)

CREATE DATABASE `test`
CREATE TABLE `user` (
  `id` int(11) unsigned NOT NULL auto_increment,
  `name` varchar(100) DEFAULT NULL ,
  PRIMARY KEY (`id`)
) ENGINE=InnoDB DEFAULT CHARSET = utf8;

insert into user values (1,”hansonwang99”)

這里插入了一條數(shù)據(jù)用于實(shí)驗(yàn)。

docker run -d -p 9411:9411 
--link mysql:mysql 
-e STORAGE_TYPE=mysql 
-e MYSQL_HOST=mysql 
-e MYSQL_TCP_PORT=3306 
-e MYSQL_DB=zipkin 
-e MYSQL_USER=root 
-e MYSQL_PASS=XXXXXX 
 --name zipkin openzipkin/zipkin

在瀏覽器中輸入：localhost:8883/mysqltest，如果看到以下輸出，就可以證明數(shù)據(jù)庫(kù)調(diào)用操作已經(jīng)成功了！

瀏覽器輸入：http://localhost:9411/zipkin/

打開(kāi)Zipkin Web UI，點(diǎn)擊服務(wù)名下拉列表能看見(jiàn)已經(jīng)成功識(shí)別了Mysql數(shù)據(jù)庫(kù)調(diào)用服務(wù)

選中mysqlservice后，點(diǎn)擊Find Traces

可以看到 首次查詢 Mysql的調(diào)用鏈追蹤信息，有很多

隨便點(diǎn)開(kāi)某一個(gè)查看：

接下來(lái)瀏覽器中再次輸入：localhost:8883/mysqltest

目的是再次觸發(fā)Mysql的調(diào)用，然后再次Find Traces，可以看到追蹤數(shù)據(jù)類似下圖：包含兩次Mysql的query動(dòng)作：

點(diǎn)開(kāi)第一個(gè)query查看，其實(shí)際上是在 嘗試連接Mysql數(shù)據(jù)庫(kù)

點(diǎn)開(kāi)第二個(gè)query查看，發(fā)現(xiàn)這里才是 實(shí)際查詢業(yè)務(wù)

從圖形化界面上可以清楚地知道每個(gè)階段的詳細(xì)步驟與耗時(shí)，因此可以用來(lái)分析哪個(gè)SQL語(yǔ)句執(zhí)行相對(duì)較慢。

本文實(shí)驗(yàn)所用源碼已經(jīng)開(kāi)源，需要的話請(qǐng) 自取。

作者更多的原創(chuàng)文章在此，歡迎觀賞

My Personal Blog

作者更多的SpringBt實(shí)踐文章在此：

Spring Boot應(yīng)用監(jiān)控實(shí)戰(zhàn)

SpringBoot應(yīng)用部署于外置Tomcat容器

ElasticSearch搜索引擎在SpringBt中的實(shí)踐

初探Kotlin+SpringBoot聯(lián)合編程

Spring Boot日志框架實(shí)踐

SpringBoot優(yōu)雅編碼之：Lombok加持

如果有興趣，也可以抽點(diǎn)時(shí)間看看作者一些關(guān)于容器化、微服務(wù)化方面的文章：

利用K8S技術(shù)棧打造個(gè)人私有云 連載文章

從一份配置清單詳解Nginx服務(wù)器配置

Docker容器可視化監(jiān)控中心搭建

利用ELK搭建Docker容器化應(yīng)用日志中心

RPC框架實(shí)踐之：Apache Thrift

RPC框架實(shí)踐之：Google gRPC

微服務(wù)調(diào)用鏈追蹤中心搭建

Docker容器跨主機(jī)通信

Docker Swarm集群初探

高效編寫(xiě)Dockerfile的幾條準(zhǔn)則