
本文详解如何使用 go 的 redigo 客户端将结构体(或结构体切片)序列化后存入 redis,并安全反序列化还原,涵盖 json 编码、列表操作、字段导出规范及常见陷阱。
在 Go 中通过 Redigo 操作 Redis 存储自定义结构体时,Redis 本身只支持字符串、字节流等基础类型,因此必须对结构体进行序列化(如 JSON)后再写入,读取时再反序列化还原。值得注意的是:您原始代码中的 title string 字段是未导出字段(小写开头),这会导致 json.Marshal 无法访问,最终序列化结果为空对象 {} —— 这是初学者最常见的坑。
✅ 正确做法:确保结构体字段可导出
首先,修正结构体定义,将字段首字母大写,并添加 JSON 标签提升可读性与兼容性:
type Resource struct {
Title string `json:"title"`
}✅ 存储结构体切片到 Redis 列表(LPUSH)
假设你要批量保存多个 Resource 实例到以 resources:
import (
"encoding/json"
"github.com/gomodule/redigo/redis"
)
func saveResourcesToRedis(conn redis.Conn, resourceID string, resources []Resource) error {
for _, r := range resources {
data, err := json.Marshal(r)
if err != nil {
return fmt.Errorf("failed to marshal resource: %w", err)
}
_, err = conn.Do("LPUSH", "resources:"+resourceID, data)
if err != nil {
return fmt.Errorf("failed to LPUSH to Redis: %w", err)
}
}
return nil
}? 提示:也可一次性 json.Marshal 整个切片 []Resource 后用 SET 存为单个键(更简洁),但若需按索引/范围获取、阻塞弹出等场景,LPUSH + LRANGE 更灵活。
✅ 从 Redis 列表读取并反序列化为结构体切片
func loadResourcesFromRedis(conn redis.Conn, resourceID string) ([]Resource, error) {
// 获取全部元素(按插入逆序,即最新在前)
reply, err := redis.ByteSlices(conn.Do("LRANGE", "resources:"+resourceID, "0", "-1"))
if err != nil {
return nil, fmt.Errorf("failed to LRANGE: %w", err)
}
var resources []Resource
for _, b := range reply {
var r Resource
if err := json.Unmarshal(b, &r); err != nil {
return nil, fmt.Errorf("failed to unmarshal resource: %w", err)
}
resources = append(resources, r)
}
return resources, nil
}⚠️ 关键注意事项
- 字段必须导出:Go 中只有首字母大写的字段才能被 json 包访问,否则 Marshal 输出为空 {}。
- 错误处理不可省略:Redis 网络异常、JSON 格式损坏、类型不匹配均可能触发 Unmarshal 错误,务必逐层校验。
- 连接管理:生产环境应使用连接池(redis.Pool),避免频繁新建连接。
- 性能考虑:高频小结构体建议启用 Redis Pipeline 批量操作;大数据量可考虑 Protocol Buffers 替代 JSON 以减少体积与解析开销。
- 键设计规范:推荐使用命名空间分隔,如 "resources:123",便于运维与 TTL 管理。
✅ 完整可运行示例(含连接初始化)
func main() {
pool := &redis.Pool{
MaxIdle: 3,
IdleTimeout: 240 * time.Second,
Dial: func() (redis.Conn, error) {
return redis.Dial("tcp", "localhost:6379")
},
}
conn := pool.Get()
defer conn.Close()
resources := []Resource{
{Title: "Redis Guide"},
{Title: "Go Concurrency"},
}
if err := saveResourcesToRedis(conn, "tutorial", resources); err != nil {
log.Fatal(err)
}
loaded, err := loadResourcesFromRedis(conn, "tutorial")
if err != nil {
log.Fatal(err)
}
fmt.Printf("Loaded %d resources: %+v\n", len(loaded), loaded)
}掌握序列化与 Redigo 的协同使用,即可安全、高效地在 Go 应用中持久化复杂数据结构——核心原则始终是:先标准化(JSON),再存储;先提取(字节流),再还原(struct)。










