1. 程式人生 > >golang-redis之list型別簡單操作

golang-redis之list型別簡單操作

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中startend之間的元素
ltrim(key, start, end):擷取名稱為key的list
lindex(key, index):返回名稱為key
的list中index位置的元素 lset(key, index, value):給名稱為key的list中index位置的元素賦值 lrem(key, count, value):刪除countkey的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 :%s\n", 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 %s\n", 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 %s\n", 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:%s\n", 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:%s\n", 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 :%s\n", 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:結果
這裡寫圖片描述