本文介绍在 go web 开发中，如何将 api 请求获取的结构化数据（如电影列表）从 http 处理函数中提取出来，并安全、可维护地供其他函数或处理器复用，避免全局变量滥用和并发风险。
本文介绍在 go web 开发中，如何将 api 请求获取的结构化数据（如电影列表）从 http 处理函数中提取出来，并安全、可维护地供其他函数或处理器复用，避免全局变量滥用和并发风险。
在 Go 中，http.HandlerFunc（如 RequestTopMovies）本质是独立的请求作用域函数，其局部变量（如解码后的 p Payload）生命周期仅限于单次请求，无法直接被其他 goroutine 或后续请求访问。若需跨函数共享响应数据，不能依赖局部变量传递，而应采用线程安全、作用域明确的设计方案。
✅ 推荐方案：使用同步容器 + 读写锁（适用于轻量级缓存）
package main
import (
"encoding/json"
"fmt"
"io/ioutil"
"net/http"
"sync"
)
type Payload struct {
Results []struct {
Overview string `json:"overview"`
Title string `json:"title"`
} `json:"results"`
}
// 全局安全缓存：支持并发读写
var (
movieCache = make(map[string]Payload)
cacheMu sync.RWMutex
)
// SetMovieData 安全写入缓存（建议在请求处理中调用）
func SetMovieData(key string, data Payload) {
cacheMu.Lock()
defer cacheMu.Unlock()
movieCache[key] = data
}
// GetMovieData 安全读取缓存（可在任意 handler 或业务逻辑中调用）
func GetMovieData(key string) (Payload, bool) {
cacheMu.RLock()
defer cacheMu.RUnlock()
data, ok := movieCache[key]
return data, ok
}
func RequestTopMovies(w http.ResponseWriter, r *http.Request) {
url := "https://api.themoviedb.org/3/movie/top_rated?api_key=YOUR_KEY"
res, err := http.Get(url)
if err != nil {
http.Error(w, "API request failed", http.StatusInternalServerError)
return
}
defer res.Body.Close()
body, err := ioutil.ReadAll(res.Body)
if err != nil {
http.Error(w, "Failed to read response", http.StatusInternalServerError)
return
}
var p Payload
if err := json.Unmarshal(body, &p); err != nil {
http.Error(w, "JSON decode failed", http.StatusBadRequest)
return
}
// ✅ 安全存入共享缓存（key 可按业务定义，如 "top_movies_2024"）
SetMovieData("top_movies", p)
// 响应客户端（可选）
fmt.Fprintf(w, "Cached %d movies", len(p.Results))
}
// 示例：另一个 handler 复用已获取的数据
func DisplayTopMovies(w http.ResponseWriter, r *http.Request) {
if p, ok := GetMovieData("top_movies"); ok {
for _, m := range p.Results {
fmt.Fprintf(w, "
⚠️ 注意事项与最佳实践
- 避免裸全局变量：直接使用 var Temp = map[string]Payload{} 而不加锁，在高并发下会导致 panic（fatal error: concurrent map writes）；
- 慎用 context 传递数据：context.Context 适用于请求生命周期内的值传递（如用户 ID、trace ID），不适合跨请求持久化数据；
- 考虑时效性：上述缓存无过期机制，生产环境应引入 TTL（如用 github.com/patrickmn/go-cache）或结合 Redis；
- 错误处理要健壮：示例中已替换 panic 为 http.Error，确保服务不崩溃；
- 结构体导出字段：确保 Payload 字段首字母大写且含正确 JSON tag，否则 json.Unmarshal 无法赋值。
通过封装带锁的缓存操作，你既保持了代码的模块化，又实现了数据在多个处理器间的可控共享——这是 Go 中平衡简洁性与并发安全的典型实践。
