Golang并发缓存实现：读写锁与过期策略详解

要实现Go语言中的并发安全缓存系统，关键在于使用sync.RWMutex和过期策略。1. 使用读写锁（RWMutex）保证并发安全，读操作用RLock，写操作用Lock；2. 为缓存项添加过期时间，通过SetWithTTL设置TTL并用time.Now().Add计算过期时间戳；3. 获取时判断是否过期，仅返回未过期数据；4. 启动后台goroutine定期调用GCOnce清理过期项；5. 实际使用中建议合理设置TTL、支持永不过期选项、引入淘汰策略，并注意避免频繁GC、缓存雪崩和锁竞争问题。

在Go语言中，实现一个并发安全的缓存系统并不难，关键在于合理使用读写锁和过期策略。如果你的应用需要频繁访问数据，又不想每次都去查数据库或者远程接口，本地缓存是个不错的选择。

下面我们就来看看如何结合sync.RWMutex（读写锁）和简单的过期机制来构建一个线程安全、自动清理的缓存结构。

使用读写锁保证并发安全

Go标准库中的sync.RWMutex是实现并发安全访问共享资源的常用方式。对于缓存来说，通常读操作远多于写操作，所以用读写锁比互斥锁（Mutex）更高效。

举个例子，当你有一个全局的map作为缓存容器时：

type Cache struct {
    mu sync.RWMutex
    data map[string]interface{}
}

每次读取的时候加读锁：

func (c *Cache) Get(key string) (interface{}, bool) {
    c.mu.RLock()
    defer c.mu.RUnlock()
    val, ok := c.data[key]
    return val, ok
}

写入或删除的时候加写锁：

func (c *Cache) Set(key string, value interface{}) {
    c.mu.Lock()
    defer c.mu.Unlock()
    c.data[key] = value
}

func (c *Cache) Delete(key string) {
    c.mu.Lock()
    defer c.mu.Unlock()
    delete(c.data, key)
}

这样就能避免多个goroutine同时修改导致的数据竞争问题了。

加入过期时间，自动清理无效数据

只做并发控制还不够，如果缓存一直不清理，内存会越占越多。所以你需要给每个缓存项加上过期时间，并定期检查清理。

可以扩展上面的结构体，为每个值添加一个过期时间戳：

type item struct {
    value      interface{}
    expireTime time.Time
}

type Cache struct {
    mu   sync.RWMutex
    data map[string]item
}

设置缓存时传入一个TTL（存活时间）：

func (c *Cache) SetWithTTL(key string, value interface{}, ttl time.Duration) {
    c.mu.Lock()
    defer c.mu.Unlock()
    c.data[key] = item{
        value:      value,
        expireTime: time.Now().Add(ttl),
    }
}

获取的时候判断是否过期：

func (c *Cache) Get(key string) (interface{}, bool) {
    c.mu.RLock()
    defer c.mu.RUnlock()
    it, ok := c.data[key]
    if !ok {
        return nil, false
    }
    if time.Now().After(it.expireTime) {
        return nil, false
    }
    return it.value, true
}

至于清理过期项，可以用一个后台goroutine定时扫描：

func (c *Cache) StartGC(interval time.Duration) {
    go func() {
        ticker := time.NewTicker(interval)
        for {
            <-ticker.C
            c.GCOnce()
        }
    }()
}

func (c *Cache) GCOnce() {
    now := time.Now()
    c.mu.Lock()
    defer c.mu.Unlock()
    for k, v := range c.data {
        if now.After(v.expireTime) {
            delete(c.data, k)
        }
    }
}

这样就实现了基本的自动清理逻辑。

实际使用中的一些小建议

• TTL设多少合适？ 要根据业务需求决定，比如用户信息可能设5分钟，热点配置可以设30秒。
• 是否要支持永不过期？ 可以加一个NoExpire的选项，比如传time.Duration(0)表示永不过期。
• 要不要考虑淘汰策略？ 如果缓存容量有限，还可以引入LRU或LFU算法做淘汰。
• 性能问题注意点：
  • 频繁GC会影响性能，建议间隔不要太短；
  • 大量缓存同时失效可能会造成雪崩，可以加一个随机偏移时间；
  • 对于高并发场景，也可以考虑分片缓存，减少锁竞争。

基本上就这些。用好读写锁+过期管理，你就可以在Go里实现一个轻量但实用的并发安全缓存系统了。不复杂但细节容易忽略，慢慢打磨就好。