Golang redis 操作初体验
发布时间：2020-12-16 18:26:28 所属栏目：大数据 来源：网络整理
导读：安装 我使用的是 https://github.com/go-redis/r... 这个 golang 客户端,因此安装方式如下: go get gopkg.in/redis.v4 接着在代码中导入此包即可: import "gopkg.in/redis.v4" 基本操作 创建客户端 通过 redis.NewClient 函数即可创建一个 redis 客户端,这个
安装我使用的是 https://github.com/go-redis/r... 这个 golang 客户端,因此安装方式如下: go get gopkg.in/redis.v4 接着在代码中导入此包即可: import "gopkg.in/redis.v4" 基本操作创建客户端通过 redis.NewClient 函数即可创建一个 redis 客户端,这个方法接收一个 redis.Options 对象参数,通过这个参数,我们可以配置 redis 相关的属性,例如 redis 服务器地址,数据库名,数据库密码等. // 创建 redis 客户端
func createClient() *redis.Client {
client := redis.NewClient(&redis.Options{
Addr: "localhost:6379",Password: "",DB: 0,})
// 通过 cient.Ping() 来检查是否成功连接到了 redis 服务器
pong,err := client.Ping().Result()
fmt.Println(pong,err)
return client
}
String 操作redis 的 String 操作有: set(key,value)：给数据库中名称为key的string赋予值value get(key)：返回数据库中名称为key的string的value getset(key,value)：给名称为key的string赋予上一次的value mget(key1,key2,…,key N)：返回库中多个string的value setnx(key,value)：添加string，名称为key，值为value setex(key,time,value)：向库中添加string，设定过期时间time mset(key N,value N)：批量设置多个string的值 msetnx(key N,value N)：如果所有名称为key i的string都不存在 incr(key)：名称为key的string增1操作 incrby(key,integer)：名称为key的string增加integer decr(key)：名称为key的string减1操作 decrby(key,integer)：名称为key的string减少integer append(key,value)：名称为key的string的值附加value substr(key,start,end)：返回名称为key的string的value的子串 在 go-redis 中,我们可以直接找到对应的操作方法,直接上代码: // String 操作
func stringOperation(client *redis.Client) {
// 第三个参数是过期时间,如果是0,则表示没有过期时间.
err := client.Set("name","xys",0).Err()
if err != nil {
panic(err)
}
val,err := client.Get("name").Result()
if err != nil {
panic(err)
}
fmt.Println("name",val)
// 这里设置过期时间.
err = client.Set("age","20",1 * time.Second).Err()
if err != nil {
panic(err)
}
client.Incr("age") // 自增
client.Incr("age") // 自增
client.Decr("age") // 自减
val,err = client.Get("age").Result()
if err != nil {
panic(err)
}
fmt.Println("age",val) // age 的值为21
// 因为 key "age" 的过期时间是一秒钟,因此当一秒后,此 key 会自动被删除了.
time.Sleep(1 * time.Second)
val,err = client.Get("age").Result()
if err != nil {
// 因为 key "age" 已经过期了,因此会有一个 redis: nil 的错误.
fmt.Printf("error: %vn",err)
}
fmt.Println("age",val)
}
list 操作redis 的 list 操作有: rpush(key,value)：在名称为key的list尾添加一个值为value的元素 lpush(key,value)：在名称为key的list头添加一个值为value的 元素 llen(key)：返回名称为key的list的长度 lrange(key,end)：返回名称为key的list中start至end之间的元素 ltrim(key,end)：截取名称为key的list lindex(key,index)：返回名称为key的list中index位置的元素 lset(key,index,value)：给名称为key的list中index位置的元素赋值 lrem(key,count,value)：删除count个key的list中值为value的元素 lpop(key)：返回并删除名称为key的list中的首元素 rpop(key)：返回并删除名称为key的list中的尾元素 blpop(key1,… key N,timeout)：lpop命令的block版本。 brpop(key1,timeout)：rpop的block版本。 rpoplpush(srckey,dstkey)：返回并删除名称为srckey的list的尾元素，并将该元素添加到名称为dstkey的list的头部 同样地,在 go-redis 中也可以找到对应的方法,下面是一个简单的示例: // list 操作
func listOperation(client *redis.Client) {
client.RPush("fruit","apple") //在名称为 fruit 的list尾添加一个值为value的元素
client.LPush("fruit","banana") //在名称为 fruit 的list头添加一个值为value的 元素
length,err := client.LLen("fruit").Result() //返回名称为 fruit 的list的长度
if err != nil {
panic(err)
}
fmt.Println("length: ",length) // 长度为2
value,err := client.LPop("fruit").Result() //返回并删除名称为 fruit 的list中的首元素
if err != nil {
panic(err)
}
fmt.Println("fruit: ",value)
value,err = client.RPop("fruit").Result() // 返回并删除名称为 fruit 的list中的尾元素
if err != nil {
panic(err)
}
fmt.Println("fruit: ",value)
}
set 操作redis 的 set 操作: sadd(key,member)：向名称为key的set中添加元素member srem(key,member) ：删除名称为key的set中的元素member spop(key) ：随机返回并删除名称为key的set中一个元素 smove(srckey,dstkey,member) ：移到集合元素 scard(key) ：返回名称为key的set的基数 sismember(key,member) ：member是否是名称为key的set的元素 sinter(key1,…key N) ：求交集 sinterstore(dstkey,(keys)) ：求交集并将交集保存到dstkey的集合 sunion(key1,(keys)) ：求并集 sunionstore(dstkey,(keys)) ：求并集并将并集保存到dstkey的集合 sdiff(key1,(keys)) ：求差集 sdiffstore(dstkey,(keys)) ：求差集并将差集保存到dstkey的集合 smembers(key) ：返回名称为key的set的所有元素 srandmember(key) ：随机返回名称为key的set的一个元素 接下来是 go-redis 的 set 操作: // set 操作
func setOperation(client *redis.Client) {
client.SAdd("blacklist","Obama") // 向 blacklist 中添加元素
client.SAdd("blacklist","Hillary") // 再次添加
client.SAdd("blacklist","the Elder") // 添加新元素
client.SAdd("whitelist","the Elder") // 向 whitelist 添加元素
// 判断元素是否在集合中
isMember,err := client.SIsMember("blacklist","Bush").Result()
if err != nil {
panic(err)
}
fmt.Println("Is Bush in blacklist: ",isMember)
// 求交集,即既在黑名单中,又在白名单中的元素
names,err := client.SInter("blacklist","whitelist").Result()
if err != nil {
panic(err)
}
// 获取到的元素是 "the Elder"
fmt.Println("Inter result: ",names)
// 获取指定集合的所有元素
all,err := client.SMembers("blacklist").Result()
if err != nil {
panic(err)
}
fmt.Println("All member: ",all)
}
hash 操作redis 的 hash 操作: hset(key,field,value)：向名称为key的hash中添加元素field hget(key,field)：返回名称为key的hash中field对应的value hmget(key,(fields))：返回名称为key的hash中field i对应的value hmset(key,(fields))：向名称为key的hash中添加元素field hincrby(key,integer)：将名称为key的hash中field的value增加integer hexists(key,field)：名称为key的hash中是否存在键为field的域 hdel(key,field)：删除名称为key的hash中键为field的域 hlen(key)：返回名称为key的hash中元素个数 hkeys(key)：返回名称为key的hash中所有键 hvals(key)：返回名称为key的hash中所有键对应的value hgetall(key)：返回名称为key的hash中所有的键（field）及其对应的value go-redis 中的 hash 操作: // hash 操作
func hashOperation(client *redis.Client) {
client.HSet("user_xys","name","xys"); // 向名称为 user_xys 的 hash 中添加元素 name
client.HSet("user_xys","age","18"); // 向名称为 user_xys 的 hash 中添加元素 age
// 批量地向名称为 user_test 的 hash 中添加元素 name 和 age
client.HMSet("user_test",map[string]string{"name": "test","age":"20"})
// 批量获取名为 user_test 的 hash 中的指定字段的值.
fields,err := client.HMGet("user_test","age").Result()
if err != nil {
panic(err)
}
fmt.Println("fields in user_test: ",fields)
// 获取名为 user_xys 的 hash 中的字段个数
length,err := client.HLen("user_xys").Result()
if err != nil {
panic(err)
}
fmt.Println("field count in user_xys: ",length) // 字段个数为2
// 删除名为 user_test 的 age 字段
client.HDel("user_test","age")
age,err := client.HGet("user_test","age").Result()
if err != nil {
fmt.Printf("Get user_test age error: %vn",err)
} else {
fmt.Println("user_test age is: ",age) // 字段个数为2
}
}
关于连接池redis.v4 包实现了 redis 的连接池管理,因此我们就不需要自己手动管理 redis 的连接了. client := redis.NewClient(&redis.Options{
Addr: "localhost:6379",PoolSize: 5,})
通过 redis.Options 的 PoolSize 属性,我们设置了 redis 连接池的大小为5. // redis.v4 的连接池管理
func connectPool(client *redis.Client) {
wg := sync.WaitGroup{}
wg.Add(10)
for i := 0; i < 10; i++ {
go func() {
defer wg.Done()
for j := 0; j < 100; j++ {
client.Set(fmt.Sprintf("name%d",j),fmt.Sprintf("xys%d",0).Err()
client.Get(fmt.Sprintf("name%d",j)).Result()
}
fmt.Printf("PoolStats,TotalConns: %d,FreeConns: %dn",client.PoolStats().TotalConns,client.PoolStats().FreeConns);
}()
}
wg.Wait()
}
上面的例子启动了10个 routine 来不断向 redis 读写数据,然后我们通过 client.PoolStats() 获取连接池的信息. 运行这个例子,输出如下: PoolStats,TotalConns: 5,FreeConns: 1 PoolStats,FreeConns: 2 PoolStats,FreeConns: 3 PoolStats,FreeConns: 4 PoolStats,FreeConns: 5 通过输出可以看到,此时最大的连接池数量确实是 5 了,并且一开始时,因为 coroutine 的数量大于5,会造成 redis 连接不足的情况(反映在 FreeConns 上就是前几次的输出 FreeConns 一直是1),当某个 coroutine 结束后,会释放此 redis 连接,因此 FreeConns 会增加. 完整示例//
// author xiongyongshun
// project go_redis
// version 1.0
// created 16/10/6 03:49
//
package main
import (
"fmt"
"gopkg.in/redis.v4"
"time"
"sync"
)
func main() {
client := createClient()
defer client.Close()
stringOperation(client)
listOperation(client)
setOperation(client)
hashOperation(client)
connectPool(client)
}
// 创建 redis 客户端
func createClient() *redis.Client {
client := redis.NewClient(&redis.Options{
Addr: "localhost:6379",})
pong,err)
return client
}
// String 操作
func stringOperation(client *redis.Client) {
// 第三个参数是过期时间,val)
}
// list 操作
func listOperation(client *redis.Client) {
client.RPush("fruit",value)
}
// set 操作
func setOperation(client *redis.Client) {
client.SAdd("blacklist",all)
}
// hash 操作
func hashOperation(client *redis.Client) {
client.HSet("user_xys",age) // 字段个数为2
}
}
// redis.v4 的连接池管理
func connectPool(client *redis.Client) {
wg := sync.WaitGroup{}
wg.Add(10)
for i := 0; i < 10; i++ {
go func() {
defer wg.Done()
for j := 0; j < 100; j++ {
client.Set(fmt.Sprintf("name%d",client.PoolStats().FreeConns);
}()
}
wg.Wait()
} （编辑：李大同） 【声明】本站内容均来自网络，其相关言论仅代表作者个人观点，不代表本站立场。若无意侵犯到您的权利，请及时与联系站长删除相关内容! |