如何在高朗到雷迪戈（Redis）的HSET时间？

Question

我正在使用 redigo 在 redigo 中存储和检索数据。我有一个结构，其中包含一个类型定义。我想在 Redis 中使用来存储结构。我有一个类型定义，可以通过向我的类型添加一个函数来使用。DataHSETScanStructRedisScanTimestamp问题在于 Redis 将 存储在时间字段之后。您无法从这些字段创建新的 Time 对象，因此这相当无用。序列化 redigo 结构的正确方法是什么？Timestampext, wall, loctype Timestamp time.Timefunc (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.ScanStructArgs.AddFlat

解决问题的方法取决于您的目标是什么。如果您的目标是加载和保存结构，而不是访问 Redis 哈希，请参阅将通用结构保存到 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, 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

}

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