context 浅析

news2025/1/21 18:49:31

在缺少直接调用关系的两个函数之间传递数据,一般都会考虑使用 context,而 context 也被用来存储整个请求链路的公参信息,用户 uid、链路 traceID、特定的业务参数等。函数第一个参数类型设置为 context.Context 也是 Go 的默认写法,如果你对是否指定 ctx 作为函数的第一个入参,感觉到模棱两可,那就指定它吧。

树状链路结构

context 的惯用模式是覆写,比如下面的 Printable 函数,参数 ctx 在函数内部被覆写了。而这个操作在当前的 context 链路上又追加上了一个节点,其实也是将 context 切换到一个新的 context 上。通过这种模式,每个方法都有了自己独立的 context 变量,并且可以查找到到上级的 context,整个调用链路都可以通过 context 来还原。

func Printable(ctx context.Context) {
	ctx = context.WithValue(ctx, "key", "value")
	// ......
}

下面这个绿色的 ctx,通过它可以获取到红色的父 ctx 和蓝色的子 ctx。创建子 ctx 的方式就是官方提供的 ctx 覆写的方式。树结构的每一条链路都是链表结构,每个 context 内部记录了指向父节点的指针。函数 WithValue 的注释有这样一段描述:WithValue returns a copy of parent in which the value associated with key is val. 但 WithValue 传递的参数类型实际是指针,这里应该只是想强调指针引用的拷贝。
在这里插入图片描述
除了通过当前节点找到父节点,还需要能查找到当前节点的所有子节点。但通过 WithValue 创建的节点并没有保存子节点的信息,也就无法查找到子节点列表,WithValue 被设计用来存储当前链路的值,查找某个具体的 key 值时,需要逐层向父节点查找,当前节点此时此刻也不包含任何子节点。

下图最左边的蓝色 ctx 查找某个 key 值时,会逐步向上查找。假如红色和绿色的 ctx 设置了相同的 key 值,会返回绿色 ctx 的 value,因为这种链路的层次关系,红色的 key 值会被覆盖掉。通过这样的设计,ctx 中的变量具有了作用域范围,红色 ctx 不能访问绿色 ctx 中的值,绿色 ctx 可以“覆盖”红色 ctx 的值。
在这里插入图片描述

孩子节点

WithValue 创建的 ctx 中没有维护孩子节点的信息,所以,接下来我们使用 WithCancel 对树形链路做分析。 cancelCtx 结构体的 children 存储了孩子节点的信息。children 是 map 类型,对应的 value 是空的结构体类型,而空的结构体不占用任何内存空间,所以 key 是关键,key 是 canceler 接口类型。

children 不支持并发读写,err 也需要并发保护,cancelCtx 通过 sync.Mutex 来控制并发。atomic.Value 本身就只原子类型,理论上是不需要加锁保护的。

// A cancelCtx can be canceled. When canceled, it also cancels any children
// that implement canceler.
type cancelCtx struct {
	Context

	mu       sync.Mutex            // protects following fields
	done     atomic.Value          // of chan struct{}, created lazily, closed by first cancel call
	children map[canceler]struct{} // set to nil by the first cancel call
	err      error                 // set to non-nil by the first cancel call
}

WithCancel 在新建节点的时候,首先要查找到对应的父节点,然后注册到父节点的 children 中,这样就建立了父子节点的对应关系。关键是查找到对应的父节点,因为父节点可能不是 WithCancel 函数传入的 ctx,而是“血型”匹配的父节点,下图蓝色的 cancelCtx 就找不到对应的父节点。

withCancel.1
再比如下图的右子树,两个浅黄色的 cancelCtx 并不存在父子关系,因为中间被 valueCtx 给隔开了。所以,关键点是判断 WithCancel 调用时的 parent 的参数类型。两个 cancelCtx 节点能否建立父子关系,首先需要类型匹配,其次需要父节点是有效的。

我们可以理解为 cancelCtx 其实是局部树,它在整个 context 树状结构中是独立的一颗颗小子树。这样的设计方式,应该和 cancelCtx 的要处理的场景有关系,毕竟 cancelCtx 是被用来处理小范围内的调用取消控制的。
在这里插入图片描述

WithValue 参考扩展

前文已经介绍过,WithValue 创建的节点并不会保存子节点的信息。但我们可以做扩展,让 WithValue 支持保存父子节点的关系。有了这层关系,我们可以将整个服务的调用链通过 ctx 关联起来,可视化地将树形结构显示出来。竖向表示串联逻辑,横向表示包含逻辑,下图中的“历史记录”和“同地域”表示并行逻辑。

在这里插入图片描述
微服务通过在入口生成统一的 traceID 来关联所有的服务,通过 traceID 来排查链路调用的问题。但通过 traceID 查询到的一条条日志缺少业务逻辑聚合关系,表面上是按服务维度进行划分的,但粒度太大了。

我们可以利用 context 实现业务逻辑层面的粒度划分,比如将整个业务域划分成召回、过滤、排序三个大逻辑,每个逻辑内部再继续划分成多个小逻辑,整个链路共用同一个 traceID,但每个业务域内生成特有的 ID 来标志对应的业务域。最终,通过业务逻辑的调用图将日志信息可视化展示出来。

我们参考 WithValue 的实现,当进入到召回逻辑时,我们启用一个业务域,在 ctx 中设置当前的业务域为“召回”,当进入到“过滤逻辑时”,我们将当前的业务域设置为“过滤”,以此类推,我们将整个链路通过树的结构连接起来。这样,一个可视化的日志排查链路就设计好了。

树形结构的表示

在 api 的交互中,要表示一个树形结构,数据结构该如何组织呢?

业务执行流程都是串行向下的,但可能存在某一阶段多路并行的情况。比如下图中黄色的圈,表示异步执行多路逻辑。按照 context 的组织思路,context 是一个树状的组织结构,子节点仅能唯一确认一个父节点,不能对应多个父节点。所以,图中红色的节点就比较尴尬,但又实际存在。

在这里插入图片描述

我们先确认最终的数据结构,基于这个数据结构,就可以简单连线构造出上面的图形。而且,根据现在的结果去推导实现的过程,思路就会开阔起来。让我想到一个Question:如何提出一个好的问题。

type node struct {
	*M
	children []*T
}

上面是伪代码的描述,node 表示图中的一个节点,*M表示节点的属性,其中 children 用来表示节点有哪些子节点。最后,我们将所有的节点和子节点连接起来,就可以构成上面的图形。

回到图示,context 结构中,蓝色的子节点包含黄色,以及红色(右图),只是我们用上图的形式做了展示(左图)。黄色的连线逻辑就变成:有父节点,没有子节点,且父节点还指向了下一个流程的红色节点。

本文来自互联网用户投稿,该文观点仅代表作者本人,不代表本站立场。本站仅提供信息存储空间服务,不拥有所有权,不承担相关法律责任。如若转载,请注明出处:http://www.coloradmin.cn/o/434347.html

如若内容造成侵权/违法违规/事实不符,请联系多彩编程网进行投诉反馈,一经查实,立即删除!

相关文章

2 常见模块库(3)

2.9 积分模块(2) External reset: 在什么条件下进行外部重置操作描述一下每个选项: Rising:当重置信号从非正的值(0或负值)变为正值时,重置积分器的状态。 Falling:当重置信号从正…

Java每日一练(20230419)

目录 1. 二叉树的最大深度 🌟 2. 二叉树的层序遍历 🌟🌟 3. 最短回文串 🌟🌟🌟 🌟 每日一练刷题专栏 🌟 Golang每日一练 专栏 Python每日一练 专栏 C/C每日一练 专栏 Jav…

双向带头循环链表的实现

双向带头循环链表 双向带头循环链表结构讲解期望实现功能创建链表和头节点作用头插和头删头插头删 尾插与尾删尾插尾删 pos 删除和插入插入删除 打印和查找 整体代码 这个数据结构可以算是YYDS的存在了。 我们前面讲过的单链表,尾删和尾插需要遍历数组,极…

是时候该换掉你的axios了

axios是一个基于Promise的HTTP客户端,每周的npm下载量4000W,如果回到在10年前,promise式的请求工具是一个很大的创新,它解决了请求繁琐的问题,在那个性能要求不那么高的年代可谓是一骑绝尘。但随着时间的推移&#xff…

【网络】UDP协议 TCP协议

🥁作者: 华丞臧. 📕​​​​专栏:【网络】 各位读者老爷如果觉得博主写的不错,请诸位多多支持(点赞收藏关注)。如果有错误的地方,欢迎在评论区指出。 推荐一款刷题网站 👉 LeetCode刷题网站 文章…

Centos7安装Elasticsearch6.4.3和Kibana6.4.3

一、下载好安装文件上传到/usr/local 二、安装Java环境 1)、解压jdk tar -zxvf jdk-8u181-linux-x64.tar.gz2)、 配置Java环境变量 vim /etc/profile 3)、profile末尾添加 export JAVA_HOME/usr/local/jdk1.8.0_181 export PATH$JAVA_HO…

【2023 · CANN训练营第一季】昇腾AI入门课(Pytorch)---昇腾AI入门课(PyTorch)微认证考试

1、下列不属于昇腾计算服务层的是() 2、AscendCL的优势包括() 3、使用AscendCL开发应用的基本流程,以下正确的是? 4、关于AscendCL初始化,以下说法不正确的是? 5、以下关于ATC工具说法正确的是 6、模型转换工具的名称是&#xf…

深入实战探究 Vue 2.7 Composition API 的强大之处

最近几年公司开发一直使用的是 Vue2.6,对于逻辑复用使用的是 Mixin 方式,但随着项目体量的增加,带了一些问题,特别是:数据混乱问题:实例上的数据属性从当前模板文件中无法查取到,存在多个 Mixin…

API 鉴权都有哪些分类,这些重点不要错过

API鉴权是保证API安全性和可用性的一项重要措施。通过API鉴权,系统可以对用户或者应用进行有效的身份认证和权限管理。一般来说,在实际开发中,我们使用以下几种API鉴权方式: 1. 基本认证 基本认证是API鉴权的一种最基本形式。此方…

如何创建Spring项目

创建Spring项目 创建一个Maven项目 这里使用的是2023版本的idea。 添加Spring框架支持 在项目的pom.xml中添加Spring支持。这里可以到中央仓库找一下。 <dependencies><!-- https://mvnrepository.com/artifact/org.springframework/spring-context --><dep…

Android Binder 图文解释和驱动源码分析

前言 最近在学习Binder&#xff0c;之前都是跳过相关细节&#xff0c;通过阅读文章对Binder有了一些认识&#xff0c;但是并没有真正理解Binder。如果要深入理解Framework的代码&#xff0c;就必须要真正理解Binder。 我学习Binder的方法&#xff1a; 一边阅读Gityuan的Bind…

视觉语言模型究竟能帮助我们完成哪些工作?

当前&#xff0c;多模式人工智能已经成为一个街谈巷议的热门话题。随着GPT-4的最近发布&#xff0c;我们看到了无数可能出现的新应用和未来技术&#xff0c;而这在六个月前是不可想象的。事实上&#xff0c;视觉语言模型对许多不同的任务都普遍有用。例如&#xff0c;您可以使用…

vmware VM虚拟机去虚拟化教程 硬件虚拟机 过鲁大师检测

一 准备工作 1. 这里演示的VM虚拟机版本是12.5.9 虚拟机系统是win7 64位 2. 用到的工具 winhex和Phoenix BIOS Editor 下载地址工具 链接&#xff1a;https://pan.baidu.com/s/1b3FfA3FyQ_lnFQSjpCGLGg?pwd1221 提取码&#xff1a;1221 3. 注意&#…

【2023 · CANN训练营第一季】昇腾AI入门课(Pytorch)---昇腾AI入门课(上)

AscendCL快速入门 AscendCL概述 AscendCL功能介绍 AscendCL基础概念解析 应用开发流程 样例代码精讲

Vivado综合参数设置

如果你正在使用Vivado开发套件进行设计&#xff0c;你会发现综合设置中提供了许多综合选项。这些选项对综合结果有着潜在的影响&#xff0c;而且能够提升设计效率。为了更好地利用这些资源&#xff0c;需要仔细研究每一个选项的功能。本文将要介绍一下Vivado的综合参数设置。 …

SpringBoot解决用户重复提交订单(方式一:通过唯一索引实现)

文章目录 前言1、方案实现1.1、给数据库表增加唯一键约束1.2、编写获取请求唯一ID的接口1.3、业务提交的时候&#xff0c;检查唯一ID 2、小结 前言 对于投入运营的软件系统&#xff08;商城、物流、工厂等&#xff09;&#xff0c;最近小编在巡检项目数据库的时候&#xff0c;发…

【场景生成与削减】基于蒙特卡洛法场景生成及启发式同步回带削减风电、光伏、负荷研究(Matlab代码实现)

&#x1f4a5;&#x1f4a5;&#x1f49e;&#x1f49e;欢迎来到本博客❤️❤️&#x1f4a5;&#x1f4a5; &#x1f3c6;博主优势&#xff1a;&#x1f31e;&#x1f31e;&#x1f31e;博客内容尽量做到思维缜密&#xff0c;逻辑清晰&#xff0c;为了方便读者。 ⛳️座右铭&a…

学习笔记 -- C++性能评估工具Perf

Installation sudo apt update sudo apt install linux-tools-common查看你的内核&#xff1a; uname -r我的输出&#xff1a; $ uname -r 5.15.0-67-generic安装对应的 tools&#xff1a; sudo apt install linux-tools-5.15.0-67-genericImplementation 1、Perf List 状…

PyTorch 人工智能研讨会:1~5

原文&#xff1a;The Deep Learning with PyTorch Workshop 协议&#xff1a;CC BY-NC-SA 4.0 译者&#xff1a;飞龙 本文来自【ApacheCN 深度学习 译文集】&#xff0c;采用译后编辑&#xff08;MTPE&#xff09;流程来尽可能提升效率。 不要担心自己的形象&#xff0c;只关心…

vmware 打开报错

Error: VMware Workstation failed? I downloaded ccleaner to free up my ram and to get rid of some junk files. I ran ccleaner, tried to start my vmware and I got the error message “VMware Workstation failed to start the VMware Authorization Service. You ca…