1.5. cache2go 内存

1.0

1.0

引言

cache2go 是个并发安全的续期式的缓存库，适合存储少量常驻内存变量。

项目地址

项目地址： github.com/muesli/cache2go [star:1.8k]

使用场景

• 本地轻量缓存

安装

go get github.com/muesli/cache2go

例子

具体方法可见注释

package main

import (
    "fmt"
    "time"

    "github.com/muesli/cache2go"
)

type myStruct struct {
    title   string
    content interface{}
}

func main() {
    table := "test"
    key := "oscome"

    // 新建 CacheTable
    cache := cache2go.Cache(table)
    setDataLoader(table)
    Callback(table, key)

    val := myStruct{"what", "hello oscome"}

    // 添加一个kv，过期时间 2s
    cache.Add(key, 2*time.Second, &val)

    // 获取value
    res, err := cache.Value(key)
    if err == nil {
        fmt.Printf("Found value=%+v", res.Data().(*myStruct))
    } else {
        fmt.Println("Error retrieving value from cache:", err)
    }

    // sleep 3s
    time.Sleep(3 * time.Second)
    res, err = cache.Value(key)
    if err != nil {
        fmt.Println("Item is not cached (anymore).")
    } else {
        fmt.Println("cache", res)
    }

    cache.Add(key, 0, &val)

    // 增加删除回调函数
    cache.SetAboutToDeleteItemCallback(func(e *cache2go.CacheItem) {
        fmt.Println("Deleted:", e.Key(), e.Data().(*myStruct).title, e.CreatedOn())
    })

    fmt.Println("to delete", key)
    // 删除
    cache.Delete(key)

    // 清除所有item
    cache.Flush()

}

func setDataLoader(table string) {
    cache := cache2go.Cache(table)
    // 在尝试访问不存在的key时将调用该回调
    cache.SetDataLoader(func(key interface{}, args ...interface{}) *cache2go.CacheItem {
        val := "this is " + key.(string) + ", xiaoou"
        fmt.Println("SetDataLoader", key, "--", val)
        return cache2go.NewCacheItem(key, 0, val)
    })
}

func Callback(table, key string) {
    cache := cache2go.Cache(table)

    // 设置添加回调
    cache.SetAddedItemCallback(func(entry *cache2go.CacheItem) {
        fmt.Println("callback 1:", entry.Key(), entry.Data(), entry.CreatedOn())
    })

    // 可以设置多个，但会被覆盖
    cache.SetAddedItemCallback(func(entry *cache2go.CacheItem) {
        fmt.Println("callback 2:", entry.Key(), entry.Data(), entry.CreatedOn())
    })

    cache.SetAboutToDeleteItemCallback(func(entry *cache2go.CacheItem) {
        fmt.Println("del 1:", entry.Key(), entry.Data(), entry.CreatedOn())
    })

    // 可以设置多个，但会被覆盖
    cache.SetAboutToDeleteItemCallback(func(entry *cache2go.CacheItem) {
        fmt.Println("del 2:", entry.Key(), entry.Data(), entry.CreatedOn())
    })

    cache.Add(key, 0, "xiaoou")

    res, err := cache.Value(key)
    if err != nil {
        fmt.Println("err", err)
        return
    }

    cache.Delete(key)

    fmt.Println(key, res.Data())

    cache.Delete(key)

    cache.RemoveAddedItemCallbacks()

    res = cache.Add(key+"2", time.Second, "oscome")

    res.SetAboutToExpireCallback(func(i interface{}) {
        fmt.Println("expire", i.(string))
    })

    time.Sleep(2 * time.Second)
}

实例代码

github.com/oscome/godaily/tree/mai...

tips

1. 注意 cache2go 是续期式的，当你访问对应的key后会自动更新过期时间，这点是需要尤其注意和redis的过期区分开的。

关注和赞赏都是对笔者最大的支持