Cache缓存项目学习2
项目架构
缓存服务器设计
ETCD使用:
当Server实例初始化时建立ETCD客户端,当server启动时,进行服务注册。
当服务器实例化peeker时,进行服务发现,服务发现分为全量发现与增量发现。增量更新维持一个watch goroutine,监视etcd的变化,如有新的服务变化,更新peeker缓存。
GRPC使用
Server层进行grpc.Server创建,实现了Get/Set/Delete方法。
Group缓存层当本地缓存未命中时,会调用PickPeer,获取远程客户端发起gRPC调用。
对于Peer节点层,PickPeer会使用一致性哈希选择返回对应的client,方便对其进行RPC调用。
Group设计
// Group 是一个缓存命名空间 type Group struct { name string getter Getter mainCache *Cache //缓存空间 peers PeerPicker //选择器 loader *singleflight.Group //单飞设计 expiration time.Duration // 缓存过期时间,0表示永不过期 closed int32 // 原子变量,标记组是否已关闭 stats groupStats // 统计信息 } // groupStats 保存组的统计信息 type groupStats struct { loads int64 // 加载次数 localHits int64 // 本地缓存命中次数 localMisses int64 // 本地缓存未命中次数 peerHits int64 // 从对等节点获取成功次数 peerMisses int64 // 从对等节点获取失败次数 loaderHits int64 // 从加载器获取成功次数 loaderErrors int64 // 从加载器获取失败次数 loadDuration int64 // 加载总耗时(纳秒) }