如何在 Golang 中 HSET 时间到 redigo (Redis)？ 如果时区不是问题如果考虑时区

编程问答 2022-04-22

问题描述

我正在使用 redigo 在 redigo 中存储和检索数据。 我有一个包含以下时间类型定义的结构。我想在 Redis 中使用 Data 存储结构 HSET。我有一个类型定义，可以通过向我的 ScanStruct 类型添加函数 RedisScan 来使用 Timestamp。

问题是 Redis 在时间 fields 之后将 Timestamp 存储为 ext,wall,loc。你不能从这些字段创建一个新的 Time 对象，所以这是相当无用的。为 redigo 序列化结构的正确方法是什么？

type Timestamp time.Time

func (t *Timestamp) RedisScan(x interface{}) error {
    ...
}

type Data struct {
    Timestamp  Timestamp `redis:"timestamp"`
}

func (r *RedisRepo) Write(data Data,key String) error {
    conn := r.pool.Get()
    defer conn.Close()
    conn.Send("HSET",redis.Args{key}.AddFlat(data)...)     
}

func (r *RedisRepo) Read(key string) (*Data,error) {
    var data Data
    conn := r.pool.Get()
    defer conn.Close()
    v,err := redis.Values(conn.Do("HGETALL",key))
    return redis.ScanStruct(v,&data)
}

解决方法

redis.ScanStruct 函数和 Args.AddFlat 方法缺少使这对可用作通用编组/解组函数的功能。

解决问题的方法取决于您的目标是什么。 如果您的目标是加载和保存结构，而不是访问 Redis 哈希，请参阅 Save generic struct to redis。

如果您的目标是访问具有定义名称和值的 Redis 散列，则编写代码来在这些定义和 Go 值之间进行转换。下面是一个散列示例，该散列定义为具有字段“时间戳”，其值为十进制编码的 Unix 秒：

type Data struct {
    Timestamp time.Time
}

func (r *RedisRepo) Write(data Data,key string) error {
    conn := r.pool.Get()
    defer conn.Close()
    _,err := conn.Do("HSET",key,"timestamp",data.Timestamp.Unix())
    return err
}

func (r *RedisRepo) Read(key string) (*Data,error) {
    conn := r.pool.Get()
    defer conn.Close()
    v,err := redis.Values(conn.Do("HGETALL",key))
    if err != nil {
        return nil,err
    }

    var fields struct {
        Timestamp int64 `redis:"timestamp"`
    }

    err = redis.ScanStruct(v,&fields)
    if err != nil {
        return nil,err
    }
    return &Data{Timestamp: time.Unix(fields.Timestamp,0)},nil
}

根据需要调整代码以匹配 Redis 哈希字段定义。以下是 RFC 3339 格式的时间代码：

type Data struct {
    Timestamp time.Time
}

func (r *RedisRepo) Write(data Data,data.Timestamp.Format(time.RFC3339))
    return err
}

func (r *RedisRepo) Read(key string) (*Data,err
    }

    var fields struct {
        Timestamp string `redis:"timestamp"`
    }

    err = redis.ScanStruct(v,err
    }
    t,err := time.Parse(time.RFC3339,fields.Timestamp)
    if err != nil {
        return nil,err
    }
    return &Data{Timestamp: t},nil
}

编写上面的 Read 示例是为了使示例易于扩展到多个领域。如果应用程序只需要访问单个字段，请将 fields 变量和 ScanStruct 废话替换为对 redis.Int64(conn.Do("HGET","timestamp") 或 redis.String(conn.Do("HGET","timestamp")

的调用 ,

如果时区不是问题

如果你对在Redis中存储什么值没有硬性要求，并且只想在你迟到time.Time时实例化一个HGET值，你可以存储时间Unix秒。这样您也不必实现 RedisScan。

一旦 HGET 返回 unix 秒，您可以使用 time.Unix() 实例化 Time 值：

type Data struct {
    Timestamp time.Time
}

func (r *RedisRepo) Write(data Data,key String) error {
    conn := r.pool.Get()
    defer conn.Close()
    _,"hash",data.Timestamp.UTC().Unix())  
    return err  
}

func (r *RedisRepo) Read(key string) (*Data,error) {
    var data Data
    conn := r.pool.Get()
    defer conn.Close()
    secs,err := redis.Int64(conn.Do("HGET",err
    }
    return &Data{Timestamp: time.Unix(secs,0).UTC()},nil
}

考虑到这不考虑时区。 time.Unix() 返回本地时间（您的服务器之一）。

如果考虑时区

@mh-cbon 建议的一个简单解决方案是将时间格式化为符合 RFC3339 的字符串。这样你就可以在标准库的帮助下格式化/解析它：

func (r *RedisRepo) Write(data Data,data.Timestamp.Format(time.RFC3339))
    return err 
}

func (r *RedisRepo) Read(key string) (*Data,error) {
    var data Data
    conn := r.pool.Get()
    defer conn.Close()
    raw,_ := redis.String(conn.Do("HGET",key))
    parsed,_ := time.Parse(time.RFC3339,raw)
    return &Data{Timestamp: parsed},nil
}

作为替代方案，您可以将 time.Location 字符串表示与 Unix 秒一起存储，例如作为 JSON 对象，然后：

type RedisTimestamp struct {
    Loc         string `json:"loc"`
    UnixSeconds int64  `json:"unix"`
}

func (r *RedisRepo) Write(data Data,key String) error {
    // ...

    rts := RedisTimestamp{
        Loc:         data.Timestamp.Location().String(),UnixSeconds: data.Timestamp.Unix(),}
    jsonStr,_ := json.Marshal(rts)
    _,jsonStr)  
    return err   
}

func (r *RedisRepo) Read(key string) (*Data,error) {
    // ...
    ts := RedisTimestamp{}
    rawjson,err := redis.Bytes(conn.Do(/* ... */))
    _ = json.Unmarshal(rawjson,&ts)

    loc,_ := time.LoadLocation(ts.Loc)
    t := time.Unix(ts.UnixSeconds,0).In(loc)

    return &Data{Timestamp: t},nil

^^^（实际上不要忽略代码中的错误）

关于 time.LoadLocation，如果您的应用在没有时区数据库的服务器上运行，you can embed it since Go 1.15

import _ "time/tzdata"

goredigoredis