go-redis Pipeline如何实现原子性？解决stringSliceCmd为空问题

go-redis的Pipelined回调仅用于注册待批量执行的Redis命令，此时所有命令并未发送至Redis服务器，stringSliceCmd只是一个未执行的命令占位对象，没有实际返回数据。你在回调内直接调用testHandleMessage处理它，自然拿不到有效结果。同时，把业务逻辑塞进Pipeline回调的写法，也不符合Pipeline的设计初衷。

正确流程是先通过Pipeline批量执行Redis命令，待所有命令执行完成后，再获取结果并处理业务逻辑：

var stringSliceCmd *redis.StringSliceCmd
// 第一步：通过Pipeline注册并执行Redis命令
_, err := RedisCli.Pipelined(ctx, func(pipe redis.Pipeliner) error {
    stringSliceCmd = pipe.LRange(ctx, "log-oss", 0, 1) // 注册LRange命令
    pipe.LTrim(ctx, "log-oss", 2, -1)                 // 注册LTrim命令
    return nil
})
// 检查Pipeline整体执行是否出错
if err != nil {
    log.Errorf("Pipeline执行失败: %v", err)
    return err
}
// 第二步：获取LRange的实际返回结果
msgSlice, err := stringSliceCmd.Result()
if err != nil {
    log.Errorf("获取LRange结果失败: %v", err)
    return err
}
// 第三步：处理消息
err = testHandleMessage(msgSlice)
if err != nil {
    log.Errorf("处理消息失败: %v", err)
    return err
}

默认Pipelined仅保证命令按顺序执行，但并非原子操作——若某条命令失败，后续命令仍会执行。如果需要严格原子性，改用TxPipelined（事务型Pipeline），Redis会将所有命令作为一个事务执行，要么全部成功，要么全部回滚：

var stringSliceCmd *redis.StringSliceCmd
// 使用TxPipelined开启事务
_, err := RedisCli.TxPipelined(ctx, func(pipe redis.Pipeliner) error {
    stringSliceCmd = pipe.LRange(ctx, "log-oss", 0, 1)
    pipe.LTrim(ctx, "log-oss", 2, -1)
    return nil
})
if err != nil {
    log.Errorf("事务Pipeline执行失败: %v", err)
    return err
}
// 后续获取结果、处理消息逻辑同前
msgSlice, err := stringSliceCmd.Result()
if err != nil {
    log.Errorf("获取LRange结果失败: %v", err)
    return err
}
err = testHandleMessage(msgSlice)
if err != nil {
    log.Errorf("处理消息失败: %v", err)
    return err
}

内容的提问来源于stack exchange，提问作者Kevin Tao