赞
踩
本篇文章和大家分享下golang如何使用redis,包括redis的连接,及redis五种常用数据结构的key-value设定。
redis客户端使用依赖包为:github.com/garyburd/redigo/redis
字符串数据结构的key-value设定,通用命令为 set key value [EX seconds] [PX milliseconds][NX|XX],其中:
EX:表示为key设置秒级过期时间;
PX:表示为key设置毫秒级过期时间;
NX:表示key必须不存在,才可以设置成功,用于添加;
XX:表示key必须存在,才可以设置成功,用于更新。
同时,可以使用SETEX key value [EX seconds][PX milliseconds]。
注:
基于redis分布式锁的实现
可用setnx获取锁,获取锁后用expire给锁加上过期时间,防止锁忘记释放。如果setnx执行之后expire执行之前,线程死掉,那锁用于得不到释放,发生死锁。
改进方案:使用set key value [EX seconds] [PX milliseconds][NX|XX]一条指令,把setnx和expire***原子化***结合起来
下面代码可参考的样例包括:
package main import ( "encoding/json" "fmt" "github.com/garyburd/redigo/redis" ) func main(){ //redis服务端的连接 client, err := redis.Dial("tcp","10.96.78.48:6379") if err != nil { fmt.Println("Connet to redis error", err) return } defer client.Close() //字符串数据结构key-value设定,其中key为"stringKey",value为"hello world!" stringReply, err := client.Do("SET", "stringKey", "hello world!") /*对于已存在的key值再次设定,不同的设定方法,不同的回复 reply, err := client.Do("SETNX","stringKey","hello") //while key exist, update key fail, reply is 0 reply, err := client.Do("SET", "stringKey", "hello", "NX") //while key exist, update key fail, reply is nil reply, err := client.Do("SET", "stringKey", "hello", "XX") //while key exist, update key success, reply is ok; while key not exist, set key fail, reply is nil //两种设置过期时间方式 方法一:reply, err := client.Do("SET", "stringKey", "hello", "EX", "5") 方法二:reply, err := client.Do("EXPIPE", "stringKey", "5")*/ if err != nil { fmt.Println("redis set string key failed:",err) return } fmt.Println(stringReply) strKeyValue, err := redis.String(client.Do("GET","stringKey")) if err != nil { fmt.Println("redis get string key failed:",err) }else{ fmt.Printf("Get string key: %v\n", strKeyValue) } //EXIST key is_key_exist, err
Copyright © 2003-2013 www.wpsshop.cn 版权所有,并保留所有权利。