本文共 616 字,大约阅读时间需要 2 分钟。
import ( "github.com/garyburd/redigo/redis" "os" "fmt" "strconv" "time")func main() { pool := &redis.Pool{ //最大闲置连接数 MaxIdle: 20, //最大活动连接数 MaxActive: 0, //闲置连接的超时时间 IdleTimeout: time.Second * 1000, //定义拨号获得连接的函数 Dial: func() (redis.Conn, error) { return redis.Dial("tcp", "127.0.0.1:6379") }, } //延时关闭连接池 defer pool.Close() for i := 0; i < 10; i++ { go func(pool *redis.Pool,i int) { conn := pool.Get() defer conn.Close() reply, err := conn.Do("set", "conn"+strconv.Itoa(i), i) s, _ := redis.String(reply, err) fmt.Println(s) }(pool,i) time.Sleep(3*time.Second) }}
转载地址:http://yqdmz.baihongyu.com/