Golang的memcache怎么实现
这篇文章将为大家详细讲解有关Golang的memcache怎么实现,小编觉得挺实用的,因此分享给大家做个参考,希望大家阅读完这篇文章后可以有所收获。
让客户满意是我们工作的目标,不断超越客户的期望值来自于我们对这个行业的热爱。我们立志把好的技术通过有效、简单的方式提供给客户,将通过不懈努力成为客户在信息化领域值得信任、有价值的长期合作伙伴,公司提供的服务项目有:空间域名、网络空间、营销软件、网站建设、王益网站维护、网站推广。
这两天在做项目的过程中遇到了一个访问全局变量的问题场景:编写一个方法,获取id对应的token值,token需要缓存起来(全局变量内存缓存),如果获取不到或者token的时间过期,那么发送http请求到其他端去取,然后缓存起来,然后再返回,那么代码如下:
code.go:
package person import ( "time" ) var gAccId2Token map[int]interface{} = make(map[int]interface{}) func GetTokenByAccountId(accountId uint, acl string) (map[string]interface{}, error) { //get token from cache if token, ok := gAccId2Token[accountId]; ok { if token != nil { now := time.Now().Unix() if int(now) < int(token.(map[string]interface{})["expireDate"].(float64)) { return token.(map[string]interface{}), nil } } } token, err := getTokenByHttpUrl(apiUrl) if err != nil { return map[string]interface{}{}, err } gAccId2Token[accountId] = token return token.(map[string]interface{}), nil }
那么问题来了:
1.由于gAccId2Token变量是全局变量,那么会出现同时读写的情况,则会可能出现读写不一致的情况。
2.就本例来看,获取id=2的token,而缓存的token已经过期了,那么就会发送http请求去获取,之后写缓存,假设写缓存的时间很长,而在这段时间内,又恰好有大量请求来获取id=2的token,由于token都过期了,就会出现大量请求http服务端的问题,不仅没有起到获取缓存的目的,又增大了后端的压力,同时又有多个写缓存的操作,而golang的map应该不是原子的,那么大量写内存也可能会造成crash的问题。
因此,我们需要对读写操作进行加锁:
memcache.go:
package person import ( "sync" "time" ) type memoryCache struct { lock *sync.RWMutex items map[interface{}]interface{} } func (mc *memoryCache) set(key interface{}, value interface{}) error { mc.lock.Lock() defer mc.lock.Unlock() mc.items[key] = value return nil } func (mc *memoryCache) get(key interface{}) interface{} { mc.lock.RLock() defer mc.lock.RUnlock() if val, ok := mc.items[key]; ok { return val } return nil } var gAccId2Token *memoryCache = &memoryCache{ lock: new(sync.RWMutex), items: make(map[interface{}]interface{}), } func GetTokenByAccountId(accountId uint, acl string) (map[string]interface{}, error) { //get token from cache token := gAccId2Token.get(accountId) if token != nil { now := time.Now().Unix() if int(now) < int(token.(map[string]interface{})["expireDate"].(float64)) { return token.(map[string]interface{}), nil } } token, err := getTokenByHttpUrl(apiUrl) if err != nil { return map[string]interface{}{}, err } gAccId2Token.set(accountId, token) return token.(map[string]interface{}), nil }
几点说明:
1.为写操作上了全局锁,一旦Lock()之后,其他lock便不能上锁,直到释放锁Unlock()之后才行,也就是说保证写操作的原子性。
2.而为读操作上了读锁,那么可以有多个线程Rlock()对一个区域枷锁,从而保证区域是可读的,直到所有读锁都RUnlock()之后,才可以上写锁。
3.将map的key和value的类型都定义成为interface{}类型,interface{}可以接收任何类型,就像是Java中的Object。
4.interface{}类型转换的方法,value.(type),即将value转换成为type类型,例如:value.(int),value.(map[string]interface{})等等。
关于“Golang的memcache怎么实现”这篇文章就分享到这里了,希望以上内容可以对大家有一定的帮助,使各位可以学到更多知识,如果觉得文章不错,请把它分享出去让更多的人看到。
新闻标题:Golang的memcache怎么实现
转载来于:http://azwzsj.com/article/peoieo.html