快速入门
redis是目前使用最广的k/v数据库,基本上各大项目都会使用,go-redis是golang操作redis的库,也是目前使用最多的库之一。
1. 入门案例
官方地址:https://github.com/go-redis/redis
写入门案例之前,需要先启动一个redis:
在本机启动一个单机redis服务端,连接地址为localhost:6379
安装go-redis
//redis 6
go get github.com/go-redis/redis/v8
//redis 7
go get github.com/go-redis/redis/v9
1
2
3
4
2
3
4
连接redis
import "github.com/go-redis/redis/v8"
rdb := redis.NewClient(&redis.Options{
Addr: "localhost:6379",
Password: "", // no password set
DB: 0, // use default DB
})
1
2
3
4
5
6
7
2
3
4
5
6
7
简单实例
package main
import (
"context"
"fmt"
"github.com/go-redis/redis/v8"
)
var rdb *redis.Client
func init() {
rdb = redis.NewClient(&redis.Options{
Addr: "localhost:6379",
Password: "", // no password set
DB: 0, // use default DB
})
}
func main() {
ctx := context.Background()
//0代表永不过期
err := rdb.Set(ctx, "gorediskey", "goredisvalue", 0).Err()
if err != nil {
panic(err)
}
value, err := rdb.Get(ctx, "gorediskey").Result()
if err != nil {
panic(err)
}
fmt.Println("gorediskey", value)
//或者
val, err := rdb.Do(ctx, "get", "gorediskey").Result()
if err != nil {
if err == redis.Nil {
fmt.Println("gorediskey 不存在")
return
}
panic(err)
}
fmt.Println("do operator : gorediskey", val.(string))
}
1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27
28
29
30
31
32
33
34
35
36
37
38
39
40
41
42
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27
28
29
30
31
32
33
34
35
36
37
38
39
40
41
42
2. 连接设置
type Options struct {
// 网络类型:[ tcp , unix ]
// 默认是 tcp
Network string
// host:port 地址
Addr string
// 要使用的 TLS 配置。 当设置 TLS 时将协商。
TLSConfig *tls.Config
//创建一个新的连接,优先于Newwork和Addr选项
Dialer func(ctx context.Context, network, addr string) (net.Conn, error)
// 新建一个redis连接的时候,会回调这个函数
OnConnect func(ctx context.Context, cn *Conn) error
// 当连接到使用 Redis ACL 系统的 Redis 6.0 或更高版本的实例时,
// 使用指定的 用户名 对当前连接进行身份验证 (ACL 列表中定义的连接之一)。
Username string
// 可选密码。
// 必须与 requirepass 服务器配置选项中指定的密码(如果连接到 Redis 5.0 或更低版本的实例)
// 或 连接到使用 Redis ACL 系统的 Redis 6.0 或更高版本的实例时的用户密码 匹配。
Password string
// 连接到服务器后要选择的数据库。
DB int
// ====== 重试、退避时间======
// 放弃前的最大重试次数。
// 默认是 3 次重试; -1(非 0)禁用重试。
MaxRetries int
// 每次重试之间的最小退避。
// 默认为 8 毫秒; -1 禁用退避。
MinRetryBackoff time.Duration
// 每次重试之间的最大退避。
// 默认为 512 毫秒; -1 禁用退避。
MaxRetryBackoff time.Duration
// ======连接超时、读超时、写超时======
// 建立新连接的拨号超时。
// 默认为 5 秒。
DialTimeout time.Duration
// 套接字读取超时。
// 如果达到,命令将失败并超时而不是阻塞。
// 使用值 -1 表示无超时,使用 0 表示默认值。
// 默认为 3 秒。
ReadTimeout time.Duration
// 套接字写入超时。
// 如果达到,命令将失败并超时而不是阻塞。
// 默认为 ReadTimeout。
WriteTimeout time.Duration
// 连接池的类型。
// FIFO 池为 true,LIFO 池为 false。
// 请注意,与 lifo 相比,fifo 的开销更高。
PoolFIFO bool
// 最大套接字连接数。
// 默认为每个可用 CPU 10 个连接,由 runtime.GOMAXPROCS 报告。
PoolSize int
// 建立新连接缓慢时有用的最小空闲连接数。
MinIdleConns int
// 客户端退出(关闭)连接的连接年龄。
// 默认是不关闭老化的连接。
MaxConnAge time.Duration
// 如果所有连接都忙,则客户端在返回错误之前等待连接的时间。
// 默认为 ReadTimeout + 1 秒。
PoolTimeout time.Duration
// 客户端关闭空闲连接的时间。
// 应该小于服务器的超时时间。
// 默认为 5 分钟。 -1 禁用空闲超时检查。
IdleTimeout time.Duration
// 空闲连接 reaper 进行空闲检查的频率。
// 默认为 1 分钟。 -1 禁用空闲连接reaper,
// 但如果设置了 IdleTimeout,空闲连接仍会被客户端丢弃。
IdleCheckFrequency time.Duration
// 在从节点上启用只读查询。
readOnly bool
// 用于实现断路器或速率限制器的限制器接口。
Limiter Limiter
}
1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27
28
29
30
31
32
33
34
35
36
37
38
39
40
41
42
43
44
45
46
47
48
49
50
51
52
53
54
55
56
57
58
59
60
61
62
63
64
65
66
67
68
69
70
71
72
73
74
75
76
77
78
79
80
81
82
83
84
85
86
87
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27
28
29
30
31
32
33
34
35
36
37
38
39
40
41
42
43
44
45
46
47
48
49
50
51
52
53
54
55
56
57
58
59
60
61
62
63
64
65
66
67
68
69
70
71
72
73
74
75
76
77
78
79
80
81
82
83
84
85
86
87