golang:goredis库pipeline使用方式

goredis库连接客户端

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: "******"})err := MainRDS.Ping().Err()if err != nil {logrus.Infof("[ConnectRedis]connect redis error:%s", err.Error())panic("init client error")}
}

pipeline命令的使用

PS:如果redis采用了集群部署，不可以直接使用pipeline命令进行操作，因为访问的key可能并不在同一个节点上

// PipelineGetHashField 使用pipeline命令获取多个hash key的单个字段
// keyList，需要获取的hash key列表
// field 需要获取的字段值
func PipelineGetHashField(keyList []string,filed string) []string {pipeClient :=client.MainRDS.Pipeline()for _, key := range keyList {pipeClient.HGet(key, filed)}res, err := pipeClient.Exec()if err != nil {if err != redis.Nil {logrus.WithField("key_list", keyList).Errorf("[PipelineGetHashField] get from redis error:%s", err.Error())}/********** ！！！！！！！！！！*************/// 注意这里如果某一次获取时出错（常见的redis.Nil），返回的err即不为空// 如果需要处理redis.Nil为默认值，此处不能直接return}valList := make([]string, 0, len(keyList))for index, cmdRes := range res {var val string// 此处断言类型为在for循环内执行的命令返回的类型,上面HGet返回的即为*redis.StringCmd类型// 处理方式和直接调用同样处理即可cmd, ok := cmdRes.(*redis.StringCmd) if ok {val,err = cmd.Result()if err != nil {logrus.WithField("key",keyList[index]).Errorf("[PipelineGetHashField] get key error:%s",err.Error())}}valList = append(valList, val)}return valList
}

golang:goredis库pipeline使用方式相关推荐

golang常用库之-操作redis go-redis/redis库、 go-redsync/redsync库（redis分布式锁）
文章目录 golang常用库之-操作redis go-redis/redis库. go-redsync/redsync库(redis分布式锁) 一.什么是go-redis/redis库 go-redi ...
Golang 标准库log的实现
原创作品,允许转载,转载时请务必以超链接形式标明文章原始出处 .作者信息和本声明.否则将追究法律责任.http://gotaly.blog.51cto.com/8861157/1406905 前一篇 ...
golang 标准库间依赖的可视化展示
简介国庆看完 << Go 语言圣经 >>,总想做点什么,来加深下印象.以可视化的方式展示 golang 标准库之间的依赖,可能是一个比较好的切入点.做之前,简单搜了下相关的内 ...
viper4android io错误,golang常用库之配置文件解析库-viper使用详解
一.viper简介 viper 配置管理解析库,是由大神 Steve Francia 开发,他在google领导着 golang 的产品开发,他也是 gohugo.io 的创始人之一,命令行解析库 c ...
GoLang各种库（转）
原文出处:https://www.jianshu.com/p/6a147fc00721 golang用于创建和发送电子邮件的库 douceur - HTML 邮件中的内联 CSS email - 一个 ...
最详细的golang + 私库（gitlab gitee）模块开发这一篇文章解决所有问题
golang独立模块开发流程大纲基本概念与背景模块开发流程总结基于gitee私库基于gitlab私库基本概念与背景 java项目开发过程中,有不同的项目组,有的项目组做业务开发,有的项目组 ...
golang常用库之mapstructure包 | 多json格式情况解析、GO json 如何转化为 map 和 struct、Go语言结构体标签（Struct Tag）
文章目录 golang常用库之mitchellh/mapstructure包 | go将map转换为struct 一.msgpack 二.背景三.多json格式情况解析使用思路四.mapstruc ...
「GoCN酷Go推荐」基于泛型的 Golang lodash 库 — samber/lo
近日,Go 核心开发团队终于宣布了 Go 1.18 正式版本的发布!这是一个大家期待很久的版本!Go 1.18 包含大量新功能:模糊测试.性能改进.工作区等,以及 Go 语言开源以来最大的一次语法特性 ...
Golang常用库学习
Golang常用库学习标准库fmt 标准库log 标准库time 标准库strconv 标准库 testing 单元测试简单测试单元测试覆盖率统计表格驱动测试性能(基准)测试标准库 os ...
Golang标准库中的fmt
Golang标准库中的fmt fmt包实现了类似C语言printf和scanf的格式化I/O.主要分为向外输出内容和获取输入内容两大部分. 1. 向外输出标准库fmt提供了以下几种输出相关函数. P ...

golang:goredis库pipeline使用方式

goredis库连接客户端

pipeline命令的使用

golang:goredis库pipeline使用方式相关推荐

最新文章

热门文章