[toc]
项目因为早期写还有些东西不足可能包括知识上的不足，目前已经进入到企业(国内互联网顶尖企业之一)工作学习到了很多大佬的知识。 但是它依旧是一个很好的学习项目。因为由于单个执行器的原因造成了性能的瓶颈。 但是项目中很多的**依然值得学习 包括淘汰策略等等。 目前笔者在写一套值得你在项目中使用的工具包。包括 缓存组件(性能比这个要高很多) 日志组件(这个我觉得非常好用) 等等一系列。。。 链接： https://github.com/xy63237777/go-lib-utils 当然目前也在开发当中 那个缓存也值得学习 : https://github.com/xy63237777/go-lib-utils/tree/master/cache
-
这是一款高性能的Go语言的缓存框架.笔者写的并不完美.虽然是线程安全并且使用了无锁.基于管道命令.支持同步异步获取.使用了LRU和LFU两种淘汰策略并且可以设置缓存时间.
-
然后这里我会进行一个快速开始.并且教你们如何使用.如果你想学习这个缓存项目的源代码并且提高功力.或者你可以帮帮笔者继续提高一下性能.那么我可以为你提供博客的教学地址.并且我会在博客的教学地址里写上我当时的完整思路还有问题的所在.如果解决这个问题的.
博客地址: https://blog.csdn.net/qq_42011541/article/details/103410959 <- 戳我(看详细思路)
- 如果你是想学习Go语言没有好的项目并且想提高功力,那么这个项目一定是你的首选
- 这里附上笔者的邮箱联系方式 : 63237777@qq.com
你只需要下面这条命令就可以把这个正式版的项目copy下来
go get -v github.com/xy63237777/channel-cache如果你想学习源码或者能为这个项目提交你的思路和代码 你可以切换至dev分支
dev : https://github.com/xy63237777/channel-cache/tree/channel-dev
然后在你的代码里获取到一个Cache实例
package main
import (
"github.com/xy63237777/channel-cache/cache-goV1"
)
func main() {
cache := gocache.NewSignalCacheForDefault()
}当然你也可以指定一些策略
第一个参数是LRU(最近最久未使用)缓存 默认是LFU(最近最少使用算法) 然后第二个参数是这个缓存的大小.
默认是2048
这是一个简单开始的例子
cache := gocache.NewSignalCache(gocache.CacheForLRU, gocache.DefaultCapacity)然后对于返回会返回值本身和bool类型. bool类型表示有无这个对象 通常会返回你想要的值+true 或者 nil + false
func main() {
cache := gocache.NewSignalCache(gocache.CacheForLRU, gocache.DefaultCapacity)
cache.Set("hello","world")
fmt.Println(cache.Get("hello"))
}当然你在Set的时候为这个对象写一定的过期时间. 如果不指定则默认不过期
下面代码如果3个小时后就会过期
func main() {
cache := gocache.NewSignalCache(gocache.CacheForLRU, gocache.DefaultCapacity)
cache.SetForExpiration("hello","world", time.Hour * 3)
fmt.Println(cache.Get("hello"))
}下面代码将异步返回你的结果
返回的先是一个管道 你通过这个管道再去读. 也就是说 你可以先去获管道,如果你不着急获取值的话. 你可以在客户端异步去完成这些工作. 等你真正需要这个变量的时候再通过管道去拿.
func main() {
cache := gocache.NewSignalCache(gocache.CacheForLRU, gocache.DefaultCapacity)
cache.SetForExpiration("hello","world", time.Hour * 3)
async := cache.GetAsync("hello")
val := <- async
fmt.Println(val)
}当然你可以删除一个缓存实例
func main() {
cache := gocache.NewSignalCache(gocache.CacheForLRU, gocache.DefaultCapacity)
cache.SetForExpiration("hello","world", time.Hour * 3)
async := cache.GetAsync("hello")
val := <- async
fmt.Println(val)
cache.Delete("hello")
}你可以创建一个缓存管理者,这个管理者是单例的.所以放心使用
如果你想单独做一个缓存服务器的话,你可以制定一个go的服务端和客户端来做一些负载均衡.,那么就应该使用manager 如果你只需要一个简单的缓存NewSignalCache应该是你的首选
func main() {
manager := gocache.NewCacheManager()
manager.CreateCacheForDefault("cache1")
}然后通过Get这个缓存就和以前使用一样了
func main() {
manager := gocache.NewCacheManager()
manager.CreateCacheForDefault("cache1")
cache := manager.GetCache("cache1")
cache.Set("hello", "world")
cache.Get("hello")
}你可以暂停或者继续一个缓存
如果当你暂停以后你的所有操作都不会接受. 并且会打印warning
func main() {
manager := gocache.NewCacheManager()
manager.CreateCacheForDefault("cache1")
cache := manager.GetCache("cache1")
err := manager.CacheStop("cache1")
if err != nil {
panic(err)
}
cache.Set("hello", "world")
fmt.Println(cache.Get("hello"))
err = manager.CacheRun("cache1")
if err != nil {
panic(err)
}
cache.Set("hello", "world")
fmt.Println(cache.Get("hello"))
}以下是笔者电脑上的打印信息
[GOPM] 12-08 00:21:23 [ WARN] Warning... Using a stopped cache
[GOPM] 12-08 00:21:23 [ WARN] Warning... Using a stopped cache
<nil> false
world true
当然你也可以像管理者里加入一个缓存实例或者删除一个实例
如果你想自定义你的缓存 你不想使用LRU 或者 LFU
那么你只需要继承下面的接口
type CacheInter interface {
Get(string) interface{}
Put(string, interface{})
Delete(string)
}package main
import gocache "four-seasons/cache-goV1"
func main() {
//参数传入你的实现
cache := gocache.NewSignalCacheCustom()
}当然你可以使用Manager来管理
可能是因为读写管道比较耗时,这个性能的损耗竟然比加解锁要耗时.本来笔者最一开始也想加锁.如果加锁的话不对加锁的粒度进行优化的话.那么是没有灵魂的. 然后我发现如果使用LFU算法 这个加锁的粒度很麻烦 很容易把代码改的面目全非. 然后就想到了Redis的方式. 执行器只有一个. 所以笔者这里也模仿了这个模式.有一个goroutines去监听这个管道.如果管道有值了就执行然后完全不需要加锁.写起来也很舒服.但是这样的代价就是可能性能丢了1倍左右. 但是我觉得目前为止来说是值得的
对比github上一个go的缓存框架. 虽然性能会慢上一倍到2倍. 这也是因为我指令太多的原因.但是换来的是功能强大. 比如缓存大小. 淘汰算法. 或者以后你自定义的数据结构 你完全不需要去加锁. 这正是Go的哲学理念不是吗? 大道至简
然后也希望大家点一个关注. 集思广益帮我优化一下. 其实我本来还有很多的想法 但是我觉得可能得不偿失就没有去试. 然后 在博客里面为会把我的所有思路写出来