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 代码实战

Golang Redis 基本操作

Golang Redis 基本操作

golang goroutine例子[golang并发代码片段]

golang代码片段(摘抄)

代码片段 - Golang 实现简单的 Web 服务器