Zipkin 分布式数据追踪系统

Zipkin 是一个分布式数据追踪系统，适用于微服务架构下的调用链路数据采集及分析工作。

可通过一个 Web 前端轻松的收集和分析数据，例如用户每次请求服务的处理时间等，可方便的监测系统中存在的瓶颈。

一、配置 Java 环境 安装 JDK

Zipkin 使用 Java8

yum install java-1.8.0-openjdk* -y
java -version

二、安装 Zipkin 

1、创建zipkin安装目录
mkdir -p /opt/server/zipkin && cd "$_"

2、下载 Zipkin
wget -O zipkin.jar 'https://search.maven.org/remote_content?g=io.zipkin.java&a=zipkin-server&v=LATEST&c=exec'

3、启动 Zipkin （nohup & 可以进行后台运行 ）
java -jar zipkin.jar

　　 Zipkin 默认监听 9411 端口

三、配置 MySQL 数据持久化 

　　1、Zipkin 支持的持久化方案很多： Cassandra, MySQL, Elasticsearch。

wget http://dev.mysql.com/get/mysql57-community-release-el7-9.noarch.rpm
rpm -Uvh mysql57-community-release-el7-9.noarch.rpm
yum install mysql-community-server -y
systemctl start mysqld.service

设置 mysql 密码 创建一个zipkin 库；
mysql -uroot -p

> ALTER USER 'root'@'localhost' IDENTIFIED BY 'passwd';

> create database zipkin;

exit

　　2、创建 Zipkin初始化文件  zipkin_init.sql 

　　　  创建了 zipkin_annotations, zipkin_dependencies, zipkin_spans 三张数据表

# cat /opt/server/zipkin/zipkin_init.sql

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);

　　3、初始化导入：

mysql -u root --password='passwd'

> use zipkin; 
> source /opt/server/zipkin/zipkin_init.sql 
> show tables;
> exit

四、重新启动 zipkin

cd /opt/server/zipkin
STORAGE_TYPE=mysql MYSQL_HOST=localhost MYSQL_TCP_PORT=3306 MYSQL_DB=zipkin MYSQL_USER=root MYSQL_PASS='passwd' \
nohup java -jar zipkin.jar &

五、创建一个dome 示例

　　1、搭建 NodeJS 环境

curl --silent --location https://rpm.nodesource.com/setup_8.x | sudo bash -
yum install nodejs -y

　　2、创建 /opt/server/service_testing 工作目录

mkdir -p /opt/server/service_testing 

 

　　3、在 /opt/server/service_testing 目录下创建并编辑 package.json

# cat /opt/server/service_testing/package.json

{
"name": "service_testing",
"version": "1.0.0",
"description": "",
"main": "index.js",
"scripts": {},
"author": "",
"license": "ISC",
"dependencies": {
"express": "^4.15.3",
"zipkin": "^0.7.2",
"zipkin-instrumentation-express": "^0.7.2",
"zipkin-transport-http": "^0.7.2"
}
}

　　4、安装相关依赖

# npm install

　　5、创建并编辑 app.js

# cat /opt/server/service_testing/app.js

const express = require('express');
const {Tracer, ExplicitContext, BatchRecorder} = require('zipkin');
const {HttpLogger} = require('zipkin-transport-http');
const zipkinMiddleware = require('zipkin-instrumentation-express').expressMiddleware;
const ctxImpl = new ExplicitContext();

const recorder = new BatchRecorder({

logger: new HttpLogger( {

endpoint: 'http://127.0.0.1:9411/api/v1/spans'

})

});
const tracer = new Tracer({ctxImpl, recorder});
const app = express();
app.use(zipkinMiddleware({

tracer,

serviceName: 'service-testing'

}));
app.use('/', (req, res, next) => {

res.send('hello one');

});
app.listen(3000, () => {

console.log('service-testing listening on port 3000!')

});

　　6、启动服务 （监听 3000 端口）http://IP:3000

# node app.js

六、zipkin 访问 http://IP:9411 

原文地址：https://www.cnblogs.com/sharesdk/p/9267736.html