博客
关于我
强烈建议你试试无所不能的chatGPT,快点击我
golang实现自定义驱动的Cache
阅读量:5951 次
发布时间:2019-06-19

本文共 3631 字,大约阅读时间需要 12 分钟。

近期在写 项目的时候需求一个缓存模型,要求缓存模型支持不同驱动,例如:memory、file、redis、mysql,实现思路代码如下:

cache.go文件,定义缓存对外接口

//ActivedRouter//Author:usher.yue//Amail:usher.yue@gmail.com//TencentQQ:4223665//缓存驱动接口定义//可以自定义扩展驱动类型 默认是 memory driverpackage cacheimport (	"./driver")//cache接口声明type Cacher interface {	GetStorage() driver.Containerer	Set(k string, v interface{})	Get(k string) (interface{}, bool)	Del(k string)	Has(k string) bool}//create memory cache//type "file" or "memory"func Newcache(cacheType string) Cacher {	switch cacheType {	case "memory":		return &driver.CacheImpl{Driver: driver.NewMapContainer()}	case "file":		{			return &driver.CacheImpl{Driver: driver.NewFileContainer()}		}	case "mysql":		{			return &driver.CacheImpl{Driver: driver.NewMysqlContainer()}		}	case "redis":		{			return &driver.CacheImpl{Driver: driver.NewRedisContainer()}		}	case "mongodb":		{			return &driver.CacheImpl{Driver: driver.NewMongoContainer()}		}	}	return nil}

driver.go  实现驱动,这里我只利用Map实现了,具体其他驱动可自行实现

//ActivedRouter//Author:usher.yue//Amail:usher.yue@gmail.com//TencentQQ:4223665//缓存驱动接口定义//可以自定义扩展驱动类型 默认是 memory cachepackage driver//容器接口声明type Containerer interface {	PushKVPair(k, v interface{}) Containerer	EraseKVPair(k interface{}) Containerer	PushKVMaps(maps ...map[string]interface{}) Containerer	ResetKVPair(k string, v interface{}) Containerer	ResetOrAddKVPair(k string, v interface{}) Containerer	ResetKVPairs(kvMaps map[string]interface{}) Containerer	ResetOrAddKVPairs(kvMaps map[string]interface{}) Containerer	Exist(k interface{}) bool	GetData() *map[string]interface{}}//基于内存实现的缓存type CacheImpl struct {	Driver Containerer //数据缓存驱动}func (self *CacheImpl) Exist(k interface{}) bool {	return self.Driver.Exist(k)}func (self *CacheImpl) GetStorage() Containerer {	return self.Driver}//setfunc (self *CacheImpl) Set(k string, v interface{}) {	self.Driver.PushKVPair(k, v)}//getfunc (self *CacheImpl) Get(k string) (interface{}, bool) {	mapData := *self.Driver.GetData()	val, ok := mapData[k]	return val, ok}//erasefunc (self *CacheImpl) Del(k string) {	self.Driver.EraseKVPair(k)}//hasfunc (self *CacheImpl) Has(k string) bool {	mapData := *self.Driver.GetData()	_, ok := mapData[k]	return ok}//Map实现的内存驱动type MapContainer struct {	data map[string]interface{}}//创建数据channerfunc NewMapContainer() *MapContainer {	return &MapContainer{data: make(map[string]interface{})}}func (this *MapContainer) PushKVPair(k, v interface{}) Containerer {	if key, ok := k.(string); !ok {		panic("key必须是string类型!")	} else {		this.data[key] = v	}	return this}func (this *MapContainer) Exist(k interface{}) bool {	return true}func (this *MapContainer) EraseKVPair(k interface{}) Containerer {	if key, ok := k.(string); !ok {		panic("key必须是string类型!")	} else {		delete(this.data, key)	}	return this}func (this *MapContainer) PushKVMaps(maps ...map[string]interface{}) Containerer {	for _, itemMap := range maps {		for itemKey, itemValue := range itemMap {			this.PushKVPair(itemKey, itemValue)		}	}	return this}func (this *MapContainer) ResetKVPair(k string, v interface{}) Containerer {	if _, ok := this.data[k]; ok {		this.data[k] = v	}	return this}func (this *MapContainer) ResetOrAddKVPair(k string, v interface{}) Containerer {	this.data[k] = v	return this}func (this *MapContainer) ResetKVPairs(kvMaps map[string]interface{}) Containerer {	for k, v := range kvMaps {		if _, ok := this.data[k]; ok {			this.data[k] = v		}	}	return this}func (this *MapContainer) ResetOrAddKVPairs(kvMaps map[string]interface{}) Containerer {	for k, v := range kvMaps {		this.data[k] = v	}	return this}func (this *MapContainer) GetData() *map[string]interface{} {	return &this.data}

你可能感兴趣的文章
python之MySQL学习——数据操作
查看>>
懒加载——实现原理
查看>>
【个人作业】单词链
查看>>
Harmonic Number (II)
查看>>
长连接、短连接、长轮询和WebSocket
查看>>
day30 模拟ssh远程执行命令
查看>>
做错的题目——给Array附加属性
查看>>
Url.Action取消字符转义
查看>>
K8S调度之标签选择器
查看>>
JQuery选择器大全
查看>>
Gamma阶段第三次scrum meeting
查看>>
python3之装饰器修复技术@wraps
查看>>
[考试]20150606
查看>>
Javascript_备忘录5
查看>>
Can’t create handler inside thread that has not called Looper.prepare()
查看>>
敏捷开发方法综述
查看>>
Hadoop数据操作系统YARN全解析
查看>>
Django 运行报错 ImportError: No module named 'PIL'
查看>>
修改数据库的兼容级别
查看>>
Windows下同时安装两个版本Jdk
查看>>