[go-redis] go操作redis数据库

先上命令速查网站，菜鸟yyds
https://www.runoob.com/redis/redis-strings.html
操作redis的包是go-redis/redis
官方文档 https://redis.uptrace.dev/guide/
github https://github.com/go-redis/redis
创建项目
创建test文件夹
创建 Redis_test.go 文件
直接上代码，代码解释全写在注释里

1. package test
3. import (
4.         "context"
5.         "encoding/json"
6.         "fmt"
7.         "github.com/go-redis/redis/v8"
8.         "testing"
9.         "time"
10. )
13. var ctx = context.Background()
15. var rdb *redis.Client
17. func init() {
18.         rdb = redis.NewClient(&redis.Options{
19.                 //        端口需要改，这里是docker的端口
20.                 Addr:          "localhost:49153",
21.                 Password: "redispw", // no password set
22.                 DB:                  0,  // use default DB
23.                 PoolSize:15,
24.                 MinIdleConns: 10, //在启动阶段创建指定数量的Idle连接，并长期维持idle状态的连接数不少于指定数量；。
25.                 //超时
26.                 //DialTimeout:  5 * time.Second, //连接建立超时时间，默认5秒。
27.                 //ReadTimeout:  3 * time.Second, //读超时，默认3秒， -1表示取消读超时
28.                 //WriteTimeout: 3 * time.Second, //写超时，默认等于读超时
29.                 //PoolTimeout:  4 * time.Second, //当所有连接都处在繁忙状态时，客户端等待可用连接的最大等待时长，默认为读超时+1秒。
30.         })
31. }
34. //        基础使用
35. func Test_Base(t *testing.T) {
36.         //        添加key
37.         //0表示没有过期时间
38.         rdb.Set(ctx, "testKey", "xxx", 0)
40.         //        获取值
41.         val, err := rdb.Get(ctx, "testKey").Result()
42.         if err != nil {
43.                 fmt.Println("错误", err)
44.         }
45.         fmt.Println("值：", val)
47.         //        设置key过期时间 成功true
48.         rdb.Expire(ctx, "testKey", time.Second*60)
50.         //        存在返回1
51.         rdb.Exists(ctx, "testKey")
53.         //        key不存在时设置值
54.         rdb.SetNX(ctx, "unkey", "val", 0)
56.         rdb.Set(ctx, "testKey2", "xxx", 0)
57.         //        删除key 可删除多个
58.         rdb.Del(ctx, "testKey2", "testKey")
60. }
62. //        字符串
63. func Test_String(t *testing.T) {
64.         //        设置值
65.         rdb.Set(ctx, "strKey", 100, 0)
66.         rdb.Set(ctx, "straey", 100, 0)
68.         //        key自增1
69.         rdb.Incr(ctx, "strKey")
70.         //        增加 66
71.         rdb.IncrBy(ctx, "straey", 66)
73.         //        -1
74.         rdb.Decr(ctx, "straey")
75.         //        -5
76.         rdb.DecrBy(ctx, "straey", 5)
78.         //        过期时间
79.         rdb.TTL(ctx, "strKey")
80.         //        str*ey                : *为任意字符串
81.         //        str[kKac]ey : 匹配[] 内的单个字符 strkey,strKey,straey,strcey
82.         //        str?ey                : ? 任意单个字符
83.         //        扫描key
84.         iter := rdb.Scan(ctx, 0, "str?ey", 0).Iterator()
85.         for iter.Next(ctx) {
86.                 fmt.Println("keys", iter.Val(), ": val", rdb.Get(ctx, iter.Val()).Val())
87.         }
88.         if err := iter.Err(); err != nil {
89.                 panic(err)
90.         }
92. }
94. //        哈希
95. func Test_Hash(t *testing.T) {
96.         rdb.HMSet(ctx,"hkey1","name","shushan","age",99,"b",true)
98.         //        以结构体存入 注意redis tag
99.         type User struct {
100.                 Name string `json:"name,omitempty" redis:"name"`
101.                 Age  int    `json:"age,omitempty" redis:"age"`
102.                 B    bool   `json:"b,omitempty" redis:"b"`
103.                 //...
104.         }
105.         user1 := User{
106.                 Name: "shushan2",
107.                 Age:  55,
108.                 B:    true,
109.         }
110.         //        结构体序列化反序列化map 你也可以用其他包进行转化为map,但是注意转化后的键名大小写问题
111.         m := make(map[string]interface{})
112.         buf,_ := json.Marshal(user1)
113.         _ = json.Unmarshal(buf,&m)
115.         //        存入
116.         rdb.HSet(ctx, "user4", m)
118.         //        取出绑定到结构体 map也行
119.         var user User
120.         rdb.HGetAll(ctx,"user4").Scan(&user)
121.         fmt.Printf(" %#v \n ",user)
122.         //        test.User{Name:"shushan2", Age:55, B:true}
124.         //        获取key下的所有值   *匹配方式与string的所有原理一样
125.         iter := rdb.HScan(ctx,"user4",0,"*",0).Iterator()
126.         for iter.Next(ctx) {
127.                 fmt.Println("keys", iter.Val())
128.         }
129.         if err := iter.Err(); err != nil {
130.                 panic(err)
131.         }
132. }
135. //        列表
136. func Test_List(t *testing.T) {
137.         //        添加
138.         rdb.LPush(ctx,"listKey1",111,222,333,444)
139.         rdb.RPush(ctx,"listKey1",5555)
140.         //        不存在不添加
141.         rdb.LPushX(ctx,"unlistKey",111)
143.         var intf []int
144.         //        根据索引获取 绑定到数组
145.         rdb.LRange(ctx,"listKey1",0,10).ScanSlice(&intf)
146.         fmt.Println(intf)
148.         var i int
149.         //        弹出
150.         rdb.LPop(ctx,"listKey1").Scan(&i)
151.         fmt.Println(i)
153.         //....
155. }
159. //        集合
160. func Test_Set(t *testing.T) {
161.         //        添加
162.         rdb.SAdd(ctx,"setKey1","m1","onlyk1")
163.         rdb.SAdd(ctx,"setKey2","m2","xca")
166.         sl,_:= rdb.SDiff(ctx,"setKey1","setKey2").Result()
167.         fmt.Println(sl)
168.         // onlyk1,m1
170.         //随机移除
171.         var val string
172.         rdb.SPop(ctx,"setKey1").Scan(&val)
173.         fmt.Println(val)
175.         // .....
176. }
178. //        管道
179. func Test_Pipe(t *testing.T) {
180.         //         官方描述
181.         //         Redis 管道允许客户端命令服务器通过执行任务而通过执行任务来提高您的性能。
182.         //        在管道中，像命令命令一样将编写 + 使用命令来执行任务，并将其用于执行任务，执行任务不是一个地执行100个命令。
183.         //        理解为命令就像石头，一次运送一个石头
184.         //        使用管道等于 用车装石头  Exec 时就运送过去
185.         pipe := rdb.Pipeline()
187.         incr := pipe.Set(ctx, "pip_test","bt",0)
188.         pipe.Expire(ctx, "pip_test", time.Hour)
190.         //        提交
191.         cmds, err := pipe.Exec(ctx)
192.         if err != nil {
193.                 fmt.Println(err)
194.         }
195.         for _, cmd := range cmds {
196.                 fmt.Println(cmd.String())
197.         }
199.         // 该值得Exec提交后有效
200.         fmt.Println(incr.Val())
201. }

复制代码

其他操作都可以查看go-redis的源码或者直接打出rdb.命令，go-redis 的函数命名方式和redis的命令是差不多的
The end

免责声明：如果侵犯了您的权益，请联系站长，我们会及时删除侵权内容，谢谢合作！