都在还说链路跟踪,那么 go-zero 的链路跟踪是咋样的?

简介: 都在还说链路跟踪,那么 go-zero 的链路跟踪是咋样的?

工作中,自然少不了开发去排查问题,那如果链路比较长,客户端一个请求打进来,可能内部微服务进行了多个服务的交互,那么如果其中有一个环节出现了问题,我们如何定位是哪一个请求或者是说是哪一条调用链呢?

可能开发的时候或多或少会加入自己的一些表示,例如请求里面会加入 requuid,链路中涉及的服务都会将这个 requuid 传下去,直到整个调用链结束

当然比较 low 的一种方式是,在微服务交互的请求和相应中加上 requuid 字段,这个应该也是从单体服务过度到微服务开发时特别容易出现的情况

实际上做链路跟踪,简单的方式就是在各种请求的上下文加上 traceid 就可以了,今天我们来看看 go-zero 中的链路跟踪是如何应用的

分别从如下几个部分来看看 go-zero 中应用链路跟踪

  • Http 服务端部分,客户端部分
  • Rpc服务端部分,客户端部分

当然关于日志组件,数据库组件等相关组件,应用到链路跟踪的地方,做法大体一致,我们一起看看 http 和 rpc 服务中应用的方式,其他的组件应用咱们也就可以简单的将知识迁移过去即可上手

Http 服务端部分

对于 ge-zero http ,我们可以一起来看看 服务端部分是如何应用的

简单来说,在我们启动 http 服务的时候,就已经将链路追踪的功能给打开了,go-zero 是通过 http handle 的方式来处理的

当然,同理,我们也可以自己在 go-zero 中加一个 middleware 也是可以达到这样的效果

go-zero 中实际上在我们服务 start 的时候,内部就开始了各种初始化,大体流程是这样的

  • (s *Server) Start() -> (ng *engine) start(router httpx.Router) error

调用内部服务启动,注册路由

  • (ng *engine) bindRoutes(router httpx.Router) -> (ng *engine) bindFeaturedRoutes -> (ng *engine) bindRoute

进行路由的绑定,并默认添加中间件 middleware TracingHandler

我们可以看看关于 TracingHandler 的源码实现

根据代码,我们基本可以看出来 TracingHandler 主要做了这几件事情:

  1. 读取 HeaderCarrier,获取 header 中的上下文 ctx
  2. 如果传入的 path 是空,则新建一个 spanName
  3. tracer.Start 开始去处理 span,设置 span 的类型,属性
  4. request 中产生新的ctx,并将相应的信息封装在 ctx 中,返回

Rpc服务端部分,客户端部分

那其实 rpc 服务端和客户端部分的实现和 http 的也是类似的,http 使用的是中间件的方式来进行处理,那么 rpc 这边块,其实可以通过拦截器的方式来进行处理

服务端

使用 go-zero 项目的框架,我们在启动 rpc 服务的时候,看看都做了些什么

  • 服务 start,go-zero 默认就给我们的 rpc 服务添加了一些默认的拦截器
  • 例如 UnaryTracingInterceptor
  • UnaryCrashInterceptor 等等

其中 UnaryTracingInterceptor 不难看出就是用于做拦路追踪的

而且我们可以看到 rpc 部分的拦截器分为流式的和非流式的,例如用于链路追踪的还有 StreamTracingInterceptor

阅读服务端 UnaryTracingInterceptor 拦截去源码,我们可以知道实际上做法和 http server 部分的做法大体一致

  • 通过 rpc 的 ctx 处理 span
  • 设置 span 的状态和属性等键值对
  • 返回具体服务接口的数据

客户端

那么客户端有什么不一样呢,其实也差不多

当我们 api 层服务在初始化客户端的时候就会使用 zrpc 包的 MustNewClient 方法

跟踪代码我们知道,最终客户端的建立,会去和 rpc 服务端进行建立连接,在建立连接的过程中会带上一些参数

正式 buildDialOptions 在处理 options 的时候将客户端的拦截器给默认加上了 UnaryTracingInterceptorStreamTracingInterceptor

那么 UnaryTracingInterceptor 的具体实现是这个样的:

  • 获取上游带下来的 span 上下文信息,startspan 中处理了关于 span 数据结构中的各种键值对
  • 从获取的 span 中创建新的 ctx,span「继承父span的traceId」
  • 将生成 span 的data加入ctx,传递到下一个中间件,流至下游

关于 微服务框架 go-zero 的链路追踪简单的流程咱们就先走到这里,有兴趣的也可以把他用起来

【欢迎查看历史文章】

感谢阅读,欢迎交流,点个赞,关注一波 再走吧

欢迎点赞,关注,收藏

朋友们,你的支持和鼓励,是我坚持分享,提高质量的动力

好了,本次就到这里

技术是开放的,我们的心态,更应是开放的。拥抱变化,向阳而生,努力向前行。

我是阿兵云原生,欢迎点赞关注收藏,下次见~

可以进入地址进行体验和学习:https://xxetb.xet.tech/s/3lucCI

相关文章
|
3月前
|
存储 中间件 数据库
go-zero 是如何追踪你的请求链路
go-zero 是如何追踪你的请求链路
|
中间件
go-micro集成链路跟踪的方法和中间件原理2
go-micro集成链路跟踪的方法和中间件原理2
91 0
|
开发框架 中间件 .NET
go-micro集成链路跟踪的方法和中间件原理
go-micro集成链路跟踪的方法和中间件原理
141 0
|
9天前
|
存储 JSON 监控
Viper,一个Go语言配置管理神器!
Viper 是一个功能强大的 Go 语言配置管理库,支持从多种来源读取配置,包括文件、环境变量、远程配置中心等。本文详细介绍了 Viper 的核心特性和使用方法,包括从本地 YAML 文件和 Consul 远程配置中心读取配置的示例。Viper 的多来源配置、动态配置和轻松集成特性使其成为管理复杂应用配置的理想选择。
29 2
|
7天前
|
Go 索引
go语言中的循环语句
【11月更文挑战第4天】
18 2
|
7天前
|
Go C++
go语言中的条件语句
【11月更文挑战第4天】
20 2
|
12天前
|
Ubuntu 编译器 Linux
go语言中SQLite3驱动安装
【11月更文挑战第2天】
36 7
|
12天前
|
关系型数据库 Go 网络安全
go语言中PostgreSQL驱动安装
【11月更文挑战第2天】
45 5
|
12天前
|
安全 Go
用 Zap 轻松搞定 Go 语言中的结构化日志
在现代应用程序开发中,日志记录至关重要。Go 语言中有许多日志库,而 Zap 因其高性能和灵活性脱颖而出。本文详细介绍如何在 Go 项目中使用 Zap 进行结构化日志记录,并展示如何定制日志输出,满足生产环境需求。通过基础示例、SugaredLogger 的便捷使用以及自定义日志配置,帮助你在实际开发中高效管理日志。
31 1
|
11天前
|
程序员 Go
go语言中的控制结构
【11月更文挑战第3天】
87 58