golang redis 管道的实现

go get github.com/redis/go-redis/v9

package main
import (
	"context"
	"fmt"
	"github.com/redis/go-redis/v9"
)
func main() {
	// 1. 连接Redis
	client := redis.NewClient(&redis.Options{
		Addr:     "localhost:6379", // Redis地址
		Password: "",               // 密码（无密码则为空）
		DB:       0,                // 数据库编号
	})
	// 2. 创建上下文（用于控制超时/取消）
	ctx := context.Background()
	// 3. 创建管道对象（此时命令尚未执行）
	pipe := client.Pipeline()
	// 4. 向管道中添加多个命令（这些命令会被暂存，等待批量发送）
	// 注意：每个命令返回的是"未来结果"（*redis.Cmd），需在执行后获取实际值
	setCmd := pipe.Set(ctx, "name", "redis-pipeline", 0) // 设置键值对（过期时间0表示永久）
	getCmd := pipe.Get(ctx, "name")                      // 获取键值
	incrCmd := pipe.Incr(ctx, "counter")                 // 自增计数器
	// 5. 执行管道中的所有命令（一次性发送到服务器，并接收所有响应）
	// 返回值是所有命令的结果列表（与添加顺序一致）
	_, err := pipe.Exec(ctx)
	if err != nil {
		fmt.Printf("管道执行失败: %v\n", err)
		return
	}
	// 6. 从"未来结果"中获取实际值（需检查每个命令的错误）
	// 获取Set命令的结果
	if err := setCmd.Err(); err != nil {
		fmt.Printf("Set命令失败: %v\n", err)
	} else {
		fmt.Println("Set结果:", setCmd.Val()) // 输出：OK
	}
	// 获取Get命令的结果
	name, err := getCmd.Result() // Result() 等价于 Val() + Err()
	if err != nil {
		fmt.Printf("Get命令失败: %v\n", err)
	} else {
		fmt.Println("Get结果:", name) // 输出：redis-pipeline
	}
	// 获取Incr命令的结果
	counter, err := incrCmd.Uint64()
	if err != nil {
		fmt.Printf("Incr命令失败: %v\n", err)
	} else {
		fmt.Println("Incr结果:", counter) // 输出：1（首次自增）
	}
}

go get github.com/gomodule/redigo/redis

package main
import (
	"fmt"
	"github.com/gomodule/redigo/redis"
)
func main() {
	// 1. 连接Redis（获取连接对象）
	conn, err := redis.Dial("tcp", "localhost:6379")
	if err != nil {
		fmt.Printf("连接Redis失败: %v\n", err)
		return
	}
	defer conn.Close() // 退出前关闭连接
	// 2. 向管道发送多个命令（Send方法仅将命令暂存到本地缓冲区）
	// 格式：Send("命令名", 参数1, 参数2, ...)
	if err := conn.Send("SET", "name", "redigo-pipeline"); err != nil {
		fmt.Printf("发送SET命令失败: %v\n", err)
		return
	}
	if err := conn.Send("GET", "name"); err != nil {
		fmt.Printf("发送GET命令失败: %v\n", err)
		return
	}
	if err := conn.Send("INCR", "counter"); err != nil {
		fmt.Printf("发送INCR命令失败: %v\n", err)
		return
	}
	// 3. 刷新缓冲区，将所有命令一次性发送到Redis服务器
	if err := conn.Flush(); err != nil {
		fmt.Printf("刷新命令失败: %v\n", err)
		return
	}
	// 4. 依次接收每个命令的响应（顺序与发送顺序一致）
	// 接收SET命令的响应
	setResp, err := redis.String(conn.Receive())
	if err != nil {
		fmt.Printf("接收SET响应失败: %v\n", err)
		return
	}
	fmt.Println("SET结果:", setResp) // 输出：OK
	// 接收GET命令的响应
	getResp, err := redis.String(conn.Receive())
	if err != nil {
		fmt.Printf("接收GET响应失败: %v\n", err)
		return
	}
	fmt.Println("GET结果:", getResp) // 输出：redigo-pipeline
	// 接收INCR命令的响应
	incrResp, err := redis.Int64(conn.Receive())
	if err != nil {
		fmt.Printf("接收INCR响应失败: %v\n", err)
		return
	}
	fmt.Println("INCR结果:", incrResp) // 输出：1（首次自增）
}