信息发布→ 登录 注册 退出

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

发布时间:2025-12-31

点击量:

本文详解如何使用 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)
}

掌握序列化与 Redigo 的协同使用,即可安全、高效地在 Go 应用中持久化复杂数据结构——核心原则始终是:先标准化(JSON),再存储;先提取(字节流),再还原(struct)

标签:# js  # git  # json  # go  # github  # 编码  # redis  # 切片  # 也可  # 对象  # 序列化  # 为空  # 的是  # 首字母  # 这是  # 多个  # 你要  # 推荐使用  # Struct  # 数据结构  # 结构体  # 字符串  # 命名空间  # Resource  # String  # red  # ai  # 字节  # app  # 大数据  
在线客服
服务热线

服务热线

4008888355

微信咨询
二维码
返回顶部
×二维码

截屏,微信识别二维码

打开微信

微信号已复制,请打开微信添加咨询详情!