0

0

怎样用Golang实现并发安全缓存 结合sync.Map与单flight模式

P粉602998670

P粉602998670

发布时间:2025-07-13 10:13:01

|

436人浏览过

|

来源于php中文网

原创

sync.map在并发缓存中提供了开箱即用的并发安全实现,其通过内部维护只读和脏两个视图,实现了无锁读取和减少锁竞争,适用于读多写少的场景。相比之下,传统map加sync.mutex需要手动管理锁,所有操作均需获取锁,性能较低。1. sync.map优化了大量并发读取的性能,因为大多数操作无需锁;2. 它适合写入不频繁、迭代需求少的场景;3. 但在写密集或需完整遍历的情况下,传统map加锁可能更高效。因此,sync.map是特定并发模式下的优化方案,而非通用替代品。

怎样用Golang实现并发安全缓存 结合sync.Map与单flight模式

Golang中构建并发安全的缓存,一个非常实用的组合是利用标准库sync.Mapgolang.org/x/sync/singleflight包。sync.Map负责高效地处理基础的并发读写,而singleflight则巧妙地解决了“缓存穿透”和“惊群效应”带来的重复计算问题,确保对同一个键的昂贵操作只执行一次。这套组合拳能让你的缓存既并发安全又高效。

怎样用Golang实现并发安全缓存 结合sync.Map与单flight模式

解决方案

要实现一个结合sync.Mapsingleflight的并发安全缓存,我们需要定义一个缓存结构体,并在其Get方法中整合两者的逻辑。

// DataFetcher 定义了一个从慢速源获取数据的接口,例如数据库、远程API等
type DataFetcher interface {
    Fetch(key string) (interface{}, error)
}

// SafeCache 结合了 sync.Map 和 singleflight.Group,实现并发安全且去重的缓存
type SafeCache struct {
    cache       sync.Map // 存储实际的缓存数据,提供并发安全的读写
    fetcher     DataFetcher // 缓存未命中时用于获取数据的源
    requestGroup singleflight.Group // 用于请求去重,避免惊群效应
}

// NewSafeCache 创建一个新的 SafeCache 实例
func NewSafeCache(fetcher DataFetcher) *SafeCache {
    return &SafeCache{
        cache:       sync.Map{},
        fetcher:     fetcher,
        requestGroup: singleflight.Group{},
    }
}

// Get 从缓存中获取数据。如果缓存未命中,则通过 DataFetcher 获取,并利用 singleflight 避免重复请求。
func (c *SafeCache) Get(key string) (interface{}, error) {
    // 尝试从 sync.Map 中快速加载。这是最快的路径,如果缓存命中,直接返回。
    if val, ok := c.cache.Load(key); ok {
        // fmt.Printf("从缓存命中:%s\n", key) // 调试信息
        return val, nil
    }

    // 缓存未命中,使用 singleflight 进行数据获取。
    // singleflight.Do 会确保对于同一个 key,只有一个 goroutine 去执行 fn 函数。
    // 其他并发请求会等待并共享这个唯一执行的结果。
    result, err, _ := c.requestGroup.Do(key, func() (interface{}, error) {
        // fmt.Printf("缓存未命中,通过 singleflight 触发数据获取:%s\n", key) // 调试信息
        data, fetchErr := c.fetcher.Fetch(key)
        if fetchErr != nil {
            // 如果数据获取失败,通常不应该缓存错误结果。
            // 但如果需要缓存一个“负面结果”(例如,该键不存在),可以考虑在这里存入一个特殊标记。
            // fmt.Printf("数据获取失败:%s, 错误:%v\n", key, fetchErr) // 调试信息
            return nil, fetchErr
        }
        c.cache.Store(key, data) // 成功获取后存入缓存
        // fmt.Printf("数据获取成功并存入缓存:%s\n", key) // 调试信息
        return data, nil
    })

    if err != nil {
        return nil, err
    }

    return result, nil
}

// Set 显式地设置缓存值。这对于预热缓存或更新特定键非常有用。
func (c *SafeCache) Set(key string, value interface{}) {
    c.cache.Store(key, value)
    // 如果有正在进行的 singleflight 请求,Forget 可以让下一次对该 key 的 Do 调用重新执行。
    // 在 Set 场景下,通常是外部更新,我们希望新的值能立即生效,所以 Forget 是一个好习惯。
    c.requestGroup.Forget(key) 
    // fmt.Printf("手动设置缓存:%s -> %v\n", key, value) // 调试信息
}

// Delete 从缓存中删除一个键值对。同时通知 singleflight 忘记该键的状态。
func (c *SafeCache) Delete(key string) {
    c.cache.Delete(key)
    c.requestGroup.Forget(key) // 确保删除后,如果再有请求,会重新发起获取操作
    // fmt.Printf("从缓存中删除:%s\n", key) // 调试信息
}

sync.Map在并发缓存中扮演了什么角色,它和传统mapsync.Mutex有什么不同?

在我看来,sync.Map在Golang并发缓存中扮演了一个非常关键的角色,它提供了一种“开箱即用”的并发安全map实现,省去了我们手动管理锁的麻烦。它的设计理念,特别是对“读多写少”或“写一次读多次”场景的优化,是其与传统mapsync.Mutex(或sync.RWMutex)最大的不同。

立即学习go语言免费学习笔记(深入)”;

AItools.fyi
AItools.fyi

找到让生活变得更轻松的最佳AI工具!

下载
怎样用Golang实现并发安全缓存 结合sync.Map与单flight模式

你可能会问,我们平时用map[string]interface{}然后外面包一层sync.RWMutex不也挺好吗?确实,对于大多数通用场景,sync.RWMutex是个非常可靠的选择。它通过读写锁来控制并发访问,读锁可以共享,写锁是排他的。但sync.Map更进一步,它内部维护了两个map:一个“只读”视图(read-only view)和一个“脏”视图(dirty view)。当进行读取操作时,它会优先从只读视图中查找,这个过程是无锁的。只有当只读视图中没有找到,或者需要写入时,才会涉及到锁的竞争,并可能将数据同步到“脏”视图,甚至提升“脏”视图为新的只读视图。

这种设计使得sync.Map在大量并发读取且写入不那么频繁的场景下,性能表现会优于简单的sync.RWMutex。因为大部分读取操作都不需要获取锁,减少了锁竞争带来的开销。然而,它也不是万能药,如果你的缓存是写操作非常频繁,或者你需要对整个map进行迭代(sync.MapRange方法会遍历所有元素,性能不一定理想),那么传统的mapsync.RWMutex可能反而是更直观、有时甚至更高效的选择。说到底,sync.Map是针对特定并发模式的优化,而非map加锁的通用替代品。

怎样用Golang实现并发安全缓存 结合sync.Map与单flight模式

单flight模式(singleflight)是如何提升缓存效率和避免雪崩效应的?

singleflight模式,尤其是golang.org/x/sync/singleflight包提供的能力,在我看来,是处理高并发下缓存穿透和“惊群效应”(或称“缓存雪崩”)的利器。想象一下,你的缓存中某个热点数据过期了,或者压根就没在缓存里(缓存穿透)。这时,成千上万个并发请求同时涌入,都试图去获取这个数据。它们会发现缓存里没有,于是乎,所有这些请求都会同时穿透缓存,直接打到你的后端数据源(比如数据库、外部API),瞬间可能就把后端服务压垮了。这就是所谓的“惊群效应”或“缓存雪崩”。

singleflight解决的就是这个问题。它的核心思想很简单:对于同一个键(key),无论有多少个并发请求同时来获取,它都只允许其中一个请求真正去执行那个昂贵的数据获取操作(比如查询数据库)。其他所有对同一个键的并发请求,都会“搭便车”,等待第一个请求的结果,然后共享这个结果。一旦第一个请求完成并返回数据,所有等待的请求都会立即

相关专题

更多
golang如何定义变量
golang如何定义变量

golang定义变量的方法:1、声明变量并赋予初始值“var age int =值”;2、声明变量但不赋初始值“var age int”;3、使用短变量声明“age :=值”等等。本专题为大家提供相关的文章、下载、课程内容,供大家免费下载体验。

180

2024.02.23

golang有哪些数据转换方法
golang有哪些数据转换方法

golang数据转换方法:1、类型转换操作符;2、类型断言;3、字符串和数字之间的转换;4、JSON序列化和反序列化;5、使用标准库进行数据转换;6、使用第三方库进行数据转换;7、自定义数据转换函数。本专题为大家提供相关的文章、下载、课程内容,供大家免费下载体验。

228

2024.02.23

golang常用库有哪些
golang常用库有哪些

golang常用库有:1、标准库;2、字符串处理库;3、网络库;4、加密库;5、压缩库;6、xml和json解析库;7、日期和时间库;8、数据库操作库;9、文件操作库;10、图像处理库。本专题为大家提供相关的文章、下载、课程内容,供大家免费下载体验。

341

2024.02.23

golang和python的区别是什么
golang和python的区别是什么

golang和python的区别是:1、golang是一种编译型语言,而python是一种解释型语言;2、golang天生支持并发编程,而python对并发与并行的支持相对较弱等等。本专题为大家提供相关的文章、下载、课程内容,供大家免费下载体验。

209

2024.03.05

golang是免费的吗
golang是免费的吗

golang是免费的。golang是google开发的一种静态强类型、编译型、并发型,并具有垃圾回收功能的开源编程语言,采用bsd开源协议。本专题为大家提供相关的文章、下载、课程内容,供大家免费下载体验。

393

2024.05.21

golang结构体相关大全
golang结构体相关大全

本专题整合了golang结构体相关大全,想了解更多内容,请阅读专题下面的文章。

200

2025.06.09

golang相关判断方法
golang相关判断方法

本专题整合了golang相关判断方法,想了解更详细的相关内容,请阅读下面的文章。

192

2025.06.10

golang数组使用方法
golang数组使用方法

本专题整合了golang数组用法,想了解更多的相关内容,请阅读专题下面的文章。

294

2025.06.17

c++ 根号
c++ 根号

本专题整合了c++根号相关教程,阅读专题下面的文章了解更多详细内容。

25

2026.01.23

热门下载

更多
网站特效
/
网站源码
/
网站素材
/
前端模板

精品课程

更多
相关推荐
/
热门推荐
/
最新课程
golang socket 编程
golang socket 编程

共2课时 | 0.1万人学习

nginx浅谈
nginx浅谈

共15课时 | 0.8万人学习

golang和swoole核心底层分析
golang和swoole核心底层分析

共3课时 | 0.1万人学习

关于我们 免责申明 举报中心 意见反馈 讲师合作 广告合作 最新更新
php中文网:公益在线php培训,帮助PHP学习者快速成长!
关注服务号 技术交流群
PHP中文网订阅号
每天精选资源文章推送

Copyright 2014-2026 https://www.php.cn/ All Rights Reserved | php.cn | 湘ICP备2023035733号