如何读取redis.Client.TxPipeline.Exec()响应？基于redis.v5批量获取哈希值

嘿，我来帮你搞定这个解析问题！从你给出的响应来看，你已经通过MULTI/EXEC批量执行了多个HGETALL命令，拿到了每个键对应的哈希表数据。下面是具体的解析方法，完全基于redis.v5的SDK来做，比直接解析字符串靠谱多了：

先理清楚你的执行流程 #

你应该是先收集了所有要查询的Redis键，然后在事务里逐个添加HGETALL命令，执行EXEC后得到了批量结果。在redis.v5里，我们不需要手动去解析那个打印出来的响应字符串，而是可以通过事务中的命令对象直接获取结构化数据。

具体代码实现 #

假设你已经有了要查询的键列表，按照这个步骤来：

import (
    "context"
    "github.com/go-redis/redis/v5"
)

func getAllHashValues(client *redis.Client, ctx context.Context, keys []string) (map[string]map[string]string, error) {
    // 1. 开启事务
    tx := client.Multi()
    
    // 2. 为每个键添加HGETALL命令，保存对应的命令对象
    var hashCmds []*redis.MapStringStringCmd
    for _, key := range keys {
        cmd := tx.HGetAll(key)
        hashCmds = append(hashCmds, cmd)
    }
    
    // 3. 执行事务
    _, err := tx.Exec(ctx)
    if err != nil {
        return nil, err
    }
    
    // 4. 解析每个命令的结果，构建键到哈希表的映射
    result := make(map[string]map[string]string, len(keys))
    for idx, cmd := range hashCmds {
        key := keys[idx]
        // 获取当前键对应的哈希表
        hashMap, err := cmd.Result()
        if err != nil {
            // 如果单个键查询出错（比如键不存在），可以选择跳过或者记录错误
            // 这里我们暂时跳过，你可以根据业务调整
            continue
        }
        result[key] = hashMap
    }
    
    return result, nil
}

关键说明 #

• 我们没有直接去解析EXEC返回的原始响应，而是通过保存的*redis.MapStringStringCmd对象调用Result()方法，直接拿到结构化的map[string]string，这是redis.v5 SDK提供的便捷方式，避免了手动解析的麻烦。
• 如果某个键不存在，HGetAll会返回一个空的map[string]string，而不是报错，除非Redis服务端出现异常。
• 事务执行失败时（比如连接问题），tx.Exec()会直接返回错误，这时候需要整体处理。

如果你已经拿到了原始响应切片 #

如果你的代码里已经拿到了EXEC返回的[]interface{}结果，也可以这样解析：

// 假设execResult是tx.Exec()返回的[]interface{}
result := make(map[string]map[string]string, len(keys))
for idx, item := range execResult {
    key := keys[idx]
    // 将interface{}类型断言为map[string]string
    hashMap, ok := item.(map[string]string)
    if !ok {
        // 类型断言失败，处理错误
        continue
    }
    result[key] = hashMap
}

不过更推荐第一种用命令对象的方式，因为SDK会帮你处理类型转换和错误，更可靠。

内容的提问来源于stack exchange，提问作者negi Yogi