|
@ -9,7 +9,14 @@ import ( |
|
|
|
|
|
|
|
|
// 定义redis链接池
|
|
|
// 定义redis链接池
|
|
|
var Pool *redisdb.Pool |
|
|
var Pool *redisdb.Pool |
|
|
var redisServerUrl string = "127.0.0.1:6379" |
|
|
|
|
|
|
|
|
|
|
|
|
|
|
// redis服务地址,如需更改,在api服务中设置
|
|
|
|
|
|
var RedisServerUrl string = "127.0.0.1:6379" |
|
|
|
|
|
|
|
|
|
|
|
// redis密码,如需更改,在api服务中设置
|
|
|
|
|
|
var RedisPassword string = "" |
|
|
|
|
|
|
|
|
|
|
|
var MaxActive, MaxIdle int = 1, 1 //最大的激活连接数,最大的空闲连接数
|
|
|
|
|
|
|
|
|
// func init() {
|
|
|
// func init() {
|
|
|
// if Pool == nil {
|
|
|
// if Pool == nil {
|
|
@ -17,18 +24,18 @@ var redisServerUrl string = "127.0.0.1:6379" |
|
|
// }
|
|
|
// }
|
|
|
// }
|
|
|
// }
|
|
|
|
|
|
|
|
|
func Conn(server_url ...string) { |
|
|
|
|
|
var url string = "127.0.0.1:6379" |
|
|
|
|
|
if len(server_url) > 0 { |
|
|
|
|
|
url = server_url[0] |
|
|
|
|
|
} |
|
|
|
|
|
RedisInit(url) |
|
|
|
|
|
|
|
|
func Conn() { |
|
|
|
|
|
RedisInit(RedisServerUrl, RedisPassword, MaxActive, MaxIdle) |
|
|
} |
|
|
} |
|
|
|
|
|
|
|
|
// 初始化redis链接池
|
|
|
|
|
|
func RedisInit(serverUrl string, max ...int) { |
|
|
|
|
|
|
|
|
/* |
|
|
|
|
|
* 初始化redis链接池 |
|
|
|
|
|
* @param serverUrl 服务地址 |
|
|
|
|
|
* @param password 密码 |
|
|
|
|
|
* @param max 最大的激活连接数,最大的空闲连接数 |
|
|
|
|
|
*/ |
|
|
|
|
|
func RedisInit(serverUrl, password string, max ...int) { |
|
|
|
|
|
|
|
|
var MaxActive, MaxIdle int |
|
|
|
|
|
if len(max) > 0 { |
|
|
if len(max) > 0 { |
|
|
MaxActive = max[0] |
|
|
MaxActive = max[0] |
|
|
} |
|
|
} |
|
@ -37,7 +44,10 @@ func RedisInit(serverUrl string, max ...int) { |
|
|
} |
|
|
} |
|
|
|
|
|
|
|
|
if serverUrl != "" { |
|
|
if serverUrl != "" { |
|
|
redisServerUrl = serverUrl |
|
|
|
|
|
|
|
|
RedisServerUrl = serverUrl |
|
|
|
|
|
} |
|
|
|
|
|
if password != "" { |
|
|
|
|
|
RedisPassword = password |
|
|
} |
|
|
} |
|
|
|
|
|
|
|
|
Pool = &redisdb.Pool{ |
|
|
Pool = &redisdb.Pool{ |
|
@ -50,16 +60,18 @@ func RedisInit(serverUrl string, max ...int) { |
|
|
func redisConn() (redisdb.Conn, error) { |
|
|
func redisConn() (redisdb.Conn, error) { |
|
|
|
|
|
|
|
|
dbOption := redisdb.DialDatabase(0) |
|
|
dbOption := redisdb.DialDatabase(0) |
|
|
pwOption := redisdb.DialPassword("") |
|
|
|
|
|
|
|
|
pwOption := redisdb.DialPassword(RedisPassword) |
|
|
// **重要** 设置读写超时
|
|
|
// **重要** 设置读写超时
|
|
|
readTimeout := redisdb.DialReadTimeout(time.Second * time.Duration(2)) |
|
|
readTimeout := redisdb.DialReadTimeout(time.Second * time.Duration(2)) |
|
|
writeTimeout := redisdb.DialWriteTimeout(time.Second * time.Duration(5)) |
|
|
writeTimeout := redisdb.DialWriteTimeout(time.Second * time.Duration(5)) |
|
|
conTimeout := redisdb.DialConnectTimeout(time.Second * time.Duration(2)) |
|
|
conTimeout := redisdb.DialConnectTimeout(time.Second * time.Duration(2)) |
|
|
|
|
|
|
|
|
c, err := redisdb.Dial("tcp", redisServerUrl, dbOption, pwOption, readTimeout, writeTimeout, conTimeout) |
|
|
|
|
|
|
|
|
c, err := redisdb.Dial("tcp", RedisServerUrl, dbOption, pwOption, readTimeout, writeTimeout, conTimeout) |
|
|
if err != nil { |
|
|
if err != nil { |
|
|
log.Println("redis server connect failed", err) |
|
|
|
|
|
|
|
|
log.Println("redis connect failed", err) |
|
|
return nil, err |
|
|
return nil, err |
|
|
|
|
|
} else { |
|
|
|
|
|
log.Println("redis connected", RedisServerUrl) |
|
|
} |
|
|
} |
|
|
return c, nil |
|
|
return c, nil |
|
|
} |
|
|
} |