- ubuntu12.04环境下使用kvm ioctl接口实现最简单的虚拟机
- Ubuntu 通过无线网络安装Ubuntu Server启动系统后连接无线网络的方法
- 在Ubuntu上搭建网桥的方法
- ubuntu 虚拟机上网方式及相关配置详解
CFSDN坚持开源创造价值,我们致力于搭建一个资源共享平台,让每一个IT人在这里找到属于你的精彩世界.
这篇CFSDN的博客文章详解如何在Go服务中做链路追踪由作者收集整理,如果你对这篇文章有兴趣,记得点赞哟.
使用 Go 语言开发微服务的时候,需要追踪每一个请求的访问链路,这块在 Go 中目前没有很好的解决方案.
在 Java 中解决这个问题比较简单,可以使用 MDC,在一个进程内共享一个请求的 RequestId.
在 Go 中实现链路追踪有两种思路:一种是在项目中使用一个全局的 map, key 是 goroutine 的唯一 Id,value 是 RequestId,另一种思路可以使用 context.Context 来实现.
下面的代码基于 gin 框架来实现.
使用 map 方案需要在全局维护一个 map,在一个请求进来的时候,会为每一个请求生成 RequestId,然后在每次在打印日志的时候,从这个 Map 中通过 goid 获取到 RequestId,打印到日志中.
代码的实现很简单:
1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27
28
|
var requestIdMap = make(map[int64]string) // 全局的 Map
func main() {
r := gin.Default()
r.Use(Logger()) // 使用中间件
r.GET("/index", func(c *gin.Context) {
Info("main goroutine") // 打印日志
c.JSON(200, gin.H{
"message": "index",
})
})
r.Run()
}
func Logger() gin.HandlerFunc {
return func(c *gin.Context) {
requestIdMap[goid.Get()] = uuid.New().String() // 在日志中间件中为每个请求设定
c.Next()
}
}
func Info(msg string) {
now := time.Now()
nowStr := now.Format("2006-01-02 15:04:05")
fmt.Printf("%s [%s] %s\n", nowStr, requestIdMap[goid.Get()], msg) // 打印日志
}
|
这样的实现很简单,但是问题也很多.
第一个问题就是,在 Go 程序中,一次请求可能会涉及到多个 goroutine,用这种方式很难在多个 gotoutine 之间传递 RequestId.
在下面的代码中,如果新启动了一个 goroutine,就会导致日志中获取不到 RequestId:
1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
|
func main() {
r := gin.Default()
r.Use(Logger())
r.GET("/index", func(c *gin.Context) {
Info("main goroutine")
go func() { // 这里新启动了一个一个 goroutine
Info("goroutine1")
}()
c.JSON(200, gin.H{
"message": "index",
})
})
r.Run()
}
|
获取 goroutine id 也不是一种常规的做法,一般要通过 hack 的方式来获取,这种做法已经不推荐了。而且这个全局的 map 为了并发安全,在实际的使用中,可以还需要用到锁,在高并发的情况下必然会影响性能.
在每个请求结束的时候,还需要手动的把 requestId 从 map 中删除,否则就会造成内存泄漏.
总的来说,使用 map 这种方式来实现并不是很好.
在上面的代码中,我们使用一个 hack 的方式去获取 goroutine id,这种方式早就不推荐使用,更推荐使用 Context,关于 Context 内容,可以去看我之前的文章,在这里就不多说了.
在传递 RequestId 的场景中,同样也可以使用 Context 来实现,使用 Context 好处很明显,Context 生命周期与请求相同,不需要手动销毁。而且Context 是每个请求独享的,也不用担心并发安全的问题,Context 还可以在 goroutine 之间传递.
使用 Context 实现的代码如下:
1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27
28
29
30
31
32
33
34
|
func main() {
r := gin.Default()
r.Use(Logger())
r.GET("/index", func(c *gin.Context) {
ctx, _ := c.Get("ctx")
Info(ctx.(context.Context) , "main goroutine")
go func() {
Info(ctx.(context.Context), "goroutine1")
}()
c.JSON(200, gin.H{
"message": "index",
})
})
r.Run()
}
func Logger() gin.HandlerFunc {
return func(c *gin.Context) {
valueCtx := context.WithValue(c.Request.Context(), "RequestId", uuid.New().String())
c.Set("ctx", valueCtx)
c.Next()
}
}
func Info(ctx context.Context, msg string) {
now := time.Now()
nowStr := now.Format("2006-01-02 15:04:05")
fmt.Printf("%s [%s] %s\n", nowStr, ctx.Value("RequestId"), msg)
}
|
这样在一个请求中,所有的 gotroutine 都可以获取到同一个 RequestId,而且不用担心内存泄漏和并发安全.
但是使用 Context 也有个问题就是需要每次传递 Context,很多人还不习惯使用这种方式。其实 Go 官方早就推荐使用 Context了,通常会把 Context 作为函数的第一个参数。如果函数使用结构体作为参数,也可以直接把 Context 作为结构体的一个字段.
Context 除了使用可以同来传递 RequestId 之外,还可以用来控制 goroutine 的生命周期,这些内容在之前的 Context 文章中详细说明了,感兴趣的可以去看看.
获取 goroutine id 这种方式应该被抛弃,而是应该使用 Context, Go 官方也早就推荐使用这种方式,在上文中,我们使用 Context 来传递 RequestId,除此之外还可以用来传递单个请求范围的值,比如认证的 token 之类的,应该习惯在代码中使用 Context.
[1] https://blog.golang.org/context 。
到此这篇关于详解如何在Go 服务中做链路追踪的文章就介绍到这了,更多相关Go 服务中做链路追踪内容请搜索我以前的文章或继续浏览下面的相关文章希望大家以后多多支持我! 。
原文链接:https://www.jianshu.com/p/f4bac3140a76 。
最后此篇关于详解如何在Go服务中做链路追踪的文章就讲到这里了,如果你想了解更多关于详解如何在Go服务中做链路追踪的内容请搜索CFSDN的文章或继续浏览相关文章,希望大家以后支持我的博客! 。
我有一个关于 JavaScript 语法的问题。实际上,我在自学 MEAN 堆栈教程时想出了编码(https://thinkster.io/mean-stack-tutorial#adding-aut
在我的书中它使用了这样的东西: for($ARGV[0]) { Expression && do { print "..."; last; }; ... } for 循环不完整吗?另外,do 的意义何
我已经编写了读取开关状态的代码,如果按 3 次 # 则退出。 void allkeypadTest(void) { static uint8_t modeKeyCount=0; do
因此,对于上周我必须做的作业,我必须使用 4 个 do-while 循环和 if 语句在 Java 中制作一个猜谜游戏。我无法成功完成它,类(class)已经继续,没有为我提供任何帮助。如果有人可以查
int i=1,j=0,n=10,k; do{ j+=i; i<<1; printf("%d\n",i); // printf("%d\n",12<<1); }while
此代码用于基本杂货计算器的按钮。当我按下按钮时,一个输入对话框会显示您输入商品价格的位置。我遇到的问题是我无法弄清楚如何获得 do ... while 循环以使输入对话框在输入后弹出。 我希望它始终恢
当我在循环中修改字符串或另一个变量时,它的条件是否每次都重新计算?或者在循环开始前一次 std::string a("aa"); do { a = "aaaa"; } while(a.size<10)
我刚刚写了这个,但我找不到问题。我使用代码块并编写了这个问题 error: expected 'while' before '{' token === Build finished: 1 errors
do { printf("Enter number (0-6): ", ""); scanf("%d", &Num); }while(Num >= 0 && Num 表示“超过”,<表
我有一个包含 10 个项目的 vector (为简单起见,所有项目都属于同一类,称其为“a”)。我想要做的是检查“A”不是 a) 隐藏墙壁或 b) 隐藏另一个“A”。我有一个碰撞函数可以做到这一点。
嗨,这是我的第二个问题。我有下表 |-----|-------|------|------| |._id.|..INFO.|.DONE.|.LAST.| |..1..|...A...|...N..|.
这个问题在这里已经有了答案: 关闭 12 年前。 Possible Duplicates: Why are there sometimes meaningless do/while and if/e
来自 wikibook在 F# 上有一小部分它说: What does let! do?# let! runs an async object on its own thread, then it i
我在 Real World Haskell 书中遇到了以下函数: namesMatching pat | not (isPattern pat) = do exists do
我有一个类似于下面的用例,我创建了多个图并使用 gridExtra 将它们排列到一些页面布局中,最后使用 ggsave 将其保存为 PDF : p1 % mutate(label2
当我使用具有 for 循环的嵌套 let 语句时,如果没有 (do (html5 ..)),我将无法运行内部 [:tr]。 (defpartial column-settings-layout [&
执行 vagrant up 时出现此错误: anr@anr-Lenovo-G505s ~ $ vagrant up Bringing machine 'default' up with 'virtua
# ################################################# # Subroutine to add data to the table Blas
我想创建一个检查特定日期格式的读取主机。此外,目标是检查用户输入是否正确,如果不正确,则提示应再次弹出。 当我刚接触编程时,发现了这段代码,这似乎很合适。我仍然在努力“直到” do {
我关注这个tutorial在谷歌云机器学习引擎上进行培训。我一步一步地跟着它,但是在将 ml 作业提交到云时我遇到了错误。我运行了这个命令。 sam@sam-VirtualBox:~/models/r
我是一名优秀的程序员,十分优秀!