golang实现自定义驱动的Cache

概述近期在写 ActivedRouter项目的时候需求一个缓存模型，要求缓存模型支持不同驱动,例如:memory、file、redis、mysql，实现思路代码如下: cache.go文件,定义缓存对外接口 //ActivedRouter//Author:usher.yue//Amail:usher.yue@gmail.com//TencentQQ:4223665//缓存驱动接口定义//可以

近期在写 ActivedRouter项目的时候需求一个缓存模型，要求缓存模型支持不同驱动,例如: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}

总结

以上是内存溢出为你收集整理的golang实现自定义驱动的Cache全部内容，希望文章能够帮你解决golang实现自定义驱动的Cache所遇到的程序开发问题。

如果觉得内存溢出网站内容还不错，欢迎将内存溢出网站推荐给程序员好友。