context使用不当引发的一个bug

痛定思痛。 2022-11-12 05:27 226阅读 0赞

## 背景 ##

> 哈喽，everybody，小松子，再次回归，最近工作比较忙，好久都没有更新文章了，接下来会进行补更。今天与大家分享一个日常开发比较容易错误的点，那就是`contxt`误用导致的`bug`，我自己就因为误用导致异步更新缓存都失败了，究竟是因为什么呢？看这样一个例子，光看代码，你能看出来有什么`bug`吗？

func AsyncAdd(run func() error)  {
     //TODO: 扔进异步协程池
     go run()
    }
    
    func GetInstance(ctx context.Context,id uint64) (string, error) {
     data,err := GetFromRedis(ctx,id)
     if err != nil && err != redis.Nil{
      return "", err
     }
     // 没有找到数据
     if err == redis.Nil {
      data,err = GetFromDB(ctx,id)
      if err != nil{
       return "", err
      }
      AsyncAdd(func() error{
       return UpdateCache(ctx,id,data)
      })
     }
     return data,nil
    }
    
    func GetFromRedis(ctx context.Context,id uint64) (string,error) {
     // TODO: 从redis获取信息
     return "",nil
    }
    
    func GetFromDB(ctx context.Context,id uint64) (string,error) {
     // TODO: 从DB中获取信息
     return "",nil
    }
    
    func UpdateCache(ctx context.Context,id interface{},data string) error {
     // TODO：更新缓存信息
     return nil
    }
    
    func main()  {
     ctx,cancel := context.WithTimeout(context.Background(), 3 * time.Second)
     defer cancel()
     _,err := GetInstance(ctx,2021)
     if err != nil{
      return
     }
    }

## 分析 ##

我们先简单分析一下，这一段代码要干什么？其实很简单，我们想要获取一段信息，首先会从缓存中获取，如果缓存中获取不到，我们就从`DB`中获取，从DB中获取到信息后，在协程池中放入更新缓存的方法，异步去更新缓存。整个设计是不是很完美，但是在实际工作中，异步更新缓存就没有成功过？

导致失败的原因就在这一段代码：

AsyncAdd(func() error{
       return UpdateCache(ctx,id,data)
      })

错误的原因只有一个，就是这个`ctx`，如果改成这样，就啥事没有了。

AsyncAdd(func() error{
       ctxAsync,cancel := context.WithTimeout(context.Background(),3 * time.Second)
       defer cancel()
       return UpdateCache(ctxAsync,id,data)
      })

看到这个，想必大家就已经知道为什么吧？

在这个`ctx`树中，根结点发生了`cancel()`，会将信号即时同步给下层，因为异步任务的`ctx`也在这棵树的节点上，所以当`main goroutine`取消了`ctx`时，异步任务也被取消了，导致了缓存更新一直失败。

![0a6b45d480c2853593bcea2ea6c3c55c.png][]

因为我之前写过一篇关于[详解Context包，看这一篇就够了！！！][Context]的文章，就不在这里细说其原理了，想知道其内部是怎么实现的，看以前[这篇][Context]文章就可以了。在这里在与大家分享一下`context`的使用原则，避免踩坑。

*  context.Background 只应用在最高等级，作为所有派生 context 的根。
 *  context 取消是建议性的，这些函数可能需要一些时间来清理和退出。
 *  不要把`Context`放在结构体中，要以参数的方式传递。
 *  以`Context`作为参数的函数方法，应该把`Context`作为第一个参数，放在第一位。
 *  给一个函数方法传递Context的时候，不要传递nil，如果不知道传递什么，就使用context.TODO
 *  Context的Value相关方法应该传递必须的数据，不要什么数据都使用这个传递。context.Value 应该很少使用，它不应该被用来传递可选参数。这使得 API 隐式的并且可以引起错误。取而代之的是，这些值应该作为参数传递。
 *  Context是线程安全的，可以放心的在多个goroutine中传递。同一个Context可以传给使用其的多个goroutine，且Context可被多个goroutine同时安全访问。
 *  Context 结构没有取消方法，因为只有派生 context 的函数才应该取消 context。

Go 语言中的 `context.Context` 的主要作用还是在多个 Goroutine 组成的树中同步取消信号以减少对资源的消耗和占用，虽然它也有传值的功能，但是这个功能我们还是很少用到。在真正使用传值的功能时我们也应该非常谨慎，使用 `context.Context` 进行传递参数请求的所有参数一种非常差的设计，比较常见的使用场景是传递请求对应用户的认证令牌以及用于进行分布式追踪的请求 ID。

## 总结 ##

写这篇文章的目的，就是把我日常写的`bug`分享出来，防止后人踩坑。已经踩过的坑就不要再踩了，把找`bug`的时间节省出来，多学点其他知识，他不香嘛～。

**好啦，这篇文章就到这里啦，素质三连（分享、点赞、在看）都是笔者持续创作更多优质内容的动力！**

**创建了一个Golang学习交流群，欢迎各位大佬们踊跃入群，我们一起学习交流。入群方式：加我vx拉你入群，或者公众号获取入群二维码**

**结尾给大家发一个小福利吧，最近我在看\[微服务架构设计模式\]这一本书，讲的很好，自己也收集了一本PDF，有需要的小伙可以到自行下载。获取方式：关注公众号：\[Golang梦工厂\]，后台回复：\[微服务\]，即可获取。**

**我翻译了一份GIN中文文档，会定期进行维护，有需要的小伙伴后台回复\[gin\]即可下载。**

**翻译了一份Machinery中文文档，会定期进行维护，有需要的小伙伴们后台回复\[machinery\]即可获取。**

**我是asong，一名普普通通的程序猿，让我们一起慢慢变强吧。欢迎各位的关注，我们下期见~~~**

![8dcff0cce0385a262bcb394d005faa30.png][]

推荐往期文章：

*  [Go看源码必会知识之unsafe包][Go_unsafe]
 *  [源码剖析panic与recover，看不懂你打我好了！][panic_recover]
 *  [详解并发编程基础之原子操作(atomic包)][atomic]
 *  [详解defer实现机制][defer]
 *  [空结构体引发的大型打脸现场][Link 1]
 *  [Leaf—Segment分布式ID生成系统（Golang实现版本）][Leaf_Segment_ID_Golang]
 *  [十张动图带你搞懂排序算法(附go实现代码)][go]
 *  [go参数传递类型][go 1]
 *  [手把手教姐姐写消息队列][Link 2]
 *  [常见面试题之缓存雪崩、缓存穿透、缓存击穿][Link 3]
 *  [详解Context包，看这一篇就够了！！！][Context]
 *  [高并发系统的限流策略：漏桶和令牌桶(附源码剖析)][Link 4]
 *  [面试官：go中for-range使用过吗？这几个问题你能解释一下原因吗][go_for-range]

[0a6b45d480c2853593bcea2ea6c3c55c.png]: /images/20221022/526d503a31534f1c9a4006176ccc02fe.png
[Context]: https://mp.weixin.qq.com/s?__biz=MzIzMDU0MTA3Nw%3D%3D&idx=1&mid=2247483915&scene=21&sn=d2df74f983fcaedc50db1962d4d3e873#wechat_redirect
[8dcff0cce0385a262bcb394d005faa30.png]: https://img-blog.csdnimg.cn/img_convert/8dcff0cce0385a262bcb394d005faa30.png
[Go_unsafe]: https://mp.weixin.qq.com/s?__biz=MzIzMDU0MTA3Nw%3D%3D&idx=1&mid=2247484529&scene=21&sn=8653947ab70f4d73ff6260965be32460#wechat_redirect
[panic_recover]: https://mp.weixin.qq.com/s?__biz=MzIzMDU0MTA3Nw%3D%3D&idx=1&mid=2247484460&scene=21&sn=0838818da3a456f409f70dd321ffa2e6#wechat_redirect
[atomic]: https://mp.weixin.qq.com/s?__biz=MzIzMDU0MTA3Nw%3D%3D&idx=1&mid=2247484475&scene=21&sn=f470d42fee8b9b65fad7b43e57518cfc#wechat_redirect
[defer]: https://mp.weixin.qq.com/s?__biz=MzIzMDU0MTA3Nw%3D%3D&idx=1&mid=2247484410&scene=21&sn=f3bf9d49c5a746b217a4d404d2a573f3#wechat_redirect
[Link 1]: https://mp.weixin.qq.com/s?__biz=MzIzMDU0MTA3Nw%3D%3D&idx=1&mid=2247484616&scene=21&sn=48ca0a39b351a7a66cc96b9827801e29#wechat_redirect
[Leaf_Segment_ID_Golang]: https://mp.weixin.qq.com/s?__biz=MzIzMDU0MTA3Nw%3D%3D&idx=1&mid=2247484313&scene=21&sn=6859d5eec70a1b3844f3bd2fc430742c#wechat_redirect
[go]: https://mp.weixin.qq.com/s?__biz=MzIzMDU0MTA3Nw%3D%3D&idx=1&mid=2247484201&scene=21&sn=7fda75e8da287bd3bbe5a719d9e72688#wechat_redirect
[go 1]: https://mp.weixin.qq.com/s?__biz=MzIzMDU0MTA3Nw%3D%3D&idx=1&mid=2247484131&scene=21&sn=5b1608613f6f1568acc85214e0ff1cbd#wechat_redirect
[Link 2]: https://mp.weixin.qq.com/s?__biz=MzIzMDU0MTA3Nw%3D%3D&idx=1&mid=2247483933&scene=21&sn=45c609694ef8cd34c98f5bd74903c754#wechat_redirect
[Link 3]: https://mp.weixin.qq.com/s?__biz=MzIzMDU0MTA3Nw%3D%3D&chksm=e8b0902edfc71938f7d7a29246d7278ac48e6c104ba27c684e12e840892252b0823de94b94c1&idx=1&lang=zh_CN&mid=2247483988&scene=21&sn=3bd52650907867d65f1c4d5c3cff8f13&token=1558933779#wechat_redirect
[Link 4]: https://mp.weixin.qq.com/s?__biz=MzIzMDU0MTA3Nw%3D%3D&idx=1&mid=2247484605&scene=21&sn=00e1b1a823034c60424007466da84cde#wechat_redirect
[go_for-range]: https://mp.weixin.qq.com/s?__biz=MzIzMDU0MTA3Nw%3D%3D&idx=1&mid=2247483875&scene=21&sn=c5da523333e807dddb70228abc2a05b9#wechat_redirect