如何将时间限制在Golang to redigo (Redis)？

Question

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

问题是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)
}

Answer 1

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

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

如果您的目标是访问具有定义的名称和值的Redis散列，那么编写在这些定义和Go值之间进行转换的代码。下面是一个散列的示例，该散列定义了字段"timestamp“，其值为十进制编码的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, key string) error {
    conn := r.pool.Get()
    defer conn.Close()
    _, err := conn.Do("HSET", key, "timestamp", data.Timestamp.Format(time.RFC3339))
    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 string `redis:"timestamp"`
    }

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

上面的Read示例是为了便于扩展到多个字段而编写的。如果应用程序只需要访问单个字段，则使用对redis.Int64(conn.Do("HGET", key, "timestamp")或redis.String(conn.Do("HGET", key, "timestamp")的调用替换fields变量和ScanStruct无用信息