Go 语言中使用 Redis Pipeline 提升批量操作性能

闻溪

发布时间：2026-10-15| 4人浏览过

原创

通过介绍 Redis 的 Round Trip Time (RTT) 机制，阐述 Pipeline 在批量操作中的优势，并给出 Go 语言下使用 go-redis 进行集群兼容及错误处理的完整示例。

Pipeline 的原理与价值

在传统模式下，Redis 客户端每执行一条命令都需要经历“发送命令 → 命令排队 → 命令执行 → 返回结果”四个步骤，这一过程称为 Round trip time (RTT)。

虽然 mget、mset 等聚合命令能减少部分 RTT，但大多数 Redis 命令并不支持批量操作，导致高频请求会消耗大量网络 IO 时间。Pipeline 正是为了解决此问题而生：它将多个命令在客户端本地缓冲，一次性发送给服务器，从而大幅降低系统调用次数和网络延迟，显著提升整体吞吐量。

基础用法与注意事项

Pipeline 的核心在于先构建管道对象，追加命令，最后统一执行。以下是一个简单的删除操作示例：

pipe := Redis.Pipeline()
pipe.Del(context.Background(), "test1")
pipe.Del(context.Background(), "test2")
ret, err := pipe.Exec(context.Background())
fmt.Println(ret, err)

重要提示：若 Redis 采用集群部署，直接使用单一 Pipeline 可能引发跨节点访问错误。因为 Pipeline 中的 Key 可能分布在不同的 Node 上，此时需对 Key 进行分片处理或改用 Cluster 专用的 Pipeline 接口。

第1步：初始化 Redis 客户端

在应用启动时建立连接池并保持心跳检测，确保服务可用性。

package client

import (
	"github.com/go-redis/redis"
	"github.com/sirupsen/logrus"
)

var MainRDS *redis.Client

func init() {
	ConnectRedis()
}

func ConnectRedis() {
	// 实际环境中请替换为真实的地址和密码
	MainRDS = redis.NewClient(&redis.Options{
		Addr:     "127.0.0.1:6379",
		Password: "password",
	})
	if err := MainRDS.Ping().Err(); err != nil {
		logrus.Errorf("[ConnectRedis] connect redis error:%s", err.Error())
		panic("init client error")
	}
}

第2步：批量读取 Hash 字段实现

在实际业务中，往往需要根据一组 Key 获取特定字段。由于 HGet 不支持批量参数，必须借助 Pipeline 遍历执行。

关键注意点：

当某个 Key 不存在时，Redis 会返回 redis.Nil 错误，但这不代表整个 Pipeline 失败。
在处理结果集时，需要逐个解析返回值，忽略特定的 redis.Nil，以免误报异常。

// PipelineGetHashField 使用pipeline命令获取多个hash key的单个字段
func PipelineGetHashField(keyList []string, filed string) []string {
	pipeClient := client.MainRDS.Pipeline()
	
	// 1. 将命令加入缓存
	for _, key := range keyList {
		pipeClient.HGet(key, filed)
	}
	
	// 2. 一次性发送到 Redis
	res, err := pipeClient.Exec()
	
	// 如果 Exec 本身出错（非 Nil），通常是网络或语法问题
	if err != nil && err != redis.Nil {
		logrus.WithField("key_list", keyList).Errorf("Pipeline exec error: %s", err.Error())
	}
	
	valList := make([]string, 0, len(keyList))
	
	// 3. 遍历结果集
	for index, cmdRes := range res {
		var val string
		// HGet 返回的具体类型为 *redis.StringCmd
		cmd, ok := cmdRes.(*redis.StringCmd)
		if !ok {
			continue
		}
		
		// 4. 处理单个命令的执行结果
		v, e := cmd.Result()
		if e != nil {
			if e == redis.Nil {
				// Key 不存在视为空值，继续处理下一个
				valList = append(valList, "")
			} else {
				// 记录其他具体错误
				logrus.WithField("key", keyList[index]).Errorf("Get key error: %s", e.Error())
				valList = append(valList, "")
			}
		} else {
			valList = append(valList, v)
		}
	}
	return valList
}