redis学习--go redis入门

1、创建客户端

引入包 “github.com/go-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 }

2、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 的 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: %v\n", err ) } fmt.Println( "age", val ) }

3、list 操作

rpush( key, value )：在名称为 key 的 list 尾添加一个值为 value 的元素

lpush( key, value )：在名称为 key 的 list 头添加一个值为 value 的元素

llen( key )：返回名称为 key 的 list 的长度

lrange( key, start, end )：返回名称为 key 的 list 中 start 至 end 之间的元素

ltrim( key, start, 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, key2,… key N, timeout )：lpop 命令的 block 版本。

brpop( key1, key2,… key N, timeout )：rpop 的 block 版本。

rpoplpush( srckey, dstkey )：返回并删除名称为 srckey 的 list 的尾元素，并将该元素添加到名称为 dstkey 的 list 的头部

//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 ) }

4、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, key2,…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 的一个元素

//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 ) }

5、hash 操作

hset( key, field, value )：向名称为 key 的 hash 中添加元素 field

hget( key, field )：返回名称为 key 的 hash 中 field 对应的 value

hmget( key, ( fields ) )：返回名称为 key 的 hash 中 field 对应的 value

hmset( key, ( fields ) )：向名称为 key 的 hash 中添加元素 field

hincrby( key, field, 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

// 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", "name", "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: %v\n", err ) } else { fmt.Println( "user_test age is: ", age ) // 字段个数为2 } }

6、连接池

redis 包实现了 redis 的连接池管理, 因此我们就不需要自己手动管理 redis 的连接了. 默认情况下, redis 的 redis 连接池大小是10, 不过我们可以在初始化 redis 客户端时自行设置连接池

client := redis.NewClient( &redis.Options{ Addr: "localhost:6379", Password: "", DB: 0, PoolSize: 5, } )

学习链接： https://blog.csdn.net/qq_38085855/article/details/83381602