如何在Golang中实现HTTP请求缓存_Golang HTTP请求缓存实现方法汇总-Golang-PHP中文网

如何在Golang中实现HTTP请求缓存_Golang HTTP请求缓存实现方法汇总

P粉602998670

发布： 2025-11-10 20:48:05

原创

141人浏览过

答案：Golang中实现HTTP请求缓存可通过内存缓存、自定义RoundTripper、外部系统如Redis或第三方库eko/gocache，结合缓存Key设计、TTL设置与并发控制，提升性能并降低服务压力。

如何在golang中实现http请求缓存_golang http请求缓存实现方法汇总

在Golang中实现HTTP请求缓存，核心目标是减少重复网络请求、提升响应速度和降低服务压力。虽然标准库net/http不直接提供缓存机制，但可以通过多种方式手动或借助第三方工具实现。以下是几种常见且实用的实现方法。

1. 使用内存缓存（如 sync.Map 或第三方库）

对于短期、轻量级的缓存需求，可以使用Go内置的sync.Map或map配合sync.RWMutex来存储HTTP响应结果。

基本思路：将请求的URL（或其哈希值）作为键，响应体和状态码作为值进行存储，并设置过期时间。

注意：需自行处理并发读写和过期清理。

示例代码片段：

立即学习“go语言免费学习笔记（深入）”；

var cache = struct {
    sync.RWMutex
    m map[string]struct {
        body        []byte
        statusCode  int
        expire      time.Time
    }
}{m: make(map[string]struct{})}
<p>func getCachedResponse(url string) ([]byte, int, bool) {
cache.RLock()
defer cache.RUnlock()
if item, found := cache.m[url]; found && time.Now().Before(item.expire) {
return item.body, item.statusCode, true
}
return nil, 0, false
}</p><p>func setCache(url string, body []byte, statusCode int, duration time.Duration) {
cache.Lock()
defer cache.Unlock()
cache.m[url] = struct {
body       []byte
statusCode int
expire     time.Time
}{body, statusCode, time.Now().Add(duration)}
}

登录后复制

每次发起HTTP请求前先查缓存，命中则直接返回，未命中再发起请求并写入缓存。

2. 利用 net/http/httputil.ReverseProxy + 自定义 RoundTripper

通过实现自定义的RoundTripper，可以在HTTP客户端发送请求前拦截并检查缓存。

这种方式更贴近标准库设计，适合封装成可复用组件。

关键点：

实现Transport.RoundTrip方法
根据请求生成唯一key（如Method + URL）
缓存响应的*http.Response（注意Body需可重读）

由于http.Response.Body是io.ReadCloser，缓存时需要读取并重新赋值为bytes.NewReader，否则无法多次读取。

存了个图

视频图片解析/字幕/剪辑，视频高清保存/图片源图提取

查看详情

3. 集成外部缓存系统（Redis / BoltDB）

当应用需要持久化缓存或多实例共享缓存时，推荐使用Redis等外部存储。

使用go-redis等客户端库，将序列化的响应数据（如JSON）存入Redis，并设置TTL。

优点：

支持分布式环境
自动过期管理
容量可控

示例流程：

请求前计算key（如sha256(method+url)）
从Redis获取缓存数据
命中则反序列化构造Response
未命中则发起请求并回填缓存

4. 使用成熟第三方库（如 gocache）

开源社区已有封装良好的缓存库，例如allegro/bigcache、dlclark/regexp2（非此用途，仅举例），更推荐eko/gocache。

eko/gocache 支持多层缓存（内存 + Redis），并提供统一接口。

使用示例：

import "github.com/eko/gocache/v2/cache"
import "github.com/eko/gocache/v2/store"
<p>// 初始化缓存
memStore := store.NewGoCache(gocache.NewGoCache(5*time.Minute), nil)
c := cache.New(memStore)</p><p>// 缓存HTTP响应
c.Set("<a href="https://www.php.cn/link/374cad868cb62202053d308252bc4040">https://www.php.cn/link/374cad868cb62202053d308252bc4040</a>", responseBytes, &gocache.Options{Expiration: 5 * time.Minute})

登录后复制