GO语言中Redis的相关知识记录

最近看到这个github.com/go-redis/redis/v8已经更新了,今天下载下来用用
这里分享一个关于redis实战的书籍,分享链接,可以查底下留言获取

安装Redis包

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

由于这个`v8`版本,使用了`context`这个包,`context`这个包是做什么的呢?
  这个包提供上下文机制在`goroutine`之间传递`deadline`,`取消信号 `
或其请求相关的信息,其实说白了就是,如何优雅的管理`goroutine`

context包基本使用

//服务器会为每个程序创建一个根Context实例,
//goroutine接受根context的一个派生Context对象
//goroutine通过 context.Done()方法监听取消信号
//例子,WithCancel()的使用
//如何优雅地关闭一个goroutine
package main
import (
"context"
"fmt"
"time"
)
func f1(ctx context.Context) {
LOOPUP:
for {
fmt.Println("我在执行")
time.Sleep(time.Second)
//这里是使用select监听通道,如果发现ctx.done()中有值,则直接跳出循环
select {
case <-ctx.Done():
break LOOPUP
default:
}
}
}
func main() {
//创建一个取消信号的根context实例
ctx,cancelFunc :=context.WithCancel(context.Background())
go f1(ctx)
time.Sleep(time.Second*5)
//运行5秒后,发送退出信号
cancelFunc()
}
//也可以使用WithDeadline() 指定到期时间触发
nowtime :=time.Now().Add(time.Second*3) //当前时间+3秒
//3秒后停止
//这里的时间是一个time类型
ctx,_:=context.WithDeadline(context.Background(),nowtime)
go f1(ctx)
//也可以指定WithTimeout(),在多少秒后执行退出
//这里的时间是一个time.Duration类型,用法一样
func WithTimeout(parent Context, timeout time.Duration) (Context, CancelFunc)

redis的基本操作

以下的命令只是简单演示几个常用的,redis里的命令,这个包都是支持的

创建Redis连接

package main
import (
"context"
"fmt"
"github.com/go-redis/redis/v8"
)
//定义一个根context对象
var ctx=context.Background()
var rdb *redis.Client
//创建连接对象,底层是使用的链接池
func init() {
rdb =redis.NewClient(&redis.Options{
Addr: "127.0.0.1:6379",
Password: "",
DB: 0,
})
}

字符串操作

//这里封装了一个函数,这里是基本的操作,别的命令都可以按这种写法实现
func redisString() {
//设置值
err :=rdb.Set(ctx,"set1","name1",0).Err()
fmt.Println(err)
//获取值
vaule ,_:=rdb.Get(ctx,"set1").Result()
fmt.Println("值是,",vaule)
//删除删除成功 n>0
n,err :=rdb.Del(ctx,"set1").Result()
fmt.Println("删除,",n,err)
}

Hash操作

//hash操作
func redisHash() {
//写入数据
//第一种写法
err:=rdb.HSet(ctx,"hash1","name","tom","age",18).Err()
//第二种
err =rdb.HSet(ctx,"hash2",map[string]interface{}{"name":"tom2","age":18}).Err()
//第三种也可以使用切片来传入,但是值得是一样的类型
err =rdb.HSet(ctx,"hash3",[]string{"name","tome3","age","182"}).Err()
//获取值
res,_:=rdb.HGet(ctx,"hash1","name").Result()
fmt.Println(res)
//获取所有的信息值
var reslutl map[string]string
reslutl,err=rdb.HGetAll(ctx,"hash2").Result()
fmt.Println(reslutl,err)
n,_:=rdb.HLen(ctx,"hash2").Result()
fmt.Println("key的数量",n)
}

Lists列表操作

//可以使用列表实现,队列或栈的操作,也可以使用brpop或blpop实现阻塞队列,这里就不写了
func redisLists() {
//向列表添加值
//err :=rdb.LPush(ctx,"list1","name1","name2","name3").Err()
//fmt.Println(err)
//查看列表中的元素
var result []string
result,_ =rdb.LRange(ctx,"list1",0,-1).Result()
fmt.Println("列表元素的值",result)
//弹出元素
res,err :=rdb.LPop(ctx,"list1").Result()
fmt.Println("弹出的元素",res,err)
}

Set集合

//set集合,这个可以抽奖,去重等操作
func redisSet() {
//向集合里添加数据
//err :=rdb.SAdd(ctx,"set11","mem1","mem2","mem3").Err()
//err =rdb.SAdd(ctx,"set22","mem2","mem3","mem4").Err()
var res []string
//查看元素
res,_=rdb.SMembers(ctx,"set11").Result()
fmt.Println("查看元素",res)
//查看元素个数
n,_:=rdb.SCard(ctx,"set11").Result()
fmt.Println("查看元素个数",n)
//取交集
res ,_=rdb.SInter(ctx,"set11","set22").Result()
fmt.Println("交集",res)
//取并集
res ,_ =rdb.SDiff(ctx,"set11","set22").Result()
fmt.Println("并集",res)
//取全集
res,_=rdb.SUnion(ctx,"set11","set22").Result()
fmt.Println("全集",res)
//删除指定元素
n,err :=rdb.SRem(ctx,"set11","mem1").Result()
fmt.Println(n,err)
//随机弹出
str:=rdb.SPop(ctx,"set22").Err()
fmt.Println(str)
}

Zset有序集合操作

//这个比较麻烦点,但是不难
func redisZset() {
//添加带分数的元素
//err :=rdb.ZAdd(ctx,"zset1",&redis.Z{Score: 50,Member: "tom1"},&redis.Z{Score: 60,Member: "tom2"}, &redis.Z{Score: 70,Member: "tom3"},&redis.Z{Score: 70,Member: "tom4"}).Err()
//_=rdb.ZAdd(ctx,"zset2",&redis.Z{Score: 100,Member: "tom4"},&redis.Z{Score: 90,Member: "tom5"},&redis.Z{Score: 85,Member: "tom6"}).Err()
//fmt.Println(err)
//查看集合里的元素
//var res []string
//res ,_ =rdb.ZRange(ctx,"zset1",0,-1).Result()
////参数,通过分数查询
//res,_=rdb.ZRangeByScore(ctx,"zset1",&redis.ZRangeBy{
//Min: "0",
//Max: "90",
//Offset: 0,
//Count: 0,
//}).Result()
//fmt.Println(res)
//var res2 []redis.Z
////带分数查询
//res2,_=rdb.ZRangeArgsWithScores(ctx,redis.ZRangeArgs{
//Key: "zset1",
//Start: 0,
//Stop: -1,
//ByScore: false,
//ByLex: false,
//Rev: true,
//Offset: 0,
//Count: 0,
//}).Result()
//fmt.Println("集合中的元素",res2)
//交集
var res []string
res ,_ =rdb.ZInter(ctx,&redis.ZStore{
Keys: []string{"zset1","zset2"},
Weights: nil,
Aggregate: "min",//这里取值有,sum,min,max
}).Result()
fmt.Println("交集的数据",res)
var res2 []redis.Z
res2 ,_ =rdb.ZInterWithScores(ctx,&redis.ZStore{
Keys: []string{"zset1","zset2"},
Weights: nil,
Aggregate: "max",//取交集分值大的那个值
}).Result()
fmt.Println("交集带分数的数据",res2)
//并集
res,_=rdb.ZDiff(ctx,"zset1","zset2").Result()
fmt.Println("并集",res)
}