NSCache - Golang多数据源驱动的高性能缓存框架

NSCache是一个支持多数据源驱动的高性能缓存框架插件库，它提供了统一的缓存操作接口，支持多种后端存储（如内存、Redis、Memcached等），并具有高性能和易扩展的特点。

主要特性

1. 统一的操作接口，支持多种缓存后端
2. 高性能设计，适合高并发场景
3. 支持多级缓存
4. 插件化架构，易于扩展
5. 支持缓存过期策略
6. 支持分布式缓存

安装

go get github.com/xxx/nscache

基本使用示例

package main

import (
	"fmt"
	"time"
	
	"github.com/xxx/nscache"
	"github.com/xxx/nscache/drivers/memory"
)

func main() {
	// 创建内存缓存驱动
	memDriver := memory.NewDriver()
	
	// 创建缓存实例
	cache := nscache.New(memDriver)
	
	// 设置缓存
	err := cache.Set("user:1", []byte("{\"name\":\"John\",\"age\":30}"), 10*time.Minute)
	if err != nil {
		fmt.Println("设置缓存失败:", err)
		return
	}
	
	// 获取缓存
	data, err := cache.Get("user:1")
	if err != nil {
		fmt.Println("获取缓存失败:", err)
		return
	}
	
	fmt.Println("获取到的缓存数据:", string(data))
	
	// 删除缓存
	err = cache.Delete("user:1")
	if err != nil {
		fmt.Println("删除缓存失败:", err)
	}
}

多数据源支持

NSCache支持多种缓存后端，以下是使用Redis作为缓存后端的示例：

package main

import (
	"fmt"
	"time"
	
	"github.com/xxx/nscache"
	"github.com/xxx/nscache/drivers/redis"
)

func main() {
	// 创建Redis缓存驱动
	redisDriver := redis.NewDriver(&redis.Options{
		Addr:     "localhost:6379",
		Password: "", // 无密码
		DB:       0,  // 默认DB
	})
	
	// 创建缓存实例
	cache := nscache.New(redisDriver)
	
	// 设置缓存
	err := cache.Set("product:1001", []byte("{\"name\":\"Laptop\",\"price\":999.99}"), 30*time.Minute)
	if err != nil {
		fmt.Println("设置缓存失败:", err)
		return
	}
	
	// 获取缓存
	data, err := cache.Get("product:1001")
	if err != nil {
		fmt.Println("获取缓存失败:", err)
		return
	}
	
	fmt.Println("获取到的产品信息:", string(data))
}

多级缓存示例

NSCache支持多级缓存，例如内存+Redis的两级缓存：

package main

import (
	"fmt"
	"time"
	
	"github.com/xxx/nscache"
	"github.com/xxx/nscache/drivers/memory"
	"github.com/xxx/nscache/drivers/redis"
	"github.com/xxx/nscache/multilevel"
)

func main() {
	// 创建内存缓存驱动
	memDriver := memory.NewDriver()
	
	// 创建Redis缓存驱动
	redisDriver := redis.NewDriver(&redis.Options{
		Addr:     "localhost:6379",
		Password: "",
		DB:       0,
	})
	
	// 创建多级缓存
	multiCache := multilevel.New(
		memDriver,  // 第一级：内存缓存
		redisDriver, // 第二级：Redis缓存
	)
	
	// 设置缓存
	err := multiCache.Set("config:site", []byte("{\"title\":\"My Site\",\"theme\":\"dark\"}"), 1*time.Hour)
	if err != nil {
		fmt.Println("设置缓存失败:", err)
		return
	}
	
	// 获取缓存
	data, err := multiCache.Get("config:site")
	if err != nil {
		fmt.Println("获取缓存失败:", err)
		return
	}
	
	fmt.Println("站点配置:", string(data))
}

高级功能

批量操作

// 批量设置
items := map[string][]byte{
	"user:1": []byte("{\"name\":\"Alice\"}"),
	"user:2": []byte("{\"name\":\"Bob\"}"),
}
err := cache.MSet(items, 10*time.Minute)

// 批量获取
keys := []string{"user:1", "user:2"}
results, err := cache.MGet(keys)

缓存统计

stats := cache.Stats()
fmt.Printf("缓存命中率: %.2f%%\n", stats.HitRate()*100)

性能优化建议

1. 对于高频访问的小数据，使用内存缓存
2. 对于大数据或需要持久化的数据，使用Redis或Memcached
3. 合理设置缓存过期时间
4. 使用多级缓存架构减少网络IO
5. 批量操作减少网络往返

自定义驱动实现

如果需要实现自定义的缓存驱动，只需实现nscache.Driver接口：

type MyDriver struct{}

func (d *MyDriver) Get(key string) ([]byte, error) {
	// 实现获取逻辑
}

func (d *MyDriver) Set(key string, value []byte, ttl time.Duration) error {
	// 实现设置逻辑
}

// 实现其他必要方法...

// 然后可以这样使用
myDriver := &MyDriver{}
cache := nscache.New(myDriver)

NSCache通过这种插件化设计，使得它可以轻松支持各种缓存后端，同时保持统一的API接口，方便开发者使用和切换不同的缓存方案。