如何在Golang中开发简单的缓存机制_Golang缓存机制项目实战汇总

type CacheItem struct {
    Value      interface{}
    Expiration int64
}
<p>type SimpleCache struct {
data *sync.Map
}

func NewSimpleCache() *SimpleCache {
    return &SimpleCache{data: &sync.Map{}}
}
<p>func (c *SimpleCache) Set(key string, value interface{}, duration time.Duration) {
expiration := time.Now().Add(duration).UnixNano()
c.data.Store(key, CacheItem{Value: value, Expiration: expiration})
}</p><p>func (c *SimpleCache) Get(key string) (interface{}, bool) {
item, found := c.data.Load(key)
if !found {
return nil, false
}
cacheItem := item.(CacheItem)
if time.Now().UnixNano() > cacheItem.Expiration {
c.data.Delete(key)
return nil, false
}
return cacheItem.Value, true
}

cache := NewSimpleCache()
cache.Set("user_123", UserInfo{Name: "Alice"}, 5*time.Minute)
<p>if val, ok := cache.Get("user_123"); ok {
fmt.Println("命中缓存:", val)
}

func (c *SimpleCache) StartCleanup(interval time.Duration) {
    ticker := time.NewTicker(interval)
    go func() {
        for range ticker.C {
            now := time.Now().UnixNano()
            c.data.Range(func(key, value interface{}) bool {
                item := value.(CacheItem)
                if now > item.Expiration {
                    c.data.Delete(key)
                }
                return true
            })
        }
    }()
}

cache.StartCleanup(1 * time.Minute) // 每分钟扫描一次

simplecache/
├── cache.go
└── example_test.go

import "yourproject/simplecache"
<p>cache := simplecache.New()
cache.Set("token", "abc123", 10*time.Minute)