转载

『互联网架构』调⽤链系统底层逻辑（108）

调用链系统很多：Dapper，鹰眼，hydra，cat，zipkin，skywalking。其实不管是任何一个调用链系统，底层的实现都是一致的。一起了解下它的底层实现。

源码：https://github.com/limingios/netFuture/tree/master/源码/『互联网架构』调⽤链系统底层逻辑（108）/

（一）调⽤链系统的本质

⼀张⽹⻚，要经历怎样的过程，才能抵达⽤户⾯前?

这是阿里早期面试最喜欢问的问题，问这个问题就是要了解你对技术的宽度。
⽹络传输层

『互联网架构』调⽤链系统底层逻辑（108）

# 该命令可直接跟踪网络通信所经过的节点
tracert www.baidu.com

『互联网架构』调⽤链系统底层逻辑（108）

负载均衡层

> 早期的监控系统只监控网络服务。

『互联网架构』调⽤链系统底层逻辑（108）

系统服务层

> 现在的监控系统直接深入系统的内部。应用系统，数据库，第三方的资源服务，请求第三方api的接口。

『互联网架构』调⽤链系统底层逻辑（108）

调⽤链基本元素

> 基本所有的调用系统都是这些元素，可能名称叫法不同。

1.事件

请求处理过程当中的具体动作

2.节点

请求所经过的系统节点，即事件的空间属性。

3.时间

事件的开始和结束时间

4.关系

事件与上⼀个事件关系。

0.1和0.1.1，0.1.2是父子关系

02和0.2.3，0.2.1，0.2.2是是父子关系。

吃饭是一个事件，夹筷子是吃饭的子事件，张嘴是吃饭的子事件。嘴动是吃饭的子事件。都是嵌套关系。

调⽤链系统本质上就是⽤来回答这⼏问题

> 跟写作文一样，时间，地点，任务，事件。（事件是一个串一个，还要保证他们之间的关系不是错综复杂的，还要并发的情况这些调用事件不是错乱的才算完成，理论很简单，但是真正要搞明白，在生产环境使用还要解决很多很多问题。）

1.什么时间？

2.在什么节点上？

3.发⽣了什么事情？

4.这个事情由谁触发？

事件捕捉

> 其实就是输出信息

1.硬编码埋点捕捉

2.AOP埋点捕捉

3.公开组件埋点捕捉

4.字节码插桩捕捉

事件串联

>事件串联的⽬的

1.所有事件都关联到同⼀个调⽤

2.各个事件之间是有层级关系的

为了到达这两个⽬的地，⼏乎所有的调⽤链系统都会有以下两个属性：

trackID:在整个系统中唯⼀，该值相同的事件表示同⼀次调⽤。

eventID（spanID）:在⼀次调⽤中唯⼀、并展出事件的层级关系

1、怎么⽣成TrackID

2、怎么传递参数

3、怎么并发情况下不允响传递的结果

『互联网架构』调⽤链系统底层逻辑（108）

串联的过程：
1.由跟踪的起点⽣成⼀个TrackId，⼀直传递⾄所有节点，并保存在事件属性值当中。
2.由跟踪的起点⽣成初始EventId（SpanID），每捕捉⼀个事件ID加1，每传递⼀次，层级加1。
trackId与eventId 的传递

『互联网架构』调⽤链系统底层逻辑（108）

eventId ⾃增⽣成⽅式

> 埋在具体某个实现⽅法类，当多线程调⽤该⽅法时如何保证⾃增正确性？

『互联网架构』调⽤链系统底层逻辑（108）

解决办法是每个跟踪请求创建⼀个互相独⽴的会话，EventId的⾃增都基于该会话实现。通常会话对象的存储基于ThreadLocal实现。

事件的开始与结束

> 我们知道⼀个事件是⼀个时间段内系统执⾏的若⼲动作，所以对于事件捕捉必须包含开启监听和结束监听两个动作？如果⼀个事件在⼀个⽅法内完成的，这个问题是⽐较好解决的，我们只要在⽅法的开始创建⼀个Event对象，在⽅法结束时调⽤该对像的close ⽅法即可。

public void addUser(){ 
// 方法的开始处，开启一个监听 
Event event=new Event(); 
//业务代码执行 
..... 
..... 
// 方法的结束处，关闭一个监听 
event.close(); 
}

但如果⼀个事件的开始和结束触发分布在多个对象或⽅法当中，情况就会变得异常复杂。⽐如⼀个JDBC执⾏事件，应该是在构建 Statement 时开始，在Statement 关闭时结束。怎样把这两个触发动作对应到同⼀个事件当中去呢（即传递Event对象）？在这⾥的解决办法是对返回结果进⾏动态代理，把Event放置到代理对象的属性当中，以达到付递的⽬标。当这个⽅法只是适应JDBC这⼀个场景，其它场景需要重新设计Event 传递路径，⽬前还没有通⽤的解决办法。

// JDBC事件开始 
Connection.prepareStatement(String sql); 
//JDBC 事件结束 
PreparedStatement.close();

上传

基于Http请求直接上传
打印⽇志，然后在基于Flume或Logstash采集上传。
第⼀种相对简单，直接把数据发送服务进⾏持久化，但如果系统流量较⼤的情况下，会影响系统本身的性能，造成压⼒。第⼆种相对复杂，但可以应对⼤流量，通常情况下会采⽤第⼆种解决办法

（二）项⽬部署

调⽤链Agent 如何部署

下载 agent.zip ⾄应⽤系统
解压缩 agent.zip
添加jvm 参数 -javaagent: <cbt-agent-bootstrap-1.0-SNAPSHOT.jar 路径>
重启应⽤

『互联网架构』调⽤链系统底层逻辑（108）

1.下载Agent.zip

2.在你启动项⽬的JVM参数⾥添加 -javaagent:cbt-agent-bootstrap-1.0-SNAPSHOT.jar

3.重启你的应⽤，观察你的应⽤⽇志，如果发现以下⽇志代表启动成功了

[2018-06-12:10:32:42]加载藏宝图配置文件来自G:gitcbt-
agentoutconfcbt.properties
[2018-06-12:10:32:43]藏宝图服务登陆成功! 
[2018-06-12:10:32:43]藏宝图服务启动成功!

4.登陆调⽤链管理WEB⻚⾯ http://client.cbtu.pro:9978/trace/requests

PS：调用链系统并非自己原创，也是通过网络学习获得的，但是我会在上边进行改良，以达到自己需要，并会告诉大家如何搭建，最终可以在微服务项目上受用。

>>原创文章，欢迎转载。转载请注明：转载自，谢谢！>>原文链接地址：上一篇:

已是最新文章

原文 https://idig8.com/2019/07/12/hulianwangjiagoudiaolianxitongdicengluoji108/

正文到此结束

所属分类：编程技术 Java

本文标签： REST 下载 javaagent 微服务源码线程管理 App 文章本质 Agent web 数据库 Bootstrap 空间 ACE zipkin zab zip 数据 http id Statement java 负载均衡 UI 时间 src Master JDBC 2019 https 配置代码 client AOP 字节码部署 git sql GitHub Connection IO JVM UTC ip cat 多线程参数 IOS 回答并发 db 互联网 API
版权声明： 本文为互联网转载文章，出处已在文章中说明(部分除外)。如果侵权，请联系本站长删除，谢谢。
本文海报： 生成海报一生成海报二

其他链接

关于本站

本站定位：个人技术类博客

本站作用：写博客、记日志、闲聊扯淡鼓捣技术。

问题交流

『互联网架构』调⽤链系统底层逻辑（108）

（一）调⽤链系统的本质

（二）项⽬部署

热门推荐

相关文章

说给你听

本文目录

随机标签

书籍教程

近期评论

网站信息

其他链接

关于本站

问题交流