摘要：
=nil｛fmt.Println（“connrisfailed，”，err）return｝defec。Close（）_，错误=c。Do（“HSet”，“books”，“abc”，100）ifer！=nil｛fmt.Println（err）return｝r，err:=redis.Int（c.Do（“HGet”，“books”，“abc”））ifer！=nil｛fmt.Println（“getabcfailed，”，err）return｝fmt.Println（r）｝listpackagemainimport（“fmt”“github.com/garyburd/redigo/redis”）funcmain（）｛c，err:=redis.Dial（“tcp”，“localhost:6379”）ifer！=nil｛fmt.PrintIn（“connrisfailed”，err）return}defec。Close（）_，错误=c。Do（“lpush”，“book_list”，“abc”，“ceg”，300）ifer！=nil｛fmt.Println（err）return｝r，err:=redis.String（c.Do（“lpop”，“book_list”））ifer！=nil｛fmt.Println（“getabcfailed，”，err）return｝fmt.Println（r）｝setpackagemainimport（“fmt”“github.com/garyburd/redigo/redis”）funcmain（）｛varp*intvarintp=&a*p=0c，err:=redis.Diall（“tcp”，“localhost:6379”）ifer！=nil{fmt.PrintIn（“connrisfailed，”）return｝defec。Close（）_，错误=c。Do（“Set”，“abc”，100）ifer！=nil｛fmt.Println（err）return｝r，err:=redis.Int（c.Do（“Get”，“abc”））ifer！=nil｛fmt.Println（“getabcfailed，”，err）return｝fmt。Println（r）}batch_setpackagemainimport（“fmt”“github.com/garyburd/redigo/redis”）funcmain（）｛c，err:=redis.Dial（“tcp”，“localhost:6379”）ifer！=nil｛fmt.Println（“connrisfailed，”，err）return｝defec。Close（）_，错误=c。Do（“MSet”，“abc”，100，“efg”，300）ifer！=nil｛fmt.Println（err）return｝r，err:=redis.Ints（c.Do（“MGet”，“abc”，“efg”））ifer！=nil｛fmt.Println（“getabcfailed，”，err）return｝for_，v:=ranger｛fmt.Println（v）｝｝过期设置packagemainimport（“fmt”“github.com/garyburd/redigo/redis”）funcmin（）｛c，err:=redis.Dial（“tcp”，“localhost:6379”）ifer！=nil｛fmt.PrintIn（“connrisfailed，”）return｝defer。Close（）_，错误=c。Do（“expire”，“abc”，10）ifer！=Nil｛fmt.Println（err）return｝｝连接池packagemainimport（“fmt”“github.com/garyburd/redigo/redis”）varpool*redis。Poolfuncinit（）｛pool=&edits.pool｛MaxIdle:16，MaxActive:0，IdleTimeout:300，Dial:func（）（redis.Cnn，error）｛returnredis.Dial（“tcp”，“localhost:6379”）｝，｝｝funcmain（）｛c:=pool.Get（）defer.Close（）_，err:=c.Do（“Set”，“abc”，100）ifer！=nil｛fmt.Println（err）return｝r，err:=redis。Int（c.Do（“Get”，“abc”）ifer=nil｛fmt.Println（“getabcfailed，”，err）return｝fmt.Println（r）pool.Close（）｝
一.golang中安装Redis
github地址:https://github.com/garyburd/redigo
文档地址:http://godoc.org/github.com/garyburd/redigo/redis
安装:
go get github.com/garyburd/redigo/redis
二.简单连接Redis
conn
package main import ( "fmt" "github.com/garyburd/redigo/redis" ) func main() { c, err := redis.Dial("tcp", "localhost:6379") if err != nil { fmt.Println("conn redis failed,", err) return } defer c.Close() }
hset
package main import ( "fmt" "github.com/garyburd/redigo/redis" ) func main() { c, err := redis.Dial("tcp", "localhost:6379") if err != nil { fmt.Println("conn redis failed,", err) return } defer c.Close() _, err = c.Do("HSet", "books", "abc", 100) if err != nil { fmt.Println(err) return } r, err := redis.Int(c.Do("HGet", "books", "abc")) if err != nil { fmt.Println("get abc failed,", err) return } fmt.Println(r) }
list
package main import ( "fmt" "github.com/garyburd/redigo/redis" ) func main() { c, err := redis.Dial("tcp", "localhost:6379") if err != nil { fmt.Println("conn redis failed,", err) return } defer c.Close() _, err = c.Do("lpush", "book_list", "abc", "ceg", 300) if err != nil { fmt.Println(err) return } r, err := redis.String(c.Do("lpop", "book_list")) if err != nil { fmt.Println("get abc failed,", err) return } fmt.Println(r) }
set
package main import ( "fmt" "github.com/garyburd/redigo/redis" ) func main() { var p *int var a int p = &a *p = 0 c, err := redis.Dial("tcp", "localhost:6379") if err != nil { fmt.Println("conn redis failed,", err) return } defer c.Close() _, err = c.Do("Set", "abc", 100) if err != nil { fmt.Println(err) return } r, err := redis.Int(c.Do("Get", "abc")) if err != nil { fmt.Println("get abc failed,", err) return } fmt.Println(r) }
batch_set
package main import ( "fmt" "github.com/garyburd/redigo/redis" ) func main() { c, err := redis.Dial("tcp", "localhost:6379") if err != nil { fmt.Println("conn redis failed,", err) return } defer c.Close() _, err = c.Do("MSet", "abc", 100, "efg", 300) if err != nil { fmt.Println(err) return } r, err := redis.Ints(c.Do("MGet", "abc", "efg")) if err != nil { fmt.Println("get abc failed,", err) return } for _, v := range r { fmt.Println(v) } }
过期设置
package main import ( "fmt" "github.com/garyburd/redigo/redis" ) func main() { c, err := redis.Dial("tcp", "localhost:6379") if err != nil { fmt.Println("conn redis failed,", err) return } defer c.Close() _, err = c.Do("expire", "abc", 10) if err != nil { fmt.Println(err) return } }
连接池
package main import ( "fmt" "github.com/garyburd/redigo/redis" ) var pool *redis.Pool func init() { pool = &redis.Pool{ MaxIdle: 16, MaxActive: 0, IdleTimeout: 300, Dial: func() (redis.Conn, error) { return redis.Dial("tcp", "localhost:6379") }, } } func main() { c := pool.Get() defer c.Close() _, err := c.Do("Set", "abc", 100) if err != nil { fmt.Println(err) return } r, err := redis.Int(c.Do("Get", "abc")) if err != nil { fmt.Println("get abc failed,", err) return } fmt.Println(r) pool.Close() }