|
|
@@ -1,4 +1,5 @@
|
|
|
package redis_util
|
|
|
+
|
|
|
import (
|
|
|
"log"
|
|
|
"strings"
|
|
|
@@ -7,8 +8,10 @@ import (
|
|
|
redisLogin "github.com/gomodule/redigo/redis"
|
|
|
)
|
|
|
|
|
|
+// RedisLoginPool 用于登陆的Redis连接池
|
|
|
var RedisLoginPool *redisLogin.Pool
|
|
|
|
|
|
+// InitRedisLogin 初始化用于登陆的Redis连接池
|
|
|
func InitRedisLogin(addrs string) {
|
|
|
addr := strings.Split(addrs, ",")
|
|
|
for _, v := range addr {
|
|
|
@@ -27,14 +30,14 @@ func InitRedisLogin(addrs string) {
|
|
|
|
|
|
}
|
|
|
|
|
|
-//
|
|
|
+// SetLoginVal 设置K，V值 用于登陆的Redis
|
|
|
func SetLoginVal(key, value string) {
|
|
|
conn := RedisLoginPool.Get()
|
|
|
defer conn.Close()
|
|
|
conn.Do("PUBLISH", key, value)
|
|
|
}
|
|
|
|
|
|
-//
|
|
|
+// GetLoginVal 获取置Key，并透传到入参处理函数 用于登陆的Redis
|
|
|
func GetLoginVal(key string, wxFunc func(wxParams []string) bool) {
|
|
|
for {
|
|
|
defer catch()
|
