Dubbo + Zipkin + Brave 实现全链路追踪

Posted 2021-04-06 OSC开源社区

链接：

https://my.oschina.net/LucasZhu/blog/2051269

最近写了一个链路追踪Demo分享下，实现了链路追踪过程中数据的记录，还有能扩展的地方，后期再继续补充。

原理参考上面文章 《Dubbo链路追踪——生成全局ID（traceId）》：

• https://my.oschina.net/LucasZhu/blog/2046356

实现链路追踪的目的

• 服务调用的流程信息，定位服务调用链

• 记录调用入参及返回值信息，方便问题重现

• 记录调用时间线，代码重构及调优处理

• 调用信息统计

分布式跟踪系统还有其他比较成熟的实现，例如：Naver的Pinpoint、Apache的HTrace、阿里的鹰眼Tracing、京东的Hydra、新浪的Watchman，美团点评的CAT，skywalking等。 本次主要利用Dubbo数据传播特性扩展Filter接口来实现链路追踪的目的

重点主要是zipkin及brave使用及特性,当前brave版本为 5.2.0 为 2018年8月份发布的release版本 , zipkin版本为2.2.1 所需JDK为1.8

快速启动zipkin

下载最新的zipkin并启动

输入 http://localhost:9411/zipkin/ 进入WebUI界面如下 

核心源码

代码的初步版本：方便描述

1. 构建客户端发送工具

2. 构建异步reporter

3. 构建tracing上下文

4. 初始化injector 和 Extractor [tab]4.1 extractor 指数据提取对象,用于在carrier中提取TraceContext相关信息或者采样标记信息到TraceContextOrSamplingFlags 中 -4.2 injector 用于将TraceContext中的各种数据注入到carrier中,其中carrier一半是指数据传输中的载体,类似于Dubbo中Invocation中的attachment(附件集合)

5. 判断此次调用是作为服务端还是客户端

6. rpc客户端调用会从ThreadLocal中获取parent的 TraceContext ,为新生成的Span指定traceId及 parentId如果没有parent traceContext 则生成的Span为 root span

7. 将Span绑定的TraceContext中 属性信息 Copy 到 Invocation中达到远程参数传递的作用

8. rpc服务提供端 , 从invocation中提取TraceContext相关信息及采样数据信息

9. 生成span , 兼容初次服务端调用

10. 记录接口信息及远程IP Port

11. 将创建的Span 作为当前Span (可以通过Tracer.currentSpan 访问到它) 并设置查询范围

12. oneway调用即只请求不接受结果

13. 如果future不为空则为 async 调用 在回调中finish span

14. 设置异步回调，回调代码执行span finish() .

15. oneway调用 因为不需等待返回值 即没有 cr (Client Receive) 需手动flush()

16. 同步调用 业务代码执行完毕后需手动finish()

17. 设置枚举类 与 Dubbo中RpcException保持对应

测试项

• Dubbo sync async oneway 测试

• RPC异常测试

• 普通业务异常测试

• 并发测试

配置方式

POM依赖添加

资源目录根路径下添加tracing.properties文件 

 一次调用信息 

调用链 

调用成功失败汇总 

zipkinHost 指定zipkin服务器IP:PORT 默认为localhost:9411 serviceName 指定应用名称 默认为trace-default

调用链： 

待扩展项

• 抽象数据传输（扩展Kafka数据传输）

• 调用返回值数据打印

• 更灵活的配置方式

• https://github.com/ZhuBaker/Tracing

送书啦！

参与活动↓↓↓↓↓

《》

就有机会活动精美图书一本

快来参与吧！

推荐阅读

点击“阅读原文”查看更多精彩内容