1:安装redigo
go get github.com/garyburd/redigo/redis
2:连接redis(通过ip端口)
import (
"github.com/garyburd/redigo/redis"
)
c, err := redis.Dial("tcp", "192.168.2.225:6379")
if err != nil {
fmt.Println("connect to redis err", err.Error())
return
}
defer c.Close()
3:命令执行
n,err := c.Do("lpush","key","value") //写
result,err := redis.Values(c.Do("lpop","key"))//读
4: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的头部
5:示例
5.1:lpush示例
_,err = c.Do("lpush","mylist","ofo","mobike","foo")
if err != nil {
fmt.Println("redis lpush failed",err.Error())
}
5.2:rpush示例
_,err = c.Do("rpush","mylist","bluegogo","xiaolan","xiaoming")
if err != nil{
fmt.Println("redis rpush failed",err.Error())
}
5.3:llen示例
num,err := c.Do("llen","mylist")
if err != nil{
fmt.Println("mylist get len err",err.Error())
}else{
fmt.Println("mylist's len is ",num)
}
5.4:lrange示例
values,err := redis.Values(c.Do("lrange","mylist",0,10))
if err != nil{
fmt.Println("lrange err",err.Error())
}
fmt.Printf("mylist is:")
for _,v := range values{
fmt.Printf(" %s ",v.([]byte))
}
fmt.Println()
5.5:ltrim示例
_, err = c.Do("ltrim", "mylist", 0, 4)
if err != nil {
fmt.Println("ltrim error", err.Error())
} else {
values, err = redis.Values(c.Do("lrange", "mylist", 0, 4))
if err != nil {
fmt.Println("ltrim failed:", err.Error())
}
fmt.Printf("ltrim mylist is:")
for _, v := range values {
fmt.Printf("%s ", v.([]byte))
}
fmt.Printf("n")
}
5.6:lindex示例
val, err := c.Do("lindex", "mylist", 2)
if err != nil {
fmt.Println("lindex error:", err.Error())
} else {
fmt.Printf("lindex get result :%sn", val)
}
5.7:rpoplpush示例
_, err = c.Do("rpoplpush", "mylist", "mybike")
if err != nil {
fmt.Println("rpoplpush failed:", err.Error())
} else {
values, err = redis.Values(c.Do("lrange", "mylist", 0, 10))
if err != nil {
fmt.Println("lrange failed:", err.Error())
}
for _, v := range values {
fmt.Printf("rpoplpush %sn", v.([]byte))
}
values, err = redis.Values(c.Do("lrange", "mybike", 0, 10))
if err != nil {
fmt.Println("lrange failed:", err.Error())
}
for _, v := range values {
//fmt.Println(string(v.([]byte)))
fmt.Printf("rpoplpush %sn", v.([]byte))
}
}
5.8:lset示例
_, err = c.Do("lset", "mylist", 2, "mysql")
if err != nil {
fmt.Println("lset error:", err.Error())
}
val, err = c.Do("lindex", "mylist", 2)
if err != nil {
fmt.Println("lset error:", err.Error())
} else {
fmt.Printf("lset get result:%sn", val)
}
5.9:lrem示例
_, err = c.Do("lrem", "mylist", 1, "mysql")
if err != nil {
fmt.Println("lrem error", err.Error())
} else {
values, err = redis.Values(c.Do("lrange", "mylist", 0, 10))
if err != nil {
fmt.Println("ltrim failed:", err.Error())
}
for _, v := range values {
fmt.Printf("lrem mylist: %s", v.([]byte))
}
fmt.Printf("n")
}
5.10:lpop示例
_, err = c.Do("lpop", "mylist")
if err != nil {
fmt.Println("lpop failed:", err.Error())
} else {
values, err = redis.Values(c.Do("lrange", "mylist", 0, 10))
if err != nil {
fmt.Println("lpop failed:", err.Error())
}
fmt.Printf("lpop mylist :")
for _, v := range values {
fmt.Printf("lpop mylist %s", v.([]byte))
}
fmt.Printf("n")
}
5.11:rpop示例
_, err = c.Do("rpop", "mylist")
if err != nil {
fmt.Println("rpop failed", err.Error())
} else {
values, err = redis.Values(c.Do("lrange", "mylist", 0, 10))
if err != nil {
fmt.Println("rpop failed:", err.Error())
}
fmt.Printf("rpop mylist :")
for _, v := range values {
//fmt.Println(string(v.([]byte)))
fmt.Printf("lpop mylist %s", v.([]byte))
}
fmt.Printf("n")
}
5.12:blpop示例
res, err := c.Do("blpop", "mylist", 10)
if err != nil {
fmt.Println("blpop error")
} else {
fmt.Printf("blpop from mylist get:%sn", res)
}
res, err = c.Do("blpop", "tmpbike", 10)
if err != nil {
fmt.Println("blpop time out")
} else {
fmt.Println("blpop from tmpbike get:", res)
}
5.13:brpop示例
res, err = c.Do("brpop", "tmpbike", 10)
if err != nil {
fmt.Println("brpop error")
} else {
fmt.Printf("brpop from tmpbike get :%sn", res)
}
res, err = c.Do("brpop", "mybike", 10)
if err != nil {
fmt.Println("brpop time out")
} else {
fmt.Printf("brpop from mybike get:%s ", res)
}
6:结果
完整源码:https://github.com/fang2329/learning/blob/master/redis_test/redis_list.go
发表评论 取消回复