Add de redigo demo and update link
This commit is contained in:
84
de/05.6.md
84
de/05.6.md
@@ -10,10 +10,90 @@ redis is a key-value storage system like Memcached, that supports the string, li
|
|||||||
|
|
||||||
There are some Go database drivers for redis:
|
There are some Go database drivers for redis:
|
||||||
|
|
||||||
|
- [https://github.com/garyburd/redigo](https://github.com/garyburd/redigo)
|
||||||
|
- [https://github.com/go-redis/redis](https://github.com/go-redis/redis)
|
||||||
|
- [https://github.com/hoisie/redis](https://github.com/hoisie/redis)
|
||||||
- [https://github.com/alphazero/Go-Redis](https://github.com/alphazero/Go-Redis)
|
- [https://github.com/alphazero/Go-Redis](https://github.com/alphazero/Go-Redis)
|
||||||
- [http://code.google.com/p/tideland-rdc/](http://code.google.com/p/tideland-rdc/)
|
|
||||||
- [https://github.com/simonz05/godis](https://github.com/simonz05/godis)
|
- [https://github.com/simonz05/godis](https://github.com/simonz05/godis)
|
||||||
- [https://github.com/hoisie/redis.go](https://github.com/hoisie/redis.go)
|
|
||||||
|
Let's see how to use the driver that redigo to operate on a database:
|
||||||
|
|
||||||
|
```Go
|
||||||
|
|
||||||
|
package main
|
||||||
|
|
||||||
|
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)
|
||||||
|
}
|
||||||
|
|
||||||
|
```
|
||||||
|
|
||||||
I forked the last of these packages, fixed some bugs, and used it in my short URL service (2 million PV every day).
|
I forked the last of these packages, fixed some bugs, and used it in my short URL service (2 million PV every day).
|
||||||
|
|
||||||
|
|||||||
Reference in New Issue
Block a user