Golang操作Redis

Posted 玩家_名狱

tags:

篇首语:本文由小常识网(cha138.com)小编为大家整理,主要介绍了Golang操作Redis相关的知识,希望对你有一定的参考价值。

安装第三方库

go get -u github.com/garyburd/redigo/redis

连接操作

package main

import (
	"fmt"
	"github.com/garyburd/redigo/redis"
)

func main() 
	redisObj, err := redis.Dial("tcp", "127.0.0.1:6379")
	if err != nil 
		fmt.Println("连接失败", err)
		return
	
	defer redisObj.Close()
    fmt.Println("连接成功")

连接之后,就可以使用连接对象下面的Do( )方法发送命令,并接收值

接受值时,我们get操作接收的的值都是字节类型,因此我们要进行转换,但是该库提供了许多转换类型的函数,比如转换成string类型就是redis.String( ),int64就是redis.Int64( )等等

package main

import (
	"fmt"
	"github.com/garyburd/redigo/redis"
)

func main() 
	redisObj, err := redis.Dial("tcp", "127.0.0.1:6379")
	if err != nil 
		fmt.Println("connect reids failed", err)
		return
	
	defer redisObj.Close()

	setResult, err := redisObj.Do("set", "name", "zhongxiaohang")
	if err != nil 
		fmt.Println("set操作失败", err)
	 else 
		fmt.Println("set操作结果", setResult)
	

	getResult, err := redis.String(redisObj.Do("get", "name"))
	if err != nil 
		fmt.Println("get操作失败", err)
	 else 
		fmt.Println("get操作结果", getResult)
	

/*
set操作结果 OK
get操作结果 zhongxiaohang
*/

接收多个值

接受多个值时类型转换,string是redis.Strings( ),int64就是redis.Int64s( )等等,接受结果是对应类型的数组

package main

import (
	"fmt"
	"github.com/garyburd/redigo/redis"
)

func main() 
	redisObj, err := redis.Dial("tcp", "127.0.0.1:6379")
	if err != nil 
		fmt.Println("connect reids failed", err)
		return
	
	defer redisObj.Close()

	setResult, err := redisObj.Do("mset", "name", "zhongxiaohang", "age", "18")
	if err != nil 
		fmt.Println("set操作失败", err)
	 else 
		fmt.Println("set操作结果", setResult)
	

	getResult, err := redis.Strings(redisObj.Do("mget", "name", "age"))
	if err != nil 
		fmt.Println("get操作失败", err)
	 else 
		fmt.Println("get操作结果", getResult)
	

/*
set操作结果 OK
get操作结果 [zhongxiaohang 18]
*/

设置键的过期时间

package main

import (
	"fmt"
	"time"

	"github.com/garyburd/redigo/redis"
)

func main() 
	redisObj, err := redis.Dial("tcp", "127.0.0.1:6379")
	if err != nil 
		fmt.Println("connect reids failed", err)
		return
	
	defer redisObj.Close()
	_, err = redisObj.Do("set", "name", "zhongxiaohang")
	if err != nil 
		fmt.Println("set操作失败", err)
	
	// 设置key的过期时间
	_, err = redisObj.Do("expire", "name", "5")
	if err != nil 
		fmt.Println("设置过期时间失败", err)
	
	time.Sleep(time.Second * 6) // 沉睡6秒,等待过期
    
	getResult, err := redis.String(redisObj.Do("get", "name"))
	if err != nil 
		fmt.Println("get操作失败", err)
	 else 
		fmt.Println("get操作结果", getResult)
	

/*
get操作失败 redigo: nil returned
*/

连接池操作

package main

import (
	"fmt"

	"github.com/garyburd/redigo/redis"
)

var redis_Pool *redis.Pool // 创建连接池

func init() 
	redis_Pool = &redis.Pool
		MaxIdle:     10,   // 初始连接数量
		MaxActive:   1000, // 连接池最大连接数量
		IdleTimeout: 60,   // 60秒内没有操作发生就会关闭连接池
		Dial: func() (redis.Conn, error) 
			return redis.Dial("tcp", "127.0.0.1:6379")
		,
	


func main() 
	redisObj := redis_Pool.Get() // 从连接池获取一个连接,连接池连接数量-1
	defer redis_Pool.Close()     // 关闭连接池
	defer redisObj.Close()       // 本次连接结束,关闭连接,连接池连接数量+1
	_, err := redisObj.Do("set", "age", "18")
	if err != nil 
		fmt.Println("set失败", err)
		return
	
	getResult, err := redis.Int(redisObj.Do("get", "age"))
	if err != nil 
		fmt.Println("get失败", err)
	 else 
		fmt.Println("get结果:", getResult)
	

/*
get结果: 18
*/

以上是关于Golang操作Redis的主要内容,如果未能解决你的问题,请参考以下文章

golang redis事务 --- 2022-04-03

Golang操作Redis

Golang操作Redis

golang操作redis

Golang Redis操作

golang 操作 Redis & Mysql & RabbitMQ