【Redis】golang操作Redis基础入门

寸 铁 2024-07-15 13:35:02 阅读 81

【Redis】golang操作Redis基础入门

大家好 我是寸铁👊

总结了一篇【Redis】golang操作Redis基础入门sparkles:

喜欢的小伙伴可以点点关注 💝

Redis的作用

Redis(Remote Dictionary Server)是一个开源的内存数据库,它主要用于存储键值对,并提供多种数据结构的支持。Redis 的主要作用包括:

1.<code>缓存: Redis 可以作为缓存系统,将常用的数据缓存在内存中,以提高数据访问速度。由于 Redis 是基于内存的,所以读取速度非常快,适用于需要快速访问的场景,如网页缓存、API 响应缓存等。2.会话存储: 可以将用户会话信息存储在 Redis 中,实现分布式会话管理。这样可以避免单点故障,并且能够轻松地实现会话共享和负载均衡。3.消息队列: Redis 支持发布订阅(Pub/Sub)模式,可以用作简单的消息队列系统。发布者将消息发布到特定的频道,而订阅者则可以订阅这些频道以接收消息。这使得 Redis 在异步通信、任务队列等场景中非常有用。4.计数器和排行榜: Redis 的原子计数器和有序集合功能可用于实现计数器和排行榜功能。比如统计网站访问次数、文章点赞数、用户积分排行等。5.分布式锁: Redis 的 SETNX 和 EXPIRE 命令结合可以实现分布式锁,用于控制多个客户端对共享资源的访问,防止出现竞态条件。6.持久化: Redis 支持多种持久化方式,包括快照(snapshot)和日志(append-only file),可以将内存中的数据定期或实时地保存到磁盘上,以防止数据丢失。7.地理空间数据处理: Redis 支持地理空间数据类型(Geo),可以存储经纬度信息,并提供相关的距离计算、地理位置查询等功能。

总的来说,Redis 是一个功能丰富的内存数据库,可以用于多种场景,包括缓存、会话存储、消息队列、计数器和排行榜、分布式锁等,为应用程序提供高性能、高可用的数据存储和处理能力。


go实现

那怎么使用go语言实现Redis的基本操作呢?下面寸铁带你手把手实现!


建立redis连接

var rdb *redis.Client

// 建立redis连接

func init() {

rdb = redis.NewClient(&redis.Options{

Addr: "localhost:6379",

Password: "",

DB: 0,

})

}


字段说明

Addr: 指定 Redis 服务器的地址,包括主机和端口号。在这里是本地主机的默认 Redis 端口 6379。

Password: Redis 服务器的访问密码,如果 Redis 设置了密码,需要在此处填入密码。

DB: 指定连接的 Redis 数据库编号。Redis 支持多个数据库,默认使用的是第一个数据库编号为 0。


设置指定键的值

ctx := context.Background()

err := rdb.Set(ctx, "rediskey", "redisvalue", 0).Err()

if err != nil {

panic(err)

}

字段说明

上下文(context):在 Go 中,上下文用于控制请求的生命周期,包括取消请求和设置超时时间等。

键名:“rediskey”,指定要设置的键名。

键值:“redisvalue”,指定要设置的键值。

过期时间:0,表示该键永不过期。


获取指定键的值

getres, err := rdb.Get(ctx, "rediskey").Result()

if err != nil {

panic(err)

}

fmt.Println("get执行的result", getres)

字段说明

上下文(context):在 Go 中,上下文用于控制请求的生命周期,包括取消请求和设置超时时间等。

键名:“rediskey”,指定要获取值的键名。


执行原生的 Redis 命令

dores, err := rdb.Do(ctx, "GET", "rediskey").Result()

if err != nil {

panic(err)

}

fmt.Println("do get 执行的result", dores.(string))

字段说明

上下文(context):在 Go 中,上下文用于控制请求的生命周期,包括取消请求和设置超时时间等。

Redis 命令:“GET”,指定要执行的 Redis 命令是 GET。

命令参数:“rediskey”,指定 GET 命令的键名。


设置指定键的值,并返回键的旧值

oldres, err := rdb.GetSet(ctx, "rediskey", "newvalue").Result()

if err != nil {

panic(err)

}

fmt.Println("GetSet执行的result", oldres) // redisvalue


字段说明

上下文(context):在 Go 中,上下文用于控制请求的生命周期,包括取消请求和设置超时时间等。

键名:“rediskey”,指定要设置值的键名。

新值:“newvalue”,指定要设置的新值。


键不存在时设置键的值

err = rdb.SetNX(ctx, "key3", "value3", 0).Err()

if err != nil {

panic(err)

}

字段说明

上下文(context):在 Go 中,上下文用于控制请求的生命周期,包括取消请求和设置超时时间等。

键名:“key3”,指定要设置值的键名。

:“value3”,指定要设置的值。

超时时间:0,表示不设置超时时间。


批量获取多个键的值

result, err := rdb.MGet(ctx, "key1", "key2", "key3").Result()

if err != nil {

panic(err)

}

fmt.Println(result)


批量查询多个键的值

//作用: 批量查询redis键的值

func checkRedisKey(ctx context.Context, rdb *redis.Client, checkKey []string) {

for _, key := range checkKey {

value, err := rdb.Get(ctx, key).Result()

if err != nil {

fmt.Printf("Error getting value for key %s: %s\n", key, err.Error())

} else {

fmt.Printf("key: %s value: %s\n", key, value)

}

}

}

字段说明

上下文(context):在 Go 中,上下文用于控制请求的生命周期,包括取消请求和设置超时时间等。

要获取值的键名:“key1”, “key2”, “key3”,指定了要获取值的多个键名。


批量设置多个键的值

setKey := rdb.MSet(ctx, "key1", "value1", "key2", "value2", "key3", "value3")

if err != nil {

panic(err)

}

fmt.Println(setKey)

字段说明

上下文(context):在 Go 中,上下文用于控制请求的生命周期,包括取消请求和设置超时时间等。

要设置值的键值对:“key1”, “value1”, “key2”, “value2”, “key3”, “value3”,这里同时设置了多个键值对。


将键的值自增 1

i, err := rdb.Incr(ctx, "inckey").Result()

fmt.Println("Incr自增后的值:", i) //1

字段说明

上下文(context):在 Go 中,上下文用于控制请求的生命周期,包括取消请求和设置超时时间等。

要自增的键名:“inckey”,指定了要进行自增操作的键名。


自增设定的整数

i2, err := rdb.IncrBy(ctx, "inckey", 2).Result()

fmt.Println("IncrBy自增后的值", i2) //3

字段说明

上下文(context):在 Go 中,上下文用于控制请求的生命周期,包括取消请求和设置超时时间等。

要自增的键名:“inckey”,指定了要进行自增操作的键名。

自增的整数值:这里是 2,表示要将键的值增加 2。


将键的值自增指定的浮点数

i3, err := rdb.IncrByFloat(ctx, "inckey", 2.2).Result()

fmt.Println("IncrByFloat自增后的值", i3) //5.2

字段说明

上下文(context):在 Go 中,上下文用于控制请求的生命周期,包括取消请求和设置超时时间等。

要自增的键名:“inckey”,指定了要进行自增操作的键名。

自增的浮点数值:这里是 2.2,表示要将键的值增加 2.2。


删除指定的键

rdb.Del(ctx, "key1")

字段说明

上下文(context):在 Go 中,上下文用于控制请求的生命周期,包括取消请求和设置超时时间等。

要删除的键名:“key1”,指定了要进行删除操作的键名。

删除指定键映射的值

由于redis不支持直接删除键所对应的值,只能先把键删除再新键一个键。

// 删除键所对应的值

err := rdb.Del(ctx, key).Err()

if err != nil {

log.Fatal(err)

}

// 再创建该键

err = rdb.Set(context.Background(), key, nil, 0).Err()

if err != nil {

log.Fatal(err)

}


批量删除键

// 作用: 批量删除键

func clearRedisKeys(ctx context.Context, rdb *redis.Client, clearKeys []string) {

for _, key := range clearKeys {

// 删除键所对应的值

err := rdb.Del(ctx, key).Err()

if err != nil {

log.Fatal(err)

}

}

}

批量删除键所对应的值

// 作用: 批量删除键所对应的值

func clearRedisKeys(ctx context.Context, rdb *redis.Client, clearKeys []string) {

for _, key := range clearKeys {

// 删除键所对应的值

err := rdb.Del(ctx, key).Err()

if err != nil {

log.Fatal(err)

}

// 再创建该键

err = rdb.Set(context.Background(), key, nil, 0).Err()

if err != nil {

log.Fatal(err)

}

}

}


批量删除多个键

err = rdb.Del(ctx, "key2", "key3").Err()

if err != nil {

panic(err)

}

字段说明

上下文(context):在 Go 中,上下文用于控制请求的生命周期,包括取消请求和设置超时时间等。

要删除的多个键名:“key2”, “key3”,指定了要进行删除操作的键名列表。


设置指定键的过期时间

rdb.Expire(ctx, "key", 10*time.Second)

字段说明

上下文(context):在 Go 中,上下文用于控制请求的生命周期,包括取消请求和设置超时时间等。

要设置过期时间的键名:“key”,指定了要设置过期时间的键名。

过期时间:这里是 10 秒,表示在当前时间的基础上,键 “key” 会在 10 秒后过期失效。


demo

package main

import (

"context"

"fmt"

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

"time"

)

// 建立redis连接

func init() {

rdb = redis.NewClient(&redis.Options{

Addr: "localhost:6379",

Password: "",

DB: 0,

})

}

func main() {

ctx := context.Background()

err := rdb.Set(ctx, "rediskey", "redisvalue", 0).Err()

if err != nil {

panic(err)

}

getres, err := rdb.Get(ctx, "rediskey").Result()

if err != nil {

panic(err)

}

fmt.Println("get执行的result", getres) //redisvalue

//使用DO 原生的操作

dores, err := rdb.Do(ctx, "GET", "rediskey").Result()

if err != nil {

panic(err)

}

fmt.Println("do get 执行的result", dores.(string)) //redisvalue

//即使设置新的值 取到的是旧的值 但是在redis中是设置了新的值

oldres, err := rdb.GetSet(ctx, "rediskey", "newvalue").Result()

if err != nil {

panic(err)

}

fmt.Println("GetSet执行的result", oldres) //redisvalue

//存在则不设置该值 不存在则设置该值

err = rdb.SetNX(ctx, "key3", "value3", 0).Err()

if err != nil {

panic(err)

}

//批量取出键的值

result, err := rdb.MGet(ctx, "key1", "key2", "key3").Result()

if err != nil {

panic(err)

}

fmt.Println(result)

//批量设置键的值 类似Map 对于同一个键的值 再设置会进行覆盖

setKey := rdb.MSet(ctx, "key1", "value1", "key2", "value2", "key3", "value3")

if err != nil {

panic(err)

}

fmt.Println(setKey)

//自增1

i, err := rdb.Incr(ctx, "inckey").Result()

fmt.Println("Incr自增后的值:", i) //1

//自增设定的整数

i2, err := rdb.IncrBy(ctx, "inckey", 2).Result()

fmt.Println("IncrBy自增后的值", i2) //3

//自增设定的浮点数

i3, err := rdb.IncrByFloat(ctx, "inckey", 2.2).Result()

fmt.Println("IncrByFloat自增后的值", i3) //5.2

//自减1

i4, err := rdb.Decr(ctx, "inckey").Result()

fmt.Println("Incr自增后的值:", i4) //0 3-->2

//自减设定的整数

i5, err := rdb.DecrBy(ctx, "inckey", 2).Result()

fmt.Println("IncrBy自增后的值", i5) //0 2-->0

//单个删除

rdb.Del(ctx, "key1")

//批量删除

err = rdb.Del(ctx, "key2", "key3").Err()

if err != nil {

panic(err)

}

//设置过期时间 10秒钟后失效

//rdb.Set(ctx, "key", "value", 10*time.Second)

rdb.Expire(ctx, "key", 10*time.Second)

}


看到这里的小伙伴,恭喜你又掌握了一个技能👊

希望大家能取得胜利,坚持就是胜利💪

我是寸铁!我们下期再见💕

往期好文💕

保姆级教程

【保姆级教程】Windows11下go-zero的etcd安装与初步使用

【保姆级教程】Windows11安装go-zero代码生成工具goctl、protoc、go-zero

【Go-Zero】手把手带你在goland中创建api文件并设置高亮


报错解决

【Go-Zero】Error: user.api 27:9 syntax error: expected ‘:‘ | ‘IDENT‘ | ‘INT‘, got ‘(‘ 报错解决方案及api路由注意事项

【Go-Zero】Error: only one service expected goctl一键转换生成rpc服务错误解决方案

【Go-Zero】【error】 failed to initialize database, got error Error 1045 (28000):报错解决方案

【Go-Zero】Error 1045 (28000): Access denied for user ‘root‘@‘localhost‘ (using password: YES)报错解决方案

【Go-Zero】type mismatch for field “Auth.AccessSecret“, expect “string“, actual “number“报错解决方案

【Go-Zero】Error: user.api 30:2 syntax error: expected ‘)‘ | ‘KEY‘, got ‘IDENT‘报错解决方案

【Go-Zero】Windows启动rpc服务报错panic:context deadline exceeded解决方案


Go面试向

【Go面试向】defer与time.sleep初探

【Go面试向】defer与return的执行顺序初探

【Go面试向】Go程序的执行顺序

【Go面试向】rune和byte类型的认识与使用

【Go面试向】实现map稳定的有序遍历的方式



声明

本文内容仅代表作者观点,或转载于其他网站,本站不以此文作为商业用途
如有涉及侵权,请联系本站进行删除
转载本站原创文章,请注明来源及作者。