57 lines
1.2 KiB
Go
57 lines
1.2 KiB
Go
package main
|
||
|
||
import (
|
||
"fmt"
|
||
"time"
|
||
|
||
redigo "github.com/gomodule/redigo/redis"
|
||
"myschools.me/suguo/tutorial-redis/conf"
|
||
)
|
||
|
||
func main() {
|
||
pool := &redigo.Pool{
|
||
Dial: func() (redigo.Conn, error) {
|
||
return redigo.Dial("tcp", conf.Host,
|
||
redigo.DialDatabase(conf.Database),
|
||
redigo.DialPassword(conf.Password),
|
||
)
|
||
},
|
||
TestOnBorrow: func(c redigo.Conn, t time.Time) error {
|
||
if time.Since(t) < time.Minute {
|
||
return nil
|
||
}
|
||
_, err := c.Do("PING")
|
||
return err
|
||
},
|
||
MaxIdle: 100,
|
||
MaxActive: 100,
|
||
IdleTimeout: 60 * time.Second,
|
||
Wait: false,
|
||
MaxConnLifetime: 0,
|
||
}
|
||
|
||
fmt.Printf("连接数：%d\n", pool.ActiveCount())
|
||
|
||
conn := pool.Get()
|
||
defer conn.Close()
|
||
|
||
//判断key是否存在
|
||
a, _ := conn.Do("EXISTS", "cp01")
|
||
i := a.(int64)
|
||
fmt.Printf("cp01的key是否存在：%d\n", i)
|
||
if i > 0 {
|
||
data, err := redigo.Bytes(conn.Do("GET", "cp01"))
|
||
if err != nil {
|
||
fmt.Printf("GET redis错误: %s\n", err.Error())
|
||
}
|
||
fmt.Printf("cp01内容：%s\n", data)
|
||
}
|
||
|
||
//设置一个值，单位s
|
||
r, err := conn.Do("SETEX", "cp01", 600, []byte("ABCDEFGHIJKLMNOPQRSTUVWXYZ"))
|
||
if err != nil {
|
||
fmt.Printf("写入redis错误: %s\n", err.Error())
|
||
}
|
||
fmt.Printf("cp01写入后的返回：%v\n", r)
|
||
}
|