Gin中的gin.Context与Golang原生的context.Context区别与联系

一.gin中的context gin.Context

1.概念

在 Gin 中,Context 是一个非常重要的概念,它是Gin的核心结构体之一,用于处理 HTTP 请求和响应,在 Gin 的处理流程中,Context 贯穿整个处理过程,用于传递请求响应的信息Gin 的 Context 是一个结构体类型,核心定义如下:

type Context struct {// 定义了一些私有成员变量,用于存储请求和响应等信息...writermem responseWriterRequest   *http.Request  // 保存request请求Writer    ResponseWriter // 回写response Params   Paramshandlers  HandlersChain  // 该次请求所有的中间件函数和处理函数index     int8           // HandlersChain的下标,用来调用某个具体的HandlerFuncfullPath  string         // 请求的url路径engine    *Engine        // 对server Engine的引用Keys      map[string]any // 用于上下游之间传递参数params       *ParamsskippedNodes *[]skippedNode
mu sync.RWMutex// Keys is a key/value pair exclusively for the context of each request.Keys map[string]any//Errors is a list of errors attached to all the handlers/middlewares who used this             context.Errors errorMsgs// Accepted defines a list of manually accepted formats for content negotiation.Accepted []string// queryCache caches the query result from c.Request.URL.Query().queryCache url.Values// formCache caches c.Request.PostForm, which contains the parsed form data from POST, PATCH,// or PUT body parameters.formCache url.Values// SameSite allows a server to define a cookie attribute making it impossible for// the browser to send this cookie along with cross-site requests.sameSite http.SameSite...// ...
}

2.中间件 

Context 中封装了原生的 Go HTTP 请求响应对象,同时还提供了一些处理请求和生成响应的各种方法,用于获取请求和响应的信息设置响应头、设置响应状态码等操作.在Gin中,Context 是通过中间件来传递的,在处理 HTTP 请求时,Gin 会依次执行注册的中间件,每个中间件可以对 Context 进行一些操作,然后将 Context 传递给下一个中间件。

例如,下面是一个简单的中间件,用于在请求头中设置一个自定义的 X-Request-ID:

func RequestIDMiddleware() gin.HandlerFunc {return func(c *gin.Context) {requestID := generateRequestID()c.Request.Header.Set("X-Request-ID", requestID)c.Next()  // 将 Context 传递给下一个中间件}
}

在上面的中间件中,生成了一个请求 ID,然后将其设置到请求头中,接着,调用 c.Next() 方法将Context 传递给下一个中间件,这样,下一个中间件就可以通过 c.Request.Header.Get("X-Request-ID") 获取到这个请求 ID

从上面可以知道:一次请求的所有中间件函数和请求处理函数都在Context.handlers中,因此,当请求到来时,只需要依次调用Context.handlers中的所有HandlerFunc即可,这就是调用中间件中的一个最重要的函数Next(),定义如下:

func (c *Context) Next() {c.index++  // 依次遍历所有的中间件函数,并调用他们for c.index < int8(len(c.handlers)) {c.handlers[c.index](c)   c.index++}
}

除了顺序执行所有中间件,还要有在某个中间件函数中终止处理的能力,比如某个中间件负责权限校验,如果用户的校验没通过,直接返回Not Authorized,跳过后续的处理,这个是通过Abort函数实现的:

func (c *Context) Abort() {c.index = abortIndex // abortIndex是个常量=63
}

abort()的原理非常简单:

直接让c.Index等于最大值,这样剩余的中间件函数都没机会执行,从这个函数中可以看出,中间件的数量是有上限的,上限就是63个

正常的执行流是依次调用各个中间件函数,但是如果在某个中间件函数中显式调用了Next(),会先执行后续的中间件,执行完成了再返回当前中间件继续执行,流程如下:

3.参数传递 

Context中有成员Keys,上游需要传递的变量可以放在里面,下游处理时再从里面取出来,实现上下游参数传递,对应Set()Get()方法

func (c *Context) Set(key string, value any) {c.mu.Lock() // 用来保护c.Keys并发安全if c.Keys == nil {c.Keys = make(map[string]any)}c.Keys[key] = valuec.mu.Unlock()
}func (c *Context) Get(key string) (value any, exists bool) {c.mu.RLock()value, exists = c.Keys[key]c.mu.RUnlock()return
}

Get()函数还有很多衍生函数,比如GetString,GetStringMapString,GetStringMapStringSlice等,都是在Get的基础上,将数据转换成我们需要的类型再返回 

4.参数绑定

请求放到Context.Request里,需要解析成结构体或map,才好在业务代码里使用,这一部分是通过Bind()系列函数实现的,Bind()系列函数的作用就是根据request的数据类型,将其解析到结构体或map里,简单的看一个参数绑定的实现:

func (c *Context) ShouldBindWith(obj any, b binding.Binding) error {return b.Bind(c.Request, obj)  // 底层调用的是binding相关的函数
}

针对不同的请求,gin提供了很多函数,用于解析对应的参数,常用的函数如下:

Param(key string) string  // 用于获取url参数,比如/welcome/:user_id中的user_id// 获取GET请求中携带的参数
GetQueryArray(key string) ([]string, bool)  
GetQuery(key string)(string, bool)
Query(key string) string
DefaultQuery(key, defaultValue string) string// 获取POST请求参数
GetPostFormArray(key string) ([]string, bool)
PostFormArray(key string) []string 
GetPostForm(key string) (string, bool)
PostForm(key string) string
DefaultPostForm(key, defaultValue string) string// data binding 
Bind (obj interface {}) error // bind data according to Content-Type
BindJSON(obj interface{}) error
BindQuery(obj interface{}) errorShouldBind(obj interface{}) error
ShouldBindJSON(obj interface{}) error
ShouldBindQuery(obj interface{}) error
...

其中Bind相关的函数是一种比较通用的方法,它允许我们将请求参数填充到一个map或struct中,这样在后续请求处理时,能够方便的使用传入的参数。Bind相关的函数分为三大类: 

// 1. Bind函数
Bind (obj interface {}) error // 根据请求中content-type的类型来选择对应的具体Bind函数,底层调用的是BindJson, BindQuery这种具体的Bind函数// 2. BindXXX(),具体的Bind函数,用于绑定一种参数类型,底层调用MustBindWith或者ShouldBindWith
BindJSON(obj interface{}) error
BindQuery(obj interface{}) error// 3. 最底层的基础函数
MustBindWith(obj any, b binding.Binding) error // 当出现参数校验问题时,会直接返回400,底层仍然是ShouldBindWith
ShouldBindWith(obj any, b binding.Binding) error

其中各种类型的Bind函数,最底层的调用都是ShouldBindWith()函数,该函数有两个参数,第一个参数obj为需要将参数填充进去的对象(本文称为填充对象);第二个参数为binding.Binding类型,该类型的定义在package binding中,如下:

type Binding interface {Name() stringBind(*http.Request, any) error
}

Bingding为一个接口,提供了Name()和Bind()两个函数,Name()负责返回对应的Bind类型,比如JSON,XML等,Bind()函数则负责实现具体类型的参数绑定。为了完成常用参数类型的绑定,gin给每种参数类型都定义了一个类,并实现Binding接口,具体实现了Binding接口的类如下: 

 

// 实现Binding接口的具体类
var (JSON          = jsonBinding{}XML           = xmlBinding{}Form          = formBinding{}Query         = queryBinding{}FormPost      = formPostBinding{}FormMultipart = formMultipartBinding{}ProtoBuf      = protobufBinding{}MsgPack       = msgpackBinding{}YAML          = yamlBinding{}Uri           = uriBinding{}Header        = headerBinding{}TOML          = tomlBinding{}
)

这样,每当一个HTTP请求到来的时候,用户可以直接调用Bind()函数,Bind()函数可以通过content-type选择对应的实现了Bind()方法的对应类的实例,调用其Bind()方法,完成参数绑定.

常用的HTTP请求参数类型HTTP GET query参数类型HTTP POST json参数类型,以这两个为例,看一下参数绑定的一些细节:

 BindJSON:

jsonBinding对Binding的实现如下:

       json的参数绑定比较简单,使用json.Decoder完成

func (jsonBinding) Name() string {return "json"
}func (jsonBinding) Bind(req *http.Request, obj any) error {if req == nil || req.Body == nil {return errors.New("invalid request")}return decodeJSON(req.Body, obj)
}func decodeJSON(r io.Reader, obj any) error {decoder := json.NewDecoder(r) // 使用json.Decoder对json进行解析if EnableDecoderUseNumber {decoder.UseNumber()}if EnableDecoderDisallowUnknownFields {decoder.DisallowUnknownFields()}if err := decoder.Decode(obj); err != nil {return err}return validate(obj) // 参数校验
}

BindQuery:

一个HTTP GET请求的query参数,在go中,可以通过request.URL.Query()获取到,获取到的query参数类型为url.Values,因此,BindQuery()首先获取到url.Values类型的query参数,然后设置对应的值,BindQuery()根据传进来的要将参数填充进去的对象类型(本文称为填充对象,是map类型还是struct ptr),分成了两个填充函数:

/* mapFormByTag是queryBinding.Bind()的底层核心函数
* ptr: 填充对象,可能是map或strcut的指针
* form: url.Values,包含所有query参数
* tag: 值为"form"
*/
func mapFormByTag(ptr any, form map[string][]string, tag string) error {// Check if ptr is a mapptrVal := reflect.ValueOf(ptr)var pointed anyif ptrVal.Kind() == reflect.Ptr {ptrVal = ptrVal.Elem()pointed = ptrVal.Interface()}if ptrVal.Kind() == reflect.Map &&ptrVal.Type().Key().Kind() == reflect.String {if pointed != nil {ptr = pointed}return setFormMap(ptr, form) // 如果填充对象是map类型}return mappingByPtr(ptr, formSource(form), tag) // 填充对象是ptr struct类型
}

接下来分别看一下两个核心的填充函数setFormMap()和mappingByPtr() 

// setFormMap本身比较简单,因为query参数(url.Values是map[string][]string类型的别称)本身就是map[string][]string类型,只需要判断填充对象是map[string]string还是map[string][]string类型
func setFormMap(ptr any, form map[string][]string) error {el := reflect.TypeOf(ptr).Elem() // 因为ptr本身是map类型,Elem返回该map的value值// 如果map填充对象的value值为[]string类型,直接填充if el.Kind() == reflect.Slice {ptrMap, ok := ptr.(map[string][]string)if !ok {return ErrConvertMapStringSlice}for k, v := range form {ptrMap[k] = v}return nil}// 否则,map填充对象为map[string]string类型,取url.Values每个key对应的value值(类型为[]string)的最后一个元素填充到填充对象中ptrMap, ok := ptr.(map[string]string)if !ok {return ErrConvertToMapString}for k, v := range form {ptrMap[k] = v[len(v)-1] // pick last}return nil
}

mappingByPtr()的逻辑比较复杂,核心是遍历struct的每一个字段,获取该struct字段的json tag,如果tag的值跟某一个url.Values的key的值相等,填充对应的值 

func mappingByPtr(ptr any, setter setter, tag string) error {_, err := mapping(reflect.ValueOf(ptr), emptyField, setter, tag)return err
}/* mapping是一个递归函数,因为struct填充对象有可能嵌套了ptr成员
* value:填充对象
* field:struct填充对象的某个具体成员变量
* setter:内部包含了url.Values
* tag: 等于"form"
*/
func mapping(value reflect.Value, field reflect.StructField, setter setter, tag string) (bool, error) {if field.Tag.Get(tag) == "-" { // just ignoring this fieldreturn false, nil}vKind := value.Kind()// 如果填充对象是ptr,获取其指向的对象递归调用mappingif vKind == reflect.Ptr {var isNew boolvPtr := valueif value.IsNil() {isNew = truevPtr = reflect.New(value.Type().Elem())}isSet, err := mapping(vPtr.Elem(), field, setter, tag) if err != nil {return false, err}if isNew && isSet {value.Set(vPtr)}return isSet, nil}// 递归到最底层,每个value都是StructField类型,开始填充值if vKind != reflect.Struct || !field.Anonymous {ok, err := tryToSetValue(value, field, setter, tag)if err != nil {return false, err}if ok {return true, nil}}// 如果填充对象是struct,针对每一个struct field,递归调用mappingif vKind == reflect.Struct {tValue := value.Type()var isSet boolfor i := 0; i < value.NumField(); i++ {sf := tValue.Field(i)if sf.PkgPath != "" && !sf.Anonymous { // unexportedcontinue}ok, err := mapping(value.Field(i), sf, setter, tag)if err != nil {return false, err}isSet = isSet || ok}return isSet, nil}return false, nil
}

总结: Gin通过区分不同的参数类型,每种参数类型实现了统一的Bind()函数来完成对应的参数绑定,用户只需要调用统一的函数,不用关系底层实现细节,即可完成参数绑定 

从上面介绍可以知道:

        在 Gin 中,Context 是通过中间件来传递的,每个中间件都可以对 Context 进行一些操作,然后将其传递给下一个中间件,最终由处理函数来使用Context中的信息进行处理

 二.gin.Context和context.Context的区别

Gin 的 gin.Context 和 Go标准库中的 context.Context 是两个不同的概念,用途也不同

  • gin.Context:是 Gin 框架中的一个结构体类型,用于封装 HTTP 请求和响应的信息,以及提供一些方法,用于获取请求和响应的信息、设置响应头、设置响应状态码等操作,gin.Context 只在 Gin 框架内部使用,用于处理 HTTP 请求和响应,它与 HTTP 请求和响应一一对应,每个 HTTP 请求都会创建一个新的 gin.Context 对象,并在处理过程中传递
  • context.Context:是 Go 标准库中的一个接口类型,用于在 Goroutine 之间传递上下文信息,context.Context 可以在 Goroutine 之间传递信息,例如传递请求 ID、数据库连接、请求超时等信息,context.Context 的具体实现是由各种库框架提供的,例如 Gin 框架中也提供了一个 gin.Context 的实现,用于在 Gin 框架中使用 context.Context

总之,gin.Context是Gin框架中用于处理HTTP请求和响应的上下文对象,而context.Context是Go标准库中用于在Goroutine之间传递上下文信息的接口类型,在使用 Gin 框架时,可以通过 gin.Context的Request.Context()方法来访问 context.Context对象,从而在 Gin 框架中使用上下文信息

例如,可以在中间件中设置一个请求 ID,并将其保存在 context.Context 中,然后在处理函数中获取这个请求 ID,下面是一个示例:

 

func RequestIDMiddleware() gin.HandlerFunc {return func(c *gin.Context) {requestID := generateRequestID()ctx := context.WithValue(c.Request.Context(), "requestID", requestID)c.Request = c.Request.WithContext(ctx)c.Next()}
}func HelloHandler(c *gin.Context) {requestID := c.Request.Context().Value("requestID").(string)c.String(http.StatusOK, "Hello, request ID = %s", requestID)
}

在上面的示例中,中间件 RequestIDMiddleware会生成一个请求ID,并将其保存在context.Context中,然后,将这个 context.Context 对象保存到 http.Request 中,在处理函数 HelloHandler 中,可以通过 c.Request.Context().Value("requestID") 来获取这个请求 ID

总之,在 Gin 中,可以通过 gin.Context 来访问 context.Context,从而在 Gin 框架中传递上下文信息,开发者可以在中间件中设置 context.Context,然后在处理函数中获取这个上下文信息

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

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

相关文章

如何查询电脑是否被锁定了IP地址?锁定IP会出现什么问题?

前言 电脑刚到手的时候&#xff0c;基本上是通过路由器DHCP进行IP分配的。路由器DHCP分配IP给电脑的好处是网络不会出现IP冲突&#xff0c;网络能正常使用。 有些电脑可能在DHCP自动获取IP时出现错误&#xff0c;所以小伙伴就会通过手动设置IP让电脑可以正常上网。 这样的操…

【真题解析】题目 3151: 蓝桥杯2023年第十四届省赛真题-飞机降落【C++ DFS 超详解注释版本】

爆搜冥想 暴力枚举每一辆飞机对于每一个飞机都只存在两种情况&#xff0c;可以降落和不可以降落如果可以降落&#xff0c;计算降落后最早可以降落的时间pre&#xff0c;作为下一次递归的传参如果不可以降落&#xff0c;枚举下一辆飞机 注意这辆的降落有盘旋这种量子叠加态&…

【前端面试3+1】02插槽、箭头函数与普通函数、重绘重排、【回文数】

一、对插槽的理解 1.定义及作用&#xff1a; 插槽是一种用于在组件中插入内容的特殊语法。它的作用是让父组件可以向子组件传递内容&#xff0c;从而实现组件的灵活性和复用性。 2.分类&#xff1a; 插槽可以分为具名插槽和作用域插槽。 2.1具名插槽&#xff1a; 具名插槽允许父…

苹果macOS 14.4.1正式发布:修复无法使用外接显示器USB集线器问题

3 月 26 日消息&#xff0c;苹果今日向 Mac 电脑用户推送了 macOS 14.4.1 更新&#xff08;内部版本号&#xff1a;23E224&#xff09;&#xff0c;本次更新距离上次发布隔了 18 天。 需要注意的是&#xff0c;因苹果各区域节点服务器配置缓存问题&#xff0c;可能有些地方探测…

怎么在vscode里面保存图片视频音频文件(只需要两步)?

在硬盘中建立一个新的文件夹(自定义命名~我的这里是html→jpg) 第一步建立文件夹 第二步右键打开然后选择其他方式打开&#xff0c;选择code打开就会自己复制过去了

Memcached分布式内存对象数据库

一 Memcached 概念 Memcached 是一个高性能的分布式内存对象缓存系统&#xff0c;用于动态 Web 应用以减轻数据库负载。它通过在内存中缓存数据和对象来减少读取数据库的次数&#xff0c;从而提高动态、数据库驱动网站的速度。 二 在架构中的位置 Memcached 处于前端或中间件后…

Gitea CORS Access-Control-Allow-Origin 的问题

最近我们在想使用我们提供的代码库进行元数据提供的时候&#xff0c;启动的服务报 CORS 问题。 如果你的 Gitea 服务器是直接暴露给外部使用的话&#xff0c;可以在 Gitea 的配置文件中添加下面的配置&#xff1a; [cors] ENABLED true ALLOW_DOMAIN *在完成上面的…

基于nodejs+vue网购平台管理系统python-flask-django-php

本篇论文对网购平台管理系统的需求分析、功能设计、系统设计进行了较为详尽的阐述&#xff0c;并对系统的整体设计进行了阐述&#xff0c;并对各功能的实现和主要功能进行了说明&#xff0c;并附上了相应的操作界面图。 前端技术&#xff1a;nodejsvueelementui, Express 框架…

Qt 作业 24/3/26

1、实现闹钟 #ifndef WIDGET_H #define WIDGET_H#include <QWidget> #include <QTime> #include <QLineEdit>QT_BEGIN_NAMESPACE namespace Ui { class Widget; } QT_END_NAMESPACEclass Widget : public QWidget {Q_OBJECTpublic:Widget(QWidget *parent …

Generating Permutations全排列

Problem generating all permutations of the numbers 1, 2, . . . , n. The first algorithm Idea 1[all the permutations of the numbers 2,3,…,n]&#xff0c; 2[all the permutations of the numbers 1,3,…,n]&#xff0c; ……&#xff0c; n[all the permutations of …

【Mybatis 基础】增删改查(@Insert, @Delete, @Update, @Select)

Mybatis Insert Delete Update Select Mybatis用法基础操作 - 删除delete 传参SpringbootMybatisCrudApplicationTests 测试类删除预编译SQL 基础操作 - 插入Insert 插入SpringbootMybatisCrudApplicationTests 测试类插入对象主键返回 基础操作 - 更新UPDATE 更新SpringbootMy…

k8s系列之十七 Istio中的服务治理

删除前面配置的目的地规则 [rootk8s-master ~]# kubectl delete destinationrule details destinationrule.networking.istio.io "details" deleted [rootk8s-master ~]# kubectl delete destinationrule productpage destinationrule.networking.istio.io "pr…

pdfjs 实现给定pdf数据切片高亮并且跳转

pdfjs 实现给定pdf数据切片高亮并且跳转 pdfjs 类的改写基本展示需求的实现高亮功能的实现查询功能分析切片数据处理 pdfjs 类的改写 需求&#xff1a; pdf文件被解析成多个分段&#xff0c;每个分段需要能够展示&#xff0c;并且通过点击分段实现源pdf内容的高亮以及跳转需求…

视频声音生成字幕 pr生成视频字幕 以及字幕乱码的解决

目录 目录 1、首先把要生成字幕的视频拖入以创建序列 2、点击工具栏的 窗口 选择 文本 3、选择字幕下的 转录序列 4、选择输出的语言&#xff08;主要看视频声音说的是啥语言&#xff09; 5、音轨 选择 音频1​编辑 6、点击转录 7、等待转录文本 8、点击创建说明性字幕按…

论文阅读笔记——Rethinking Pointer Reasoning in Symbolic Execution

文章目录 前言Rethinking Pointer Reasoning in Symbolic Execution12.1、基本情况概述12.2、摘要12.3、引言12.4、方法12.4.1、基本版本12.4.1.1、内存加载和存储12.4.1.2、状态合并 12.4.2、改进12.4.2.1、地址范围选择12.4.2.2、内存清理12.4.2.3、符号化的未初始化内存12.4…

卷起来——高级数据分析师

要成为一名高级数据分析师&#xff0c;需要掌握一系列的技能&#xff0c;包括数据处理、统计分析、机器学习、数据可视化以及业务理解等&#xff0c;喜欢或者想往这方面发展的童鞋们&#xff0c;卷起来&#xff0c;点击以下链接中的链接&#xff0c;备注"分析"进群交…

Clip Converter - 视频在线下载方法

Clip Converter - 视频在线下载方法 1. Video URL to Download2. Continue3. StartReferences YT to MP4 & MP3 Converter! https://www.clipconverter.cc/ Clip Converter is a free online media conversion application, which allows you to reocord, convert and do…

YOLOv8改进 | 主干篇 | 修复官方去除掉PP-HGNetV2的通道缩放功能(轻量又涨点,全网独家整理)

一、本文介绍 本文给大家带来的改进机制是大家在跑RT-DETR提供的HGNetV2时的一个通道缩放功能&#xff08;官方在前几个版本去除掉的一个功能&#xff09;&#xff0c;其中HGNetV2当我们将其集成在YOLOv8n的模型上作为特征提取主干的时候参数量仅为230W 计算量为6.7GFLOPs该网…

无人直播(视频推流)

环境搭建 我这里采用的是ffmpeg来进行推流直播 yum -y install wgetwget --no-check-certificate https://www.johnvansickle.com/ffmpeg/old-releases/ffmpeg-4.0.3-64bit-static.tar.xztar -xJf ffmpeg-4.0.3-64bit-static.tar.xzcd ffmpeg-4.0.3-64bit-staticmv ffmpeg /u…

kubernetes-networkpolicies网络策略问题

kubernetes-networkpolicies网络策略问题 问题描述 重点重点重点&#xff0c;查看我的博客CKA考题&#xff0c;里面能找到解决方法 1.部署prometheus监控的时候&#xff0c;都部署成功&#xff0c;但是web访问503-504超时 2.添加ingress的时候也是访问不到&#xff0c;其他命…