Go實戰--golang中使用redis(redigo和go-redis/redis)

開源庫redigo的使用

github地址：
https://github.com/garyburd/redigo

文檔地址：
http://godoc.org/github.com/garyburd/redigo/redis

獲取：

go get github.com/garyburd/redigo/redis

連接redis

package main import ( "fmt" "github.com/garyburd/redigo/redis" ) func main() { c, err := redis.Dial("tcp", "127.0.0.1:6379") if err != nil { fmt.Println("Connect to redis error", err) return } defer c.Close() } 

讀寫
這里寫入的值永遠不會過期

package main

import (
    "fmt" "github.com/garyburd/redigo/redis" ) func main() { c, err := redis.Dial("tcp", "127.0.0.1:6379") if err != nil { fmt.Println("Connect to redis error", err) return } defer c.Close() _, err = c.Do("SET", "mykey", "superWang") if err != nil { fmt.Println("redis set failed:", err) } username, err := redis.String(c.Do("GET", "mykey")) if err != nil { fmt.Println("redis get failed:", err) } else { fmt.Printf("Get mykey: %v \n", username) } } 

如何設置過期呢，可以使用SET的附加參數：

package main

import (
    "fmt" "time" "github.com/garyburd/redigo/redis" ) func main() { c, err := redis.Dial("tcp", "127.0.0.1:6379") if err != nil { fmt.Println("Connect to redis error", err) return } defer c.Close() _, err = c.Do("SET", "mykey", "superWang", "EX", "5") if err != nil { fmt.Println("redis set failed:", err) } username, err := redis.String(c.Do("GET", "mykey")) if err != nil { fmt.Println("redis get failed:", err) } else { fmt.Printf("Get mykey: %v \n", username) } time.Sleep(8 * time.Second) username, err = redis.String(c.Do("GET", "mykey")) if err != nil { fmt.Println("redis get failed:", err) } else { fmt.Printf("Get mykey: %v \n", username) } } 

輸出：
Get mykey: superWang
redis get failed: redigo: nil returned

批量寫入讀取

MGET key [key …]
MSET key value [key value …]

批量寫入讀取對象(Hashtable)
HMSET key field value [field value …]
HMGET key field [field …]

檢測值是否存在
EXISTS key

package main

import (
    "fmt" "github.com/garyburd/redigo/redis" ) func main() { c, err := redis.Dial("tcp", "127.0.0.1:6379") if err != nil { fmt.Println("Connect to redis error", err) return } defer c.Close() _, err = c.Do("SET", "mykey", "superWang") if err != nil { fmt.Println("redis set failed:", err) } is_key_exit, err := redis.Bool(c.Do("EXISTS", "mykey1")) if err != nil { fmt.Println("error:", err) } else { fmt.Printf("exists or not: %v \n", is_key_exit) } } 

輸出：
exists or not: false

刪除
DEL key [key …]

package main

import (
    "fmt" "github.com/garyburd/redigo/redis" ) func main() { c, err := redis.Dial("tcp", "127.0.0.1:6379") if err != nil { fmt.Println("Connect to redis error", err) return } defer c.Close() _, err = c.Do("SET", "mykey", "superWang") if err != nil { fmt.Println("redis set failed:", err) } username, err := redis.String(c.Do("GET", "mykey")) if err != nil { fmt.Println("redis get failed:", err) } else { fmt.Printf("Get mykey: %v \n", username) } _, err = c.Do("DEL", "mykey") if err != nil { fmt.Println("redis delelte failed:", err) } username, err = redis.String(c.Do("GET", "mykey")) if err != nil { fmt.Println("redis get failed:", err) } else { fmt.Printf("Get mykey: %v \n", username) } } 

輸出：
Get mykey: superWang
redis get failed: redigo: nil returned

讀寫json到redis

package main import ( "encoding/json" "fmt" "github.com/garyburd/redigo/redis" ) func main() { c, err := redis.Dial("tcp", "127.0.0.1:6379") if err != nil { fmt.Println("Connect to redis error", err) return } defer c.Close() key := "profile" imap := map[string]string{"username": "666", "phonenumber": "888"} value, _ := json.Marshal(imap) n, err := c.Do("SETNX", key, value) if err != nil { fmt.Println(err) } if n == int64(1) { fmt.Println("success") } var imapGet map[string]string valueGet, err := redis.Bytes(c.Do("GET", key)) if err != nil { fmt.Println(err) } errShal := json.Unmarshal(valueGet, &imapGet) if errShal != nil { fmt.Println(err) } fmt.Println(imapGet["username"]) fmt.Println(imapGet["phonenumber"]) } 

設置過期時間
EXPIRE key seconds

// 設置過期時間為24小時 n, _ := rs.Do("EXPIRE", key, 24*3600) if n == int64(1) { fmt.Println("success") } 

列表操作
命令：

redis 127.0.0.1:6379> LPUSH runoobkey redis (integer) 1 redis 127.0.0.1:6379> LPUSH runoobkey mongodb (integer) 2 redis 127.0.0.1:6379> LPUSH runoobkey mysql (integer) 3 redis 127.0.0.1:6379> LRANGE runoobkey 0 10 1) "mysql" 2) "mongodb" 3) "redis" 

代碼實現：

package main

import (
    "fmt" "github.com/garyburd/redigo/redis" ) func main() { c, err := redis.Dial("tcp", "127.0.0.1:6379") if err != nil { fmt.Println("Connect to redis error", err) return } defer c.Close() _, err = c.Do("lpush", "runoobkey", "redis") if err != nil { fmt.Println("redis set failed:", err) } _, err = c.Do("lpush", "runoobkey", "mongodb") if err != nil { fmt.Println("redis set failed:", err) } _, err = c.Do("lpush", "runoobkey", "mysql") if err != nil { fmt.Println("redis set failed:", err) } values, _ := redis.Values(c.Do("lrange", "runoobkey", "0", "100")) for _, v := range values { fmt.Println(string(v.([]byte))) } } 

輸出：
mysql
mongodb
redis

管道

請求/響應服務可以實現持續處理新請求，即使客戶端沒有准備好讀取舊響應。這樣客戶端可以發送多個命令到服務器而無需等待響應，最后在一次讀取多個響應。這就是管道化(pipelining)，這個技術在多年就被廣泛使用了。距離，很多POP3協議實現已經支持此特性，顯著加速了從服務器下載新郵件的過程。
Redis很早就支持管道化，所以無論你使用任何版本，你都可以使用管道化技術

連接支持使用Send()，Flush()，Receive()方法支持管道化操作

Send(commandName string, args ...interface{}) error Flush() error Receive() (reply interface{}, err error) 

Send向連接的輸出緩沖中寫入命令。Flush將連接的輸出緩沖清空並寫入服務器端。Recevie按照FIFO順序依次讀取服務器的響應。下例展示了一個簡單的管道：

c.Send("SET", "foo", "bar") c.Send("GET", "foo") c.Flush() c.Receive() // reply from SET v, err = c.Receive() // reply from GET 

Do方法組合了Send,Flush和 Receive方法。Do方法先寫入命令，然后清空輸出buffer，最后接收全部掛起響應包括Do方發出的命令的結果。如果任何響應中包含一個錯誤，Do返回錯誤。如果沒有錯誤，Do方法返回最后一個響應。

開源庫go-redis/redis的使用

github地址：
https://github.com/go-redis/redis

文檔地址：
https://godoc.org/github.com/go-redis/redis

獲取：

go get -u github.com/go-redis/redis

應用：

package main

import (
    "fmt" "github.com/go-redis/redis" ) func main() { client := redis.NewClient(&redis.Options{ Addr: "127.0.0.1:6379", Password: "", // no password set DB: 0, // use default DB }) pong, err := client.Ping().Result() fmt.Println(pong, err) err = client.Set("key", "value", 0).Err() if err != nil { panic(err) } val, err := client.Get("key").Result() if err != nil { panic(err) } fmt.Println("key", val) val2, err := client.Get("key2").Result() if err == redis.Nil { fmt.Println("key2 does not exists") } else if err != nil { panic(err) } else { fmt.Println("key2", val2) } } 

輸出：
PONG
key value
key2 does not exists