如何在 Go 中使用 Redigo 将结构体数组存入并从 Redis 读取_技术教程

本文详解如何使用 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: 为键的 Redis 列表中：

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)
}