Add redigo demo
This commit is contained in:
80
zh/05.6.md
80
zh/05.6.md
@@ -15,7 +15,85 @@ Go目前支持redis的驱动有如下
|
||||
- https://github.com/simonz05/godis
|
||||
- https://github.com/hoisie/redis.go
|
||||
|
||||
目前我fork了最后一个驱动,更新了一些bug,目前应用在我自己的短域名服务项目中(每天200W左右的PV值)
|
||||
我以redigo驱动为例来演示如何进行数据的操作:
|
||||
```Go
|
||||
|
||||
package redis
|
||||
|
||||
import (
|
||||
"fmt"
|
||||
"github.com/garyburd/redigo/redis"
|
||||
"os"
|
||||
"os/signal"
|
||||
"syscall"
|
||||
"time"
|
||||
)
|
||||
|
||||
var (
|
||||
Pool *redis.Pool
|
||||
)
|
||||
|
||||
func init() {
|
||||
redisHost := ":6379"
|
||||
Pool = newPool(redisHost)
|
||||
close()
|
||||
}
|
||||
|
||||
func newPool(server string) *redis.Pool {
|
||||
|
||||
return &redis.Pool{
|
||||
|
||||
MaxIdle: 3,
|
||||
IdleTimeout: 240 * time.Second,
|
||||
|
||||
Dial: func() (redis.Conn, error) {
|
||||
c, err := redis.Dial("tcp", server)
|
||||
if err != nil {
|
||||
return nil, err
|
||||
}
|
||||
return c, err
|
||||
},
|
||||
|
||||
TestOnBorrow: func(c redis.Conn, t time.Time) error {
|
||||
_, err := c.Do("PING")
|
||||
return err
|
||||
},
|
||||
}
|
||||
}
|
||||
|
||||
func close() {
|
||||
c := make(chan os.Signal, 1)
|
||||
signal.Notify(c, os.Interrupt)
|
||||
signal.Notify(c, syscall.SIGTERM)
|
||||
signal.Notify(c, syscall.SIGKILL)
|
||||
go func() {
|
||||
<-c
|
||||
Pool.Close()
|
||||
os.Exit(0)
|
||||
}()
|
||||
}
|
||||
|
||||
func Get(key string) ([]byte, error) {
|
||||
|
||||
conn := Pool.Get()
|
||||
defer conn.Close()
|
||||
|
||||
var data []byte
|
||||
data, err := redis.Bytes(conn.Do("GET", key))
|
||||
if err != nil {
|
||||
return data, fmt.Errorf("error get key %s: %v", key, err)
|
||||
}
|
||||
return data, err
|
||||
}
|
||||
|
||||
func main() {
|
||||
test, err := Get("test")
|
||||
fmt.Println(test, err)
|
||||
}
|
||||
|
||||
```
|
||||
|
||||
另外以前我fork了最后一个驱动,更新了一些bug,目前应用在我自己的短域名服务项目中(每天200W左右的PV值)
|
||||
|
||||
https://github.com/astaxie/goredis
|
||||
|
||||
|
||||
Reference in New Issue
Block a user