OneCache - Golang多后端存储高性能缓存插件库

OneCache是一个支持多后端存储的高性能缓存库，它提供了统一的API接口来操作不同的缓存后端，包括内存、Redis、Memcached等。

主要特性

• 统一API接口，支持多种后端存储
• 高性能，低延迟
• 支持缓存过期时间设置
• 线程安全
• 简单易用的API设计

安装

go get github.com/adelowo/onecache

基本使用示例

1. 内存缓存

package main

import (
	"fmt"
	"time"
	
	"github.com/adelowo/onecache"
	"github.com/adelowo/onecache/store"
)

func main() {
	// 创建内存存储
	memStore := store.NewInMemoryStore()
	
	// 创建缓存实例
	cache := onecache.New(memStore)
	
	// 设置缓存，10秒过期
	err := cache.Set("key1", []byte("value1"), 10*time.Second)
	if err != nil {
		panic(err)
	}
	
	// 获取缓存
	val, err := cache.Get("key1")
	if err != nil {
		panic(err)
	}
	
	fmt.Println(string(val)) // 输出: value1
	
	// 删除缓存
	err = cache.Delete("key1")
	if err != nil {
		panic(err)
	}
}

2. Redis缓存

package main

import (
	"fmt"
	"time"
	
	"github.com/adelowo/onecache"
	"github.com/adelowo/onecache/store"
)

func main() {
	// 创建Redis存储
	redisStore := store.NewRedisStore(&store.RedisOptions{
		Addr:     "localhost:6379",
		Password: "", // 无密码
		DB:       0,  // 默认DB
	})
	
	cache := onecache.New(redisStore)
	
	// 设置缓存，1分钟过期
	err := cache.Set("user:1001", []byte("{\"name\":\"John\",\"age\":30}"), time.Minute)
	if err != nil {
		panic(err)
	}
	
	// 获取缓存
	userData, err := cache.Get("user:1001")
	if err != nil {
		panic(err)
	}
	
	fmt.Println(string(userData)) // 输出: {"name":"John","age":30}
}

3. Memcached缓存

package main

import (
	"fmt"
	"time"
	
	"github.com/adelowo/onecache"
	"github.com/adelowo/onecache/store"
)

func main() {
	// 创建Memcached存储
	memcachedStore := store.NewMemcachedStore([]string{"localhost:11211"})
	
	cache := onecache.New(memcachedStore)
	
	// 设置缓存，无过期时间
	err := cache.Set("config:app", []byte("production"), 0)
	if err != nil {
		panic(err)
	}
	
	// 获取缓存
	config, err := cache.Get("config:app")
	if err != nil {
		panic(err)
	}
	
	fmt.Println(string(config)) // 输出: production
}

高级功能

批量操作

// 批量设置
err := cache.SetMulti(map[string][]byte{
	"key1": []byte("value1"),
	"key2": []byte("value2"),
}, time.Minute)

// 批量获取
values, err := cache.GetMulti([]string{"key1", "key2"})

缓存清理

// 清空所有缓存
err := cache.Flush()

自定义存储后端

你可以实现自己的存储后端，只需要实现store.Store接口：

type MyCustomStore struct{}

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

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

func (m *MyCustomStore) Delete(key string) error {
	// 实现删除逻辑
}

func (m *MyCustomStore) Flush() error {
	// 实现清空逻辑
}

// 使用自定义存储
customStore := &MyCustomStore{}
cache := onecache.New(customStore)

性能优化建议

1. 对于高频访问的小数据，使用内存缓存
2. 对于分布式系统，使用Redis或Memcached
3. 合理设置缓存过期时间
4. 使用批量操作减少网络开销
5. 对于大型对象，考虑压缩后再存储

OneCache提供了简单统一的API来操作不同的缓存后端，使得在应用程序中切换缓存策略变得非常容易，同时保持了高性能的特性。