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的主要内容,如果未能解决你的问题,请参考以下文章