将Golang中的哈希集合（HSET）时间转换为redigo（Redis）

今天golang学习网给大家带来了《将Golang中的哈希集合（HSET）时间转换为redigo（Redis）》，其中涉及到的知识点包括等等，无论你是小白还是老手，都适合看一看哦~有好的建议也欢迎大家在评论留言，若是看完有所收获，也希望大家能多多点赞支持呀！一起加油学习~

我正在使用 redigo 在 redigo 中存储和检索数据。 我有一个结构体，其中包含时间之后的类型定义。我想在 redis 中使用 hset 存储结构 data 。我有一个类型定义，可以通过将函数 redisscan 添加到我的 timestamp 类型来使用 scanstruct。

问题在于，redis 将 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 值之间进行转换的代码。下面是一个哈希示例，该哈希定义为具有字段“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")

如果你要向redis的哈希集中添加一些东西，你至少需要有这三个值。

1. 哈希集的名称
2. 哈希集的键（稍后也可以添加额外的键）
3. 哈希集的值

最好的编码方法是在 redigo 库上添加一个包装器来抽象实现并将依赖项注入到您的代码中。

// Not the best way
func dummy(){

    redisConn := redisCache.pool.Get()
    defer redisConn.Close()
    response, err := redisConn.Do("HSET", args...)

}

type Implementation struct {
    RedisImplementation RedigoAbstractionConnection
}

// Best way
func (i Implementation) AddDataToRedisHashSet(hashName string, key string, value string) error {
    var args = []interface{}{hashName}
    args = append(args, key, value)
    _, err := i.RedisImplementation.HSET(args...) // Returns an interface and an error
    if err != nil{
        // Handle Error
    }
    return nil
}

今天关于《将Golang中的哈希集合（HSET）时间转换为redigo（Redis）》的内容介绍就到此结束，如果有什么疑问或者建议，可以在golang学习网公众号下多多回复交流；文中若有不正之处，也希望回复留言以告知！