近期在寫(xiě) ActivedRouter項(xiàng)目的時(shí)候需求一個(gè)緩存模型，要求緩存模型支持不同驅(qū)動(dòng),例如:memory、file、redis、mysql，實(shí)現(xiàn)思路代碼如下:

cache.go文件,定義緩存對(duì)外接口

//ActivedRouter //Author:usher.yue //Amail:usher.yue@gmail.com //TencentQQ:4223665 //緩存驅(qū)動(dòng)接口定義 //可以自定義擴(kuò)展驅(qū)動(dòng)類(lèi)型 默認(rèn)是 memory driverpackage cacheimport ("./driver" )//cache接口聲明 type Cacher interface {GetStorage() driver.ContainererSet(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 ?實(shí)現(xiàn)驅(qū)動(dòng),這里我只利用Map實(shí)現(xiàn)了，具體其他驅(qū)動(dòng)可自行實(shí)現(xiàn)

//ActivedRouter //Author:usher.yue //Amail:usher.yue@gmail.com //TencentQQ:4223665 //緩存驅(qū)動(dòng)接口定義 //可以自定義擴(kuò)展驅(qū)動(dòng)類(lèi)型 默認(rèn)是 memory cachepackage driver//容器接口聲明 type Containerer interface {PushKVPair(k, v interface{}) ContainererEraseKVPair(k interface{}) ContainererPushKVMaps(maps ...map[string]interface{}) ContainererResetKVPair(k string, v interface{}) ContainererResetOrAddKVPair(k string, v interface{}) ContainererResetKVPairs(kvMaps map[string]interface{}) ContainererResetOrAddKVPairs(kvMaps map[string]interface{}) ContainererExist(k interface{}) boolGetData() *map[string]interface{} }//基于內(nèi)存實(shí)現(xiàn)的緩存 type CacheImpl struct {Driver Containerer //數(shù)據(jù)緩存驅(qū)動(dòng) }func (self *CacheImpl) Exist(k interface{}) bool {return self.Driver.Exist(k) }func (self *CacheImpl) GetStorage() Containerer {return self.Driver }//set func (self *CacheImpl) Set(k string, v interface{}) {self.Driver.PushKVPair(k, v) }//get func (self *CacheImpl) Get(k string) (interface{}, bool) {mapData := *self.Driver.GetData()val, ok := mapData[k]return val, ok }//erase func (self *CacheImpl) Del(k string) {self.Driver.EraseKVPair(k) }//has func (self *CacheImpl) Has(k string) bool {mapData := *self.Driver.GetData()_, ok := mapData[k]return ok }//Map實(shí)現(xiàn)的內(nèi)存驅(qū)動(dòng) type MapContainer struct {data map[string]interface{} }//創(chuàng)建數(shù)據(jù)channer func 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類(lèi)型!")} 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類(lèi)型!")} 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] = vreturn 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 }

總結(jié)

以上是生活随笔為你收集整理的golang实现自定义驱动的Cache的全部?jī)?nèi)容，希望文章能夠幫你解決所遇到的問(wèn)題。

如果覺(jué)得生活随笔網(wǎng)站內(nèi)容還不錯(cuò)，歡迎將生活随笔推薦給好友。