package db
  
  import (
  	"github.com/garyburd/redigo/redis"

  	"time"
  )
  var RedisPool *redis.Pool
  

  //conf *conf.ServerConf
  func ConnectRedis(db int, auth, address string) error {

  	RedisPool = &redis.Pool{
  		//最大活跃连接数，0代表无限
  		MaxActive: 888,
  		MaxIdle: 20,
  		//闲置连接的超时时间
  		IdleTimeout: time.Second * 100,
  		//定义拨号获得连接的函数
  		Dial: func() (redis.Conn, error) {

  			option := []redis.DialOption{redis.DialDatabase(db)}
  			if auth != "" {
  				option = append(option, redis.DialPassword(auth))

  			}

  			return redis.Dial("tcp",address, option...)

  		},
  	}
  	return nil
  }
  
  func CloseRedis()  {
  	RedisPool.Close()
  }
  
  func HKEYS(args ...interface{}) (reply interface{}, err error) {
  	conn := RedisPool.Get()
  	defer conn.Close()
  	return conn.Do("HKEYS", args)
  }
  
  func HMSET(args ...interface{})  (reply interface{}, err error) {
  	conn := RedisPool.Get()
  	defer conn.Close()
  	return conn.Do("HMSET", args)
  }