package db // //import ( // "fmt" // "github.com/garyburd/redigo/redis" // "pro2d/conf" // "pro2d/utils" // "time" //) // //type RedisPool struct { // RedisPool *redis.Pool //} // //func (rp *RedisPool)Connect(conf *conf.ServerConf) error { // rp.RedisPool = &redis.Pool{ // //最大活跃连接数,0代表无限 // MaxActive: 888, // MaxIdle: 20, // //闲置连接的超时时间 // IdleTimeout: time.Second * 100, // //定义拨号获得连接的函数 // Dial: func() (redis.Conn, error) { // option := []redis.DialOption{redis.DialDatabase(conf.RedisConf.DB)} // if conf.RedisConf.Auth != "" { // option = append(option, redis.DialPassword(conf.RedisConf.Auth)) // } // return redis.Dial("tcp",conf.RedisConf.Address, option...) // }, // } // return nil //} // //func (rp *RedisPool)Close() { // rp.RedisPool.Close() //} // //func (rp *RedisPool) Insert() error { // conn := rp.RedisPool.Get() // defer conn.Close() // reply, err := conn.Do("HKEYS", fmt.Sprintf("account:%s", "123123")) // if err != nil { // return err // } // // utils.Sugar.Debugf("%v", reply) // reply, err = conn.Do("HMSET", fmt.Sprintf("account:%s", "1231231"), "phone", "1231231", "passwd", "2131231") // if err != nil { // utils.Sugar.Errorf("%v", err) // return err // } // utils.Sugar.Debugf("%v", reply) // return nil //}