golang操作Redis的实现示例

 更新时间:2024年04月25日 11:52:45   作者:寸 铁  
本文主要介绍了golang操作Redis的实现示例,文中通过示例代码介绍的非常详细,对大家的学习或者工作具有一定的参考学习价值,需要的朋友们下面随着小编来一起学习学习吧

Redis的作用

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

  • 1.缓存: 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)

字段说明

  • 上下文(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”,指定了要进行删除操作的键名。

批量删除多个键

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)

}

到此这篇关于golang操作Redis的实现示例的文章就介绍到这了,更多相关golang操作Redis内容请搜索脚本之家以前的文章或继续浏览下面的相关文章希望大家以后多多支持脚本之家! 

相关文章

  • Go语言通过chan进行数据传递的方法详解

    Go语言通过chan进行数据传递的方法详解

    这篇文章主要为大家详细介绍了Go语言如何通过chan进行数据传递的功能,文中的示例代码讲解详细,感兴趣的小伙伴可以跟随小编一起了解一下
    2023-06-06
  • 详解Go语言如何高效解压ZIP文件

    详解Go语言如何高效解压ZIP文件

    在日常开发中,我们经常需要处理 ZIP 文件,本文主要为大家介绍一个使用 Go 语言编写的高效 ZIP 文件解压工具,希望对大家有一定的帮助
    2025-03-03
  • 详解golang中 work与 module 的区别与联系

    详解golang中 work与 module 的区别与联系

    Go 模块通常由一个项目或库组成,并包含一组随后一起发布的 Go 包,Go 模块通过允许用户将项目代码放在他们选择的目录中并为每个模块指定依赖项的版本,解决了原始系统的许多问题,本文将给大家介绍一下golang中 work与 module 的区别与联系,需要的朋友可以参考下
    2023-09-09
  • 关于Golang获取当前项目绝对路径的问题

    关于Golang获取当前项目绝对路径的问题

    这篇文章主要介绍了Golang获取当前项目绝对路径的问题,通常的做法是go run用于本地开发,用一个命令中快速测试代码确实非常方便;在部署生产环境时,我们会通过go build构建出二进制文件然后上传到服务器再去执行,那么会产生什么问题呢?感兴趣的朋友一起看看吧
    2022-04-04
  • 基于Go语言对浮点数进行比较的方法

    基于Go语言对浮点数进行比较的方法

    在 Go 语言(以及大多数遵循 IEEE 754 标准的编程语言)中,‌差值容限(Epsilon) ‌ 是指在进行浮点数比较时,允许两个数值之间存在的最大微小误差范围,本文给大家介绍了基于Go语言对浮点数进行比较的方法,需要的朋友可以参考下
    2026-05-05
  • 基于Go goroutine实现一个简单的聊天服务

    基于Go goroutine实现一个简单的聊天服务

    对于聊天服务,想必大家都不会陌生,因为在我们的生活中经常会用到,本文我们用 Go 并发来实现一个聊天服务器,这个程序可以让一些用户通过服务器向其它所有用户广播文本消息,文中通过代码示例介绍的非常详细,需要的朋友可以参考下
    2023-06-06
  • Go垃圾回收提升内存管理效率优化最佳实践

    Go垃圾回收提升内存管理效率优化最佳实践

    这篇文章主要为大家介绍了Go垃圾回收提升内存管理效率优化最佳实践,有需要的朋友可以借鉴参考下,希望能够有所帮助,祝大家多多进步,早日升职加薪
    2023-12-12
  • Go设计模式之原型模式讲解和代码示例

    Go设计模式之原型模式讲解和代码示例

    原型是一种创建型设计模式,使你能够复制对象,甚至是复杂对象,而又无需使代码依赖它们所属的类,本文将通过代码示例示例给大家讲解一下Go 原型模式,感兴趣的小伙伴可以参考阅读
    2023-07-07
  • Golang实现文件传输功能

    Golang实现文件传输功能

    这篇文章主要为大家详细介绍了Golang实现文件传输功能,文中示例代码介绍的非常详细,具有一定的参考价值,感兴趣的小伙伴们可以参考一下
    2022-07-07
  • 深入探究Go语言的错误策略与异常机制

    深入探究Go语言的错误策略与异常机制

    本文深入探讨了Go语言的错误策略与异常机制,主要介绍了错误处理的重要性,以及Go语言中的错误类型和处理函数,此外还讨论了Go语言的异常机制,包括panic和recover函数的使用,需要的朋友可以参考下
    2024-02-02

最新评论