备案控制台
探索云世界
开发者社区 Golang语言社区 文章 正文

go语言使用redis（redigo）

2019-01-07 3391
版权
版权声明：
本文内容由阿里云实名注册用户自发贡献，版权归原作者所有，阿里云开发者社区不拥有其著作权，亦不承担相应法律责任。具体规则请查看《 阿里云开发者社区用户服务协议》和 《阿里云开发者社区知识产权保护指引》。如果您发现本社区中有涉嫌抄袭的内容，填写 侵权投诉表单进行举报，一经查实，本社区将立刻删除涉嫌侵权内容。
本文涉及的产品
云数据库 Redis 版，社区版 2GB
推荐场景：
搭建游戏排行榜
简介： go的redis client用的比较多两个包是redix和redigo，因为beego cache模块里redis使用的是redigo，所以我也就使用这个包了。因为代码内容偏多，结构不清晰，不方便阅读，最后整理成一份思维导图，便于学习。

go的redis client用的比较多两个包是redix和redigo，因为beego cache模块里redis使用的是redigo，所以我也就使用这个包了。因为代码内容偏多，结构不清晰，不方便阅读，最后整理成一份思维导图，便于学习。当把整体分析，会发现提供给开发者使用的内容非常巧妙。

image

点击下载

Demo:

 1package main
 2
 3import (
 4    "fmt"
 5    "github.com/gomodule/redigo/redis"
 6    "log"
 7)
 8
 9func main() {
10    c1, err := redis.Dial("tcp", "127.0.0.1:6379")
11    if err != nil {
12        log.Fatalln(err)
13    }
14    defer c1.Close()
15    c2, err := redis.DialURL("redis://127.0.0.1:6379")
16    if err != nil {
17        log.Fatalln(err)
18    }
19    defer c2.Close()
20
21
22    rec1, err := c1.Do("Get", "name")
23    fmt.Println(string(rec1.([]byte)))
24
25    c2.Send("Get", "name")
26    c2.Flush()
27    rec2, err := c2.Receive()
28    fmt.Println(string(rec2.([]byte)))
29}

下面内容是更加详细的源码分析

提供给开发者使用的内容
（1）变量
（2）常量
（3）新类型
（4）接口
（5）结构体
（6）函数

1、变量
var ErrNil = errors.New("redigo: nil returned")
2、常量
3、新类型
（1）type Args []interface{}
（2）type Error string
4、接口
（1）Conn
（2）ConnWithTimeout
（3）Scanner
（4）Argument
5、结构体
（1）DialOption
（2）Pool
（3）PoolStats
（4）Subscription
（5）PubSubConn
（6）Message
（7）Script
（8）Pong
6、函数
（1）func NewPool(newFn func() (Conn, error), maxIdle int) *Pool
（2）func NewScript(keyCount int, src string) *Script
（3）func NewLoggingConn(conn Conn, logger *log.Logger, prefix string) Conn
（4）func NewLoggingConnFilter(conn Conn, logger log.Logger, prefix string, skip func(cmdName string) bool) Conn
（5）func DoWithTimeout(c Conn, timeout time.Duration, cmd string, args ...interface{}) (interface{}, error)
（6）func DoWithTimeout(c Conn, timeout time.Duration, cmd string, args ...interface{}) (interface{}, error)
（7）func Int(reply interface{}, err error) (int, error)
（8）func Int64(reply interface{}, err error) (int64, error)
（9）func Uint64(reply interface{}, err error) (uint64, error)
（10）func Float64(reply interface{}, err error) (float64, error)
（11）func String(reply interface{}, err error) (string, error)
（12）func Bytes(reply interface{}, err error) ([]byte, error)
（13）func Bool(reply interface{}, err error) (bool, error)
（14）func MultiBulk(reply interface{}, err error) ([]interface{}, error)
（15）func Values(reply interface{}, err error) ([]interface{}, error)
（16）func Float64s(reply interface{}, err error) ([]float64, error)
（17）func Strings(reply interface{}, err error) ([]string, error)
（18）func ByteSlices(reply interface{}, err error) ([][]byte, error)
（19）func Int64s(reply interface{}, err error) ([]int64, error)
（20）func Ints(reply interface{}, err error) ([]int, error)
（21）func StringMap(result interface{}, err error) (map[string]string, error)
（22）func IntMap(result interface{}, err error) (map[string]int, error)
（23）func Int64Map(result interface{}, err error) (map[string]int64, error)
（24）func Positions(result interface{}, err error) ([][2]float64, error)
（25）func DialTimeout(network, address string, connectTimeout, readTimeout, writeTimeout time.Duration) (Conn, error)
（26）func DialReadTimeout(d time.Duration) DialOption
（27）func DialWriteTimeout(d time.Duration) DialOption
（28）func DialConnectTimeout(d time.Duration) DialOption
（29）func DialKeepAlive(d time.Duration) DialOption
（30）func DialNetDial(dial func(network, addr string) (net.Conn, error)) DialOption
（31）func DialDatabase(db int) DialOption
（32）func DialPassword(password string) DialOption
（33）func DialTLSConfig(c *tls.Config) DialOption
（34）func DialTLSSkipVerify(skip bool) DialOption

一、变量
var ErrNil = errors.New("redigo: nil returned")
暴露给开发者的目的是，因为从redis服务器获取数据的时候可能遇到值为空的情况。
二、常量
三、新类型
（1）type Args []interface{}

  1type Args []interface{}
  2
  3func (args Args) Add(value ...interface{}) Args
  4// Add是直接将值追加到args后面的结果返回，但是并不会修改到args
  5func (args Args) AddFlat(v interface{}) Args 
  6// AddFlat根据值的类型存储，分为以下五种情况：Struct、Slice、Map、Ptr、其他类型
  7（1）Struct：
  8package main
  9
 10import (
 11    "fmt"
 12    "github.com/gomodule/redigo/redis"
 13)
 14
 15type Ints struct {
 16    A int
 17    b int
 18    C float32
 19}
 20
 21func (Ints)Add() {
 22    fmt.Println(123)
 23}
 24
 25func main() {
 26    i := Ints{1,2,1.2}
 27    args := redis.Args{1,2,3}
 28    args1 := args.AddFlat(i)
 29    fmt.Println(args, len(args))
 30    fmt.Println(args1, len(args1))
 31}
 32输出：
 33[1 2 3] 3
 34[1 2 3 A 1 C 1.2] 7
 35（2）Slice：
 36package main
 37
 38import (
 39    "fmt"
 40    "github.com/gomodule/redigo/redis"
 41)
 42
 43func main() {
 44    i := []int{1,2,12}
 45    args := redis.Args{1,2,3}
 46    args1 := args.AddFlat(i)
 47    fmt.Println(args, len(args))
 48    fmt.Println(args1, len(args1))
 49}
 50输出：
 51[1 2 3] 3
 52[1 2 3 1 2 12] 6
 53（3）Map：
 54package main
 55
 56import (
 57    "fmt"
 58    "github.com/gomodule/redigo/redis"
 59)
 60
 61func main() {
 62    i := map[int]string{1:"你好",2:"测试"}
 63    args := redis.Args{1,2,3}
 64    args1 := args.AddFlat(i)
 65    fmt.Println(args, len(args))
 66    fmt.Println(args1, len(args1))
 67}
 68输出：
 69[1 2 3] 3
 70[1 2 3 1 你好 2 测试] 7
 71（4）Prt
 72package main
 73
 74import (
 75    "fmt"
 76    "github.com/gomodule/redigo/redis"
 77)
 78
 79func main() {
 80    a := 123
 81    i := &a
 82    args := redis.Args{1,2,3}
 83    args1 := args.AddFlat(i)
 84    fmt.Println(args, len(args))
 85    fmt.Println(args1, len(args1))
 86}
 87输出：
 88[1 2 3] 3
 89[1 2 3 0xc00008a2d8] 4
 90（5）其他类型：
 91package main
 92
 93import (
 94    "fmt"
 95    "github.com/gomodule/redigo/redis"
 96)
 97
 98type Int int8
 99
100func main() {
101    a := 123
102    b := Int(8)
103    args := redis.Args{1,2,3}
104    args1 := args.AddFlat(a)
105    args1 = args1.AddFlat(b)
106    fmt.Println(args, len(args))
107    fmt.Println(args1, len(args1))
108}
109输出：
110[1 2 3] 3
111[1 2 3 123 8] 5

（2）type Error string

1type Error string
2func (err Error) Error() string { return string(err) }

四、接口
（1）Conn
（2）ConnWithTimeout
（3）Scanner
（4）Argument
五、结构体
（1）DialOption
源码：

1type DialOption struct {
2    f func(*dialOptions)
3}
4

作用：该结构体是被设计成 当创建与redis服务器连接时，进行参数设置。
与该结构体有关的函数：

 1（1）func DialReadTimeout(d time.Duration) DialOption
 2设置读超时时间
 3（2）func DialWriteTimeout(d time.Duration) DialOption
 4设置读超时时间
 5（3）func DialConnectTimeout(d time.Duration) DialOption
 6设置连接超时时间
 7（4）func DialKeepAlive(d time.Duration) DialOption 
 8（5）func DialNetDial(dial func(network, addr string) (net.Conn, error)) DialOption
 9（6）func DialDatabase(db int) DialOption
10设置连接数据库
11（7）func DialPassword(password string) DialOption
12设置连接redis密码
13（8）func DialTLSConfig(c *tls.Config) DialOption
14设置TLS配置信息
15（9）func DialTLSSkipVerify(skip bool) DialOption
16是否跳过TLS验证
17（10）func DialUseTLS(useTLS bool) DialOption
18是否使用TLS
19

（2）Pool
源码：

 1type Pool struct {
 2    Dial func() (Conn, error)
 3    TestOnBorrow func(c Conn, t time.Time) error
 4    MaxIdle int
 5    MaxActive int
 6    IdleTimeout time.Duration
 7    Wait bool
 8    MaxConnLifetime time.Duration
 9    chInitialized uint32
10    mu     sync.Mutex 
11    closed bool 
12    active int 
13    ch     chan struct{} 
14    idle   idleList
15}

作用：用来管理redis连接池
相关函数：

 1（1）func NewPool(newFn func() (Conn, error), maxIdle int) *Pool
 2            创建一个连接池对象
 3（2）func (p *Pool) Get() Conn
 4            获取一个连接 
 5（3）func (p *Pool) Stats() PoolStats
 6            获取池的状态
 7（4）func (p *Pool) ActiveCount() int
 8            获取存活数量
 9（5）func (p *Pool) IdleCount() int
10            获取空闲数量
11（6）func (p *Pool) Close() error
12            关闭
13

（3）PoolStats
源码：

1type PoolStats struct {
2    ActiveCount int 
3    IdleCount int
4}

作用：记录redis池中存活连接数量和空闲连接数
（4）Subscription
源码：

1type Subscription struct {
2    Kind string          
3    Channel string  
4    Count int
5}

作用：Subscription用于订阅或取消订阅通知。
相关函数：

Demo：

 1package main
 2
 3import (
 4    "fmt"
 5    "github.com/gomodule/redigo/redis"
 6    "log"
 7    "reflect"
 8)
 9
10func main() {
11    rc, err := redis.Dial("tcp", "127.0.0.1:6379")
12    if err != nil {
13        log.Fatalln(err)
14    }
15    defer rc.Close()
16
17    rc.Send("SUBSCRIBE", "example")
18    rc.Flush()
19    for {
20        reply, err := redis.Values(rc.Receive())
21        if err != nil {
22            fmt.Println(err)
23        }
24        if len(reply) == 3 {
25            if reflect.TypeOf(reply[2]).String() == "[]uint8" {
26                fmt.Println(string(reply[2].([]byte)))
27            }
28        }
29    }
30}

（5）PubSubConn
源码：


1type PubSubConn struct {
2    Conn Conn
3}

相关函数：

1（1）func (c PubSubConn) Subscribe(channel ...interface{}) error
 2            订阅给定的一个或多个频道的信息。
 3（2）func (c PubSubConn) PSubscribe(channel ...interface{}) error
 4            订阅一个或多个符合给定模式的频道。
 5（3）func (c PubSubConn) Unsubscribe(channel ...interface{}) error
 6            指退订给定的频道。
 7（4）func (c PubSubConn) PUnsubscribe(channel ...interface{}) error
 8            退订所有给定模式的频道。
 9（5）func (c PubSubConn) Ping(data string) error 
10            测试客户端是否能够继续连通
11（6）func (c PubSubConn) Receive() interface{}
12             获取回复信息
13（7）func (c PubSubConn) ReceiveWithTimeout(timeout time.Duration) interface{}
14             在指定时间内获取时间
15（8）func (c PubSubConn) Close() error 
16              关闭
17

（6）Message
源码：


1type Message struct {
2    Channel string    // 频道名称
3    Pattern string      // 频道模式
4    Data []byte            // 数据
5}

（7）Script
源码：

1type Script struct {
2    keyCount int
3    src               string
4    hash           string
5}

相关函数：

1（1）func NewScript(keyCount int, src string) *Script 
2（2）func (s *Script) Hash() string
3（3）func (s *Script) Do(c Conn, keysAndArgs ...interface{}) (interface{}, error) 
4（4）func (s *Script) SendHash(c Conn, keysAndArgs ...interface{}) error 
5（5）func (s *Script) Send(c Conn, keysAndArgs ...interface{}) error 
6（6）func (s *Script) Load(c Conn) error
7

（8）Pong
源码：

1type Pong struct {
2    Data string
3}

(6)函数

 1（1）func NewPool(newFn func() (Conn, error), maxIdle int) *Pool
 2（2）func NewScript(keyCount int, src string) *Script 
 3（3）func NewLoggingConn(conn Conn, logger *log.Logger, prefix string) Conn
 4（4）func NewLoggingConnFilter(conn Conn, logger *log.Logger, prefix string, skip func(cmdName string) bool) Conn
 5（5）func DoWithTimeout(c Conn, timeout time.Duration, cmd string, args ...interface{}) (interface{}, error)
 6（6）func DoWithTimeout(c Conn, timeout time.Duration, cmd string, args ...interface{}) (interface{}, error)
 7（7）func Int(reply interface{}, err error) (int, error)
 8（8）func Int64(reply interface{}, err error) (int64, error)
 9（9）func Uint64(reply interface{}, err error) (uint64, error)
10（10）func Float64(reply interface{}, err error) (float64, error)
11（11）func String(reply interface{}, err error) (string, error)
12（12）func Bytes(reply interface{}, err error) ([]byte, error)
13（13）func Bool(reply interface{}, err error) (bool, error) 
14（14）func MultiBulk(reply interface{}, err error) ([]interface{}, error) 
15（15）func Values(reply interface{}, err error) ([]interface{}, error)
16（16）func Float64s(reply interface{}, err error) ([]float64, error)
17（17）func Strings(reply interface{}, err error) ([]string, error) 
18（18）func ByteSlices(reply interface{}, err error) ([][]byte, error)
19（19）func Int64s(reply interface{}, err error) ([]int64, error)
20（20）func Ints(reply interface{}, err error) ([]int, error)
21（21）func StringMap(result interface{}, err error) (map[string]string, error) 
22（22）func IntMap(result interface{}, err error) (map[string]int, error)
23（23）func Int64Map(result interface{}, err error) (map[string]int64, error)
24（24）func Positions(result interface{}, err error) ([]*[2]float64, error)
25（25）func DialTimeout(network, address string, connectTimeout, readTimeout, writeTimeout time.Duration) (Conn, error) 
26（26）func DialReadTimeout(d time.Duration) DialOption
27（27）func DialWriteTimeout(d time.Duration) DialOption
28（28）func DialConnectTimeout(d time.Duration) DialOption
29（29）func DialKeepAlive(d time.Duration) DialOption 
30（30）func DialNetDial(dial func(network, addr string) (net.Conn, error)) DialOption
31（31）func DialDatabase(db int) DialOption
32（32）func DialPassword(password string) DialOption
33（33）func DialTLSConfig(c *tls.Config) DialOption
34（34）func DialTLSSkipVerify(skip bool) DialOption
35

经过学习源码发现，这些顶尖的设计者与我们普通开发者的区别在于，他们包设计非常巧妙，以及只把有必要的内容提供给开发者。

原文发布时间为：2019-1-5
本文作者：Golang语言社区
本文来自云栖社区合作伙伴“ Golang语言社区”，了解相关信息可以关注“Golangweb”微信公众号

文章标签：
云数据库 Redis 版
NoSQL
Redis
Go
开发者
关键词：
Go语言
Go redis
云数据库 Redis 版go
云数据库 Redis 版语言
相关实践学习
基于Redis实现在线游戏积分排行榜
本场景将介绍如何基于Redis数据库实现在线游戏中的游戏玩家积分排行榜功能。
云数据库 Redis 版使用教程
云数据库Redis版是兼容Redis协议标准的、提供持久化的内存数据库服务，基于高可靠双机热备架构及可无缝扩展的集群架构，满足高读写性能场景及容量需弹性变配的业务需求。 产品详情：https://www.aliyun.com/product/kvstore     ------------------------------------------------------------------------- 阿里云数据库体验：数据库上云实战 开发者云会免费提供一台带自建MySQL的源数据库 ECS 实例和一台目标数据库 RDS实例。跟着指引，您可以一步步实现将ECS自建数据库迁移到目标数据库RDS。 点击下方链接，领取免费ECS&RDS资源，30分钟完成数据库上云实战！https://developer.aliyun.com/adc/scenario/51eefbd1894e42f6bb9acacadd3f9121?spm=a2c6h.13788135.J_3257954370.9.4ba85f24utseFl
技术小能手
目录
相关文章
极客李华
|
10天前
|
Go
go语言中的数据类型
go语言中的数据类型
极客李华
11 0
技术蜜糖罐
|
15天前
|
Go 开发者
掌握Go语言：Go语言结构体，精准封装数据，高效管理实体对象（22）
掌握Go语言：Go语言结构体，精准封装数据，高效管理实体对象（22）
技术蜜糖罐
21 0
技术蜜糖罐
|
15天前
|
安全 Go
掌握Go语言：Go语言通道，并发编程的利器与应用实例（20）
掌握Go语言：Go语言通道，并发编程的利器与应用实例（20）
技术蜜糖罐
26 0
技术蜜糖罐
|
15天前
|
存储 缓存 安全
掌握Go语言：Go语言中的字典魔法，高效数据检索与应用实例解析（18）
掌握Go语言：Go语言中的字典魔法，高效数据检索与应用实例解析（18）
技术蜜糖罐
33 0
fensnote
|
15天前
|
Go
使用Go语言发邮件
使用Go语言发邮件
fensnote
20 2
憧憬blog
|
27天前
|
缓存 安全 Java
Go语言小细节
Go语言小细节
憧憬blog
36 0
wljslmz
|
1月前
|
存储 安全 Go
Go语言中如何判断map中是否包含某个key？
【2月更文挑战第24天】
wljslmz
46 2
wljslmz
|
1月前
|
安全 编译器 Go
Go语言中的int和int32：同一个概念吗？
【2月更文挑战第24天】
wljslmz
55 3
技术蜜糖罐
|
15天前
|
存储 安全 Go
掌握Go语言：Go语言类型转换，无缝处理数据类型、接口和自定义类型的转换细节解析（29）
掌握Go语言：Go语言类型转换，无缝处理数据类型、接口和自定义类型的转换细节解析（29）
技术蜜糖罐
20 0
程序三两行
|
9天前
|
存储 Java 编译器
go语言基础语法
go语言基础语法
程序三两行
28 1

Golang语言社区

热门文章

最新文章

  • 1
    微软开抢年收入上亿美元的 Redis 饭碗？开源性能遥遥领先的 Garnet：无需修改，Redis 客户端可直接接入
  • 2
    Docker安装详细步骤及相关环境安装配置（mysql、jdk、redis、自己的私有仓库Gitlab 、C和C++环境以及Nginx服务代理）
  • 3
    springboot中集成redis，二次封装成工具类
  • 4
    SpringBoot集成Redis
  • 5
    Redis与Python的完美结合：实现高效数据交互和应用场景全解析
  • 6
    【Redis性能瓶颈揭秘】「调优系列」深入分析热Key的排查策略和解决方案
  • 7
    使用innoSetup将mysql+nginx+redis+jar包打包成windows安装包
  • 8
    在Docker中设置Redis的密码
  • 9
    深入解析Redis：一种快速、高效的键值存储系统
  • 10
    【Redis深度专题】「踩坑技术提升」一文教会你如何在支持Redis在低版本Jedis情况下兼容Redis的ACL机制
  • 1
    什么是协程（Goroutine）？探索Go语言并发的奇妙世界
    31
  • 2
    Go语言中如何判断map中是否包含某个key？
    46
  • 3
    Go语言中tag的用处及详细介绍
    33
  • 4
    Go语言中的int和int32：同一个概念吗？
    55
  • 5
    Go语言的接口比较：两个interface能否比较？
    71
  • 6
    Go语言GC(垃圾回收)的工作原理
    22
  • 7
    Go语言协程泄漏(Goroutine Leak)：原因和解决方案
    37
  • 8
    Go面向对象是如何实现的？
    27
  • 9
    Go中的GMP状态详解
    30
  • 10
    Go语言在身份认证与访问控制中的应用
    317

    • 相关课程

    更多
  • Go语言核心编程 - 数据结构和算法
  • Go语言核心编程 - 基础语法、数组、切片、Map
  • Go语言核心编程 - 面向对象、文件、单元测试、反射、TCP编程
  • Go语言完全自学手册图文教程
  • 云数据库 Redis 版使用教程
  • Redis数据库入门

    • 相关电子书

    更多
  • Go语言路上踩过的坑
  • gohbase ：HBase go客户端
  • Go构建日请求千亿级微服务实践

    • 相关实验场景

    更多
  • Tair for Redis数据闪回：任意时间点数据恢复
  • 如何开通Redis的专属集群
  • 基于Redis实现在线游戏积分排行榜
    • 下一篇
    阿里云oss简介和使用流程
    为什么选择阿里云什么是云计算全球基础设施技术领先稳定可靠安全合规分析师报告
    产品和定价全部产品免费试用产品动态产品定价价格计算器云上成本管理
    解决方案技术解决方案
    文档与社区文档开发者社区天池大赛培训与认证
    权益中心免费试用高校计划企业扶持计划推荐返现计划
    支持与服务基础服务企业增值服务迁云服务官网公告健康看板信任中心
    关注阿里云
    关注阿里云公众号或下载阿里云APP，关注云资讯，随时随地运维管控云服务
    阿里云APP阿里云微信
    联系我们：4008013260
    法律声明Cookies政策廉正举报安全举报联系我们加入我们
    阿里巴巴集团淘宝网天猫全球速卖通阿里巴巴国际交易市场1688阿里妈妈飞猪阿里云计算AliOS万网高德UC友盟优酷钉钉支付宝达摩院淘宝海外阿里云盘饿了么
    © 2009-2024 Aliyun.com 版权所有 增值电信业务经营许可证： 浙B2-20080101 域名注册服务机构许可： 浙D3-20210002 京D3-20220015
    浙公网安备 33010602009975号浙B2-20080101-4