zipkin使用_尚学堂0134之elk的学习及zipkin的数据跟踪

对应作业

1. 安装Logstash
   1. Logstash的作用是什么&＃xff1f;

ElasticSearch是一个基于Lucene的搜索服务器。它提供了一个分布式多用户能力的全文搜索引擎&＃xff0c;基于RESTful web接口。Elasticsearch是用Java语言开发的&＃xff0c;并作为Apache许可条款下的开放源码发布&＃xff0c;是一种流行的企业级搜索引擎。ElasticSearch用于云计算中&＃xff0c;能够达到实时搜索&＃xff0c;稳定&＃xff0c;可靠&＃xff0c;快速&＃xff0c;安装使用方便。官方客户端在Java、.NET&＃xff08;C#&＃xff09;、PHP、Python、Apache Groovy、Ruby和许多其他语言中都是可用的。根据DB-Engines的排名显示&＃xff0c;Elasticsearch是最受欢迎的企业搜索引擎&＃xff0c;其次是Apache Solr&＃xff0c;也是基于Lucene。

1. 安装Kibana
   1. Kibana的作用是什么

图形化界面 ,方便我们管理应用程序

1. Spring_Cloud与ELK的集成-创建项目
   1. 创建Provider接口。
   2. 创建Provider服务。
   3. 修改POM文件&＃xff0c;添加服务相关坐标。
   4. 修改POM文件&＃xff0c;添加sleuth启动器坐标、添加logstash坐标。
   5. 修改配置文件&＃xff0c;添加服务相关配置。
   6. 创建Consumer服务。
   7. 修改POM文件&＃xff0c;添加服务相关坐标。
   8. 修改POM文件&＃xff0c;添加sleuth启动器坐标、添加logstash坐标。
   9. 修改配置文件&＃xff0c;添加服务相关配置。

net.logstash.logback

logstash-logback-encoder

5.0

1. Spring_Cloud与ELK的集成-操作ELK
   1. Kibana操作界面中的Discover的作用是什么&＃xff1f;
   2. Kibana操作界面中的Visualize的作用是什么&＃xff1f;
   3. Kibana操作界面中的Timelion的作用是什么&＃xff1f;
   4. Kibana操作界面中的DevTools的作用是什么&＃xff1f;
   5. Kibana操作界面中的Management的作用是什么&＃xff1f;

Discover 在这个界面可以查询日志数据

Visualize: 视图展示,支持许多风格。

Dashboard:图表展示&＃xff0c;一个仪表板显示 Kibana 保存的一系列可视化

Timelion : 是一个时间序列数据的可视化功能&＃xff0c;可以结合在一个单一的可视化完全独立的数据源。它是由一个简单的表达式语言驱动的&＃xff0c;你用来检索时间序列数据&＃xff0c;进行计算&＃xff0c;找出 复杂的问题的答案&＃xff0c;并可视化的结果。这个功能由一系列的功能函数组成&＃xff0c;同样的查询的结 果&＃xff0c;也可以通过 Dashboard 显示查看。

DevTools可以直接操作 es 中的数据&＃xff0c;使用户方便的通过浏览器直接与 Elasticsearch 进行交互。

管理中的应用是在你执行你的运行时配置 kibana&＃xff0c;包括初始设置和指标进行配置模式&＃xff0c; 高级设置&＃xff0c;调整自己的行为和 Kibana&＃xff0c;各种“对象”&＃xff0c;你可以查看保存在整个 Kibana 的内容 如发现页&＃xff0c;可视化和仪表板。

1. 什么是Zipkin
   1. 什么是Zipkin&＃xff1f;
   2. Zipkin和ELK有什么区别&＃xff1f;

1. 创建Zipkin服务端
   1. &＃64;EnableZipkinServer注解的作用是什么&＃xff1f;

开启ipKinServer端服务

1. Spring Cloud与Zipkin的集成
   1. 创建Provider服务接口项目。
   2. 创建Provider服务。
   3. 修改POM文件&＃xff0c;添加相关坐标。
   4. 修改POM文件&＃xff0c;添加Zipkin坐标。
   5. 修改配置文件&＃xff0c;添加服务相关配置。
   6. 修改配置文件&＃xff0c;添加Zipkin URL配置。
   7. 创建Consumer服务。
   8. 修改POM文件&＃xff0c;添加相关坐标。
   9. 修改POM文件&＃xff0c;添加Zipkin坐标。
   10. 修改配置文件&＃xff0c;添加服务相关配置。
   11. 修改配置文件&＃xff0c;添加Zipkin URL配置。

org.springframework.cloud

spring-cloud-starter-zipkin

spring:

zipkin:

base-url: http://127.0.0.1:9411

enabled: true

sleuth:

web:

client:

enabled: true

sampler:

probability: 1.0 #zipkin采集率 0.1表示 10%采集率

1. Zipkin的原理剖析
   1. Zipkin有哪些时间类型&＃xff1f;每种事件类型表示什么含义&＃xff1f;
   2. Zipkin的执行原理是什么&＃xff1f;

cs: client send

cr: client receive

sr: server receive

ss: server send

1. 采用RabbitMQ收集Zipkin的跟踪数据-创建服务端
   1. &＃64;EnableZipkinStreamServer注解的作用是什么&＃xff1f;

开启运行RabbitMQ的消息驱动Stream

1. 采用RabbitMQ收集Zipkin的跟踪数据-创建客户端
   1. 创建Provider服务。
   2. 需改POM文件&＃xff0c;添加服务相关坐标。
   3. 修改POM文件&＃xff0c;添加Zipkin Stream、Binder Rabbit坐标。
   4. 修改配置文件&＃xff0c;添加服务相关配置。
   5. 修改配置文件&＃xff0c;添加RabbitMQ连接配置。
   6. 创建Consumer服务。
   7. 需改POM文件&＃xff0c;添加服务相关坐标。
   8. 修改POM文件&＃xff0c;添加Zipkin Stream、Binder Rabbit坐标。
   9. 修改配置文件&＃xff0c;添加服务相关配置。
   10. 修改配置文件&＃xff0c;添加RabbitMQ连接配置。
   11. 访问Zipkin服务端查看结果。

1. 跟踪数据持久化到MySQL
   1. 创建Zipkin服务端。
   2. 修改POM文件&＃xff0c;添加服务相关坐标。
   3. 修改POM文件&＃xff0c;添加MySQL数据库驱动坐标&＃xff0c;添加jdbc启动器。
   4. 修改配置文件&＃xff0c;添加服务相关配置
   5. 修改配置文件&＃xff0c;添加Zipkin储存类型。
   6. 执行MySQL脚本。
   7. 访问Zipkin服务端&＃xff0c;查看MySQL数据库中数据。

CREATE TABLE IF NOT EXISTS zipkin_spans (

&＃96;trace_id_high&＃96; BIGINT NOT NULL DEFAULT 0 COMMENT &＃39;If non zero, this means the trace uses 128 bit traceIds instead of 64 bit&＃39;,

&＃96;trace_id&＃96; BIGINT NOT NULL,

&＃96;id&＃96; BIGINT NOT NULL,

&＃96;name&＃96; VARCHAR(255) NOT NULL,

&＃96;parent_id&＃96; BIGINT,

&＃96;debug&＃96; BIT(1),

&＃96;start_ts&＃96; BIGINT COMMENT &＃39;Span.timestamp(): epoch micros used for endTs query and to implement TTL&＃39;,

&＃96;duration&＃96; BIGINT COMMENT &＃39;Span.duration(): micros used for minDuration and maxDuration query&＃39;

) ENGINE&＃61;InnoDB ROW_FORMAT&＃61;COMPRESSED CHARACTER SET&＃61;utf8 COLLATE utf8_general_ci;

ALTER TABLE zipkin_spans ADD UNIQUE KEY(&＃96;trace_id_high&＃96;, &＃96;trace_id&＃96;, &＃96;id&＃96;) COMMENT &＃39;ignore insert on duplicate&＃39;;

ALTER TABLE zipkin_spans ADD INDEX(&＃96;trace_id_high&＃96;, &＃96;trace_id&＃96;, &＃96;id&＃96;) COMMENT &＃39;for joining with zipkin_annotations&＃39;;

ALTER TABLE zipkin_spans ADD INDEX(&＃96;trace_id_high&＃96;, &＃96;trace_id&＃96;) COMMENT &＃39;for getTracesByIds&＃39;;

ALTER TABLE zipkin_spans ADD INDEX(&＃96;name&＃96;) COMMENT &＃39;for getTraces and getSpanNames&＃39;;

ALTER TABLE zipkin_spans ADD INDEX(&＃96;start_ts&＃96;) COMMENT &＃39;for getTraces ordering and range&＃39;;

CREATE TABLE IF NOT EXISTS zipkin_annotations (

&＃96;trace_id_high&＃96; BIGINT NOT NULL DEFAULT 0 COMMENT &＃39;If non zero, this means the trace uses 128 bit traceIds instead of 64 bit&＃39;,

&＃96;trace_id&＃96; BIGINT NOT NULL COMMENT &＃39;coincides with zipkin_spans.trace_id&＃39;,

&＃96;span_id&＃96; BIGINT NOT NULL COMMENT &＃39;coincides with zipkin_spans.id&＃39;,

&＃96;a_key&＃96; VARCHAR(255) NOT NULL COMMENT &＃39;BinaryAnnotation.key or Annotation.value if type &＃61;&＃61; -1&＃39;,

&＃96;a_value&＃96; BLOB COMMENT &＃39;BinaryAnnotation.value(), which must be smaller than 64KB&＃39;,

&＃96;a_type&＃96; INT NOT NULL COMMENT &＃39;BinaryAnnotation.type() or -1 if Annotation&＃39;,

&＃96;a_timestamp&＃96; BIGINT COMMENT &＃39;Used to implement TTL; Annotation.timestamp or zipkin_spans.timestamp&＃39;,

&＃96;endpoint_ipv4&＃96; INT COMMENT &＃39;Null when Binary/Annotation.endpoint is null&＃39;,

&＃96;endpoint_ipv6&＃96; BINARY(16) COMMENT &＃39;Null when Binary/Annotation.endpoint is null, or no IPv6 address&＃39;,

&＃96;endpoint_port&＃96; SMALLINT COMMENT &＃39;Null when Binary/Annotation.endpoint is null&＃39;,

&＃96;endpoint_service_name&＃96; VARCHAR(255) COMMENT &＃39;Null when Binary/Annotation.endpoint is null&＃39;

) ENGINE&＃61;InnoDB ROW_FORMAT&＃61;COMPRESSED CHARACTER SET&＃61;utf8 COLLATE utf8_general_ci;

ALTER TABLE zipkin_annotations ADD UNIQUE KEY(&＃96;trace_id_high&＃96;, &＃96;trace_id&＃96;, &＃96;span_id&＃96;, &＃96;a_key&＃96;, &＃96;a_timestamp&＃96;) COMMENT &＃39;Ignore insert on duplicate&＃39;;

ALTER TABLE zipkin_annotations ADD INDEX(&＃96;trace_id_high&＃96;, &＃96;trace_id&＃96;, &＃96;span_id&＃96;) COMMENT &＃39;for joining with zipkin_spans&＃39;;

ALTER TABLE zipkin_annotations ADD INDEX(&＃96;trace_id_high&＃96;, &＃96;trace_id&＃96;) COMMENT &＃39;for getTraces/ByIds&＃39;;

ALTER TABLE zipkin_annotations ADD INDEX(&＃96;endpoint_service_name&＃96;) COMMENT &＃39;for getTraces and getServiceNames&＃39;;

ALTER TABLE zipkin_annotations ADD INDEX(&＃96;a_type&＃96;) COMMENT &＃39;for getTraces&＃39;;

ALTER TABLE zipkin_annotations ADD INDEX(&＃96;a_key&＃96;) COMMENT &＃39;for getTraces&＃39;;

ALTER TABLE zipkin_annotations ADD INDEX(&＃96;trace_id&＃96;, &＃96;span_id&＃96;, &＃96;a_key&＃96;) COMMENT &＃39;for dependencies job&＃39;;

CREATE TABLE IF NOT EXISTS zipkin_dependencies (

&＃96;day&＃96; DATE NOT NULL,

&＃96;parent&＃96; VARCHAR(255) NOT NULL,

&＃96;child&＃96; VARCHAR(255) NOT NULL,

&＃96;call_count&＃96; BIGINT,

&＃96;error_count&＃96; BIGINT

) ENGINE&＃61;InnoDB ROW_FORMAT&＃61;COMPRESSED CHARACTER SET&＃61;utf8 COLLATE utf8_general_ci;

ALTER TABLE zipkin_dependencies ADD UNIQUE KEY(&＃96;day&＃96;, &＃96;parent&＃96;, &＃96;child&＃96;);

mysql:

jdbc-url: ${MYSQL_JDBC_URL:}

host: ${MYSQL_HOST:localhost}

port: ${MYSQL_TCP_PORT:3306}

username: ${MYSQL_USER:}

password: ${MYSQL_PASS:}

db: ${MYSQL_DB:zipkin}

max-active: ${MYSQL_MAX_CONNECTIONS:10}

use-ssl: ${MYSQL_USE_SSL:false}

1. 什么是分布式事务
   1. 什么是分布式事务&＃xff1f;

分布式事务是指事务的参与者、支持事务的服务器、资源服务器以及事务管理器分别位于不同的分布式系统的不同节点之上。

1. XA的两阶段提交方案
2. 什么是XA协议&＃xff1f;
3. 什么是XA一阶段提交&＃xff1f;
4. 什么是XA二阶段提交&＃xff1f;

XA 协议由Oracle Tuxedo 首先提出的&＃xff0c;并交给X/Open 组织&＃xff0c;作为资源管理器&＃xff08;数据库&＃xff09;与事务管理器的接口标准。目前&＃xff0c;Oracle、Informix、DB2 和Sybase 等各大数据库厂家都提供对XA 的支持。XA 协议采用两阶段提交方式来管理分布式事务。XA 接口提供资源管理器与事务管理器之间进行通信的标准接口。

一阶段提交协议相对简单。优点也很直观&＃xff0c;它不用再与其他的对象交互&＃xff0c;节省了判断步骤和时间&＃xff0c;所以在性能上是在阶段提交协议中最好的。

但缺点也很明显&＃xff1a;数据库确认执行事务的时间较长&＃xff0c;出问题的可能性就随之增大。如果有多个数据源&＃xff0c;一阶段提交协议无法协调他们之间的关系。

二阶段三角色: 在一阶段协议的基础上&＃xff0c;有了二阶段协议&＃xff0c;二阶段协议的好处是添加了一个管理者角色。

很明显&＃xff0c;二阶段协议通过将两层变为三层&＃xff0c;增加了中间的管理者角色&＃xff0c;从而协调多个数据源之间的关系&＃xff0c;二阶段提交协议分为两个阶段。

1. TCC分布式事务解决方案
   1. 什么是TCC解决方案&＃xff1f;
   2. TCC原理是什么&＃xff1f;
   3. TC优点是什么&＃xff1f;
   4. TCC的缺点是什么&＃xff1f;

TCC 是由支付宝架构师提供的一种柔性解决分布式事务解决方案,主要包括三个步骤

Try&＃xff1a;预留业务资源/数据效验

Confirm&＃xff1a;确认执行业务操作

Cancel&＃xff1a;取消执行业务操作

TCC 方案在电商、金融领域落地较多。TCC 方案其实是两阶段提交的一种改进。

其将整个业务逻辑的每个分支显式的分成了Try、Confirm、Cancel 三个操作.

Try 部分完成业务的准备工作&＃xff0c;confirm 部分完成业务的提交&＃xff0c;cancel 部分完成事务的回滚。

让应用自己定义数据库操作的粒度&＃xff0c;使得降低锁冲突、提高吞吐量成为可能。

对应用的侵入性强。业务逻辑的每个分支都需要实现try、confirm、cancel三个操作&＃xff0c;

应用侵入性较强&＃xff0c;改造成本高。实现难度较大。

需要按照网络状态、系统故障等不同的失败原因实现不同的回滚策略。

为了满足一致性的要求&＃xff0c;confirm 和cancel 接口必须实现幂等。

1. 分布式事务中间件解决方案
   1. 什么是分布式事务中间件解决方案&＃xff1f;

分布式事务中间件其本身并不创建事务&＃xff0c;而是基于对本地事务的协调从而达到事务一致性的效果。典型代表有&＃xff1a;阿里的GTS&＃xff08;https://www.aliyun.com/aliware/txc&＃xff09;、开源应用LCN。

1. 什么是LCN框架
   1. 什么事LCN分布式事务处理框架&＃xff1f;

在设计框架之初的1.0 ~ 2.0 的版本时&＃xff0c;框架设计的步骤是如下的&＃xff0c;各取其首字母得来的LCN 命名。

LCN: 锁定事务单元&＃xff08;lock&＃xff09;、确认事务模块状态(confirm)、通知事务(notify)

它的宗旨 : LCN 并不生产事务&＃xff0c;LCN 只是本地事务的协调工