在Golang项目开发中，代理模式常被用来控制对目标对象的访问，而结合缓存机制可以避免重复请求带来的性能损耗，尤其适合下游服务响应较慢或者请求频率较高的场景。两者的结合既保留了代理的访问控制能力，又能通过缓存提升整体效率。
核心实现思路
代理与缓存结合的核心逻辑是：代理对象接收请求后，先检查缓存中是否存在对应的结果，如果存在则直接返回缓存内容，不需要转发请求到目标对象；如果不存在，则转发请求到目标对象，获取结果后先存入缓存再返回给调用方。
整体结构可以分为三个部分：
- 目标接口：定义被代理对象需要实现的方法，保证代理和目标对象的方法签名一致
- 目标对象：实现目标接口，完成实际的业务逻辑处理
- 代理对象：同样实现目标接口，内部持有目标对象的引用和缓存实例，负责缓存检查和请求转发
完整实现示例
1. 定义目标接口和目标对象
首先定义一个数据查询的接口，目标对象实现该接口，模拟从下游服务获取数据的逻辑。
// 定义查询接口
type DataFetcher interface {
Fetch(key string) (string, error)
}
// 实际的目标对象，模拟从数据库或远程服务获取数据
type RealDataFetcher struct{}
func (r *RealDataFetcher) Fetch(key string) (string, error) {
// 模拟耗时操作，比如远程请求或者数据库查询
time.Sleep(100 * time.Millisecond)
return "data_for_" + key, nil
}
2. 实现缓存模块
这里使用简单的map作为缓存存储，实际项目中可以替换为Redis等分布式缓存，同时需要添加过期时间和并发控制逻辑。
// 缓存结构，使用sync.Map保证并发安全
type Cache struct {
data *sync.Map
// 可以扩展添加过期时间、最大缓存数量等字段
}
func NewCache() *Cache {
return &Cache{
data: &sync.Map{},
}
}
// 从缓存获取数据
func (c *Cache) Get(key string) (string, bool) {
val, ok := c.data.Load(key)
if !ok {
return "", false
}
return val.(string), true
}
// 向缓存写入数据
func (c *Cache) Set(key string, value string) {
c.data.Store(key, value)
}
3. 实现代理对象
代理对象实现DataFetcher接口，内部持有目标对象和缓存实例，完成缓存检查和请求转发的逻辑。
// 代理对象结构
type CacheProxy struct {
realFetcher DataFetcher
cache *Cache
}
func NewCacheProxy(realFetcher DataFetcher, cache *Cache) *CacheProxy {
return &CacheProxy{
realFetcher: realFetcher,
cache: cache,
}
}
// 实现Fetch方法，先查缓存再转发请求
func (p *CacheProxy) Fetch(key string) (string, error) {
// 先检查缓存
if val, ok := p.cache.Get(key); ok {
fmt.Println("从缓存获取数据，key:", key)
return val, nil
}
// 缓存未命中，转发请求到目标对象
fmt.Println("缓存未命中，请求目标对象，key:", key)
data, err := p.realFetcher.Fetch(key)
if err != nil {
return "", err
}
// 将结果写入缓存
p.cache.Set(key, data)
return data, nil
}
4. 测试验证逻辑
编写测试代码验证代理与缓存结合的效果，观察重复请求是否命中缓存。
func main() {
// 初始化目标对象和缓存
realFetcher := &RealDataFetcher{}
cache := NewCache()
// 创建代理对象
proxy := NewCacheProxy(realFetcher, cache)
// 第一次请求，缓存未命中
data1, err := proxy.Fetch("test_key")
if err != nil {
fmt.Println("请求出错:", err)
return
}
fmt.Println("第一次请求结果:", data1)
// 第二次请求，缓存命中
data2, err := proxy.Fetch("test_key")
if err != nil {
fmt.Println("请求出错:", err)
return
}
fmt.Println("第二次请求结果:", data2)
}
实践注意事项
缓存一致性问题
如果目标对象的数据会发生更新，需要及时清理或者更新缓存中的对应内容，避免出现缓存数据和实际数据不一致的情况。可以在代理对象中添加更新缓存的方法，在数据变更时主动触发。
缓存过期策略
示例中的缓存没有设置过期时间，长期运行会导致缓存占用内存过高。实际实现时可以给缓存项添加过期时间戳，在获取缓存时检查是否过期，过期则重新请求目标对象。
并发控制优化
如果多个请求同时查询同一个不存在的缓存key，可能会出现缓存击穿的情况，即多个请求同时转发到目标对象。可以使用单飞（singleflight）模式，保证同一个key在同一时间只有一个请求去查询目标对象，其他请求等待结果即可。
扩展优化方向
目前的实现是基础版本，还可以根据实际需求做更多优化：比如添加缓存淘汰策略，当缓存数量达到上限时淘汰最久未使用的内容；支持不同的缓存存储介质，比如本地内存缓存和分布式缓存切换；添加缓存命中率统计，方便监控缓存效果等。