更新import包

exists.go

@@ -12,12 +12,3 @@ func Exist(key string) (bool, error) {
 	return redisdb.Bool(c.Do("EXISTS", key))
 
 }
-
-//hexists
-func HExist(key string) (bool, error) {
-	c := GetConn()
-	defer c.Close()
-
-	return redisdb.Bool(c.Do("HEXISTS", key))
-
-}

exists_test.go

@@ -1,20 +1,15 @@
 package redis
 
 import (
-	// "strconv"
 	"testing"
-	// "tgo/helper"
 )
 
 func Test_Exists(t *testing.T) {
 
-	RedisInit("10.62.29.23:6379", "123456")
+	RedisInit("127.0.0.1:6379", "123456")
 
-	ret3, err := Exists("testing23")
+	ret3, err := Exists("60007_product2")
 	t.Log(ret3)
 	t.Log(err)
 
-	ret4, err := HExists("testing23", "cc")
-	t.Log(ret4)
-	t.Log(err)
 }

expire.go

@@ -20,3 +20,20 @@ func SetExpire(key string, expire int64) (int64, error) {
 	}
 	return redisdb.Int64(reply, err)
 }
+
+/**
+ * 获取有效期
+ */
+func GetExpire(key string) (int64, error) {
+	c := GetConn()
+	var err error
+	var reply interface{}
+	reply, err = c.Do("TTL", key)
+
+	CloseConn(c)
+
+	if err != nil {
+		return 0, err
+	}
+	return redisdb.Int64(reply, err)
+}

expire_test.go

@@ -0,0 +1,24 @@
+package redis
+
+import (
+	// "strconv"
+	"testing"
+	// "tgo/helper"
+)
+
+func Test_GetExpire(t *testing.T) {
+
+	RedisPassword = "123456"
+	RedisInit("127.0.0.1:6379", RedisPassword)
+
+	Set("test1", "sss")
+
+	ret3, err := SetExpire("test1", 10)
+	t.Log(ret3)
+	t.Log(err)
+
+	ret4, err := GetExpire("test1")
+	t.Log(ret4)
+	t.Log(err)
+
+}

go.mod

@@ -1,9 +1,8 @@
 module git.tetele.net/tgo/redis
 
-go 1.17
+go 1.16
 
 require (
-	git.tetele.net/tgo/conf v0.48.0
 	git.tetele.net/tgo/helper v0.3.1
 	github.com/gomodule/redigo v1.8.8
 )

go.sum

@@ -1,5 +1,3 @@
-git.tetele.net/tgo/conf v0.48.0 h1:goHmxuzkSnoPFJbTVIF7IL13SAINQWWilEQVrRJR9Wg=
-git.tetele.net/tgo/conf v0.48.0/go.mod h1:AWVIBEDE5dtotthUgR0SWaR2Qa6/f+O5WQ3s7Tj8q7A=
 git.tetele.net/tgo/helper v0.3.1 h1:5+6xK6nr2BB1A0XVKrrA8R/GW0y3aUuKUIcz3zgAwZo=
 git.tetele.net/tgo/helper v0.3.1/go.mod h1:89mQwyfqZ+t8YXiVwzSxA70gLlUNqoZGDEUxvV46jXk=
 github.com/davecgh/go-spew v1.1.0 h1:ZDRjVQ15GmhC3fiQ8ni8+OwkZQO4DARzQgrnXU1Liz8=
@@ -11,7 +9,6 @@ github.com/pmezard/go-difflib v1.0.0/go.mod h1:iKH77koFhYxTK1pcRnkKkqfTogsbg7gZN
 github.com/stretchr/objx v0.1.0/go.mod h1:HFkY916IF+rwdDfMAkV7OtwuqBVzrE8GR6GFx+wExME=
 github.com/stretchr/testify v1.7.0 h1:nwc3DEeHmmLAfoZucVR881uASk0Mfjw8xYJ99tb5CcY=
 github.com/stretchr/testify v1.7.0/go.mod h1:6Fq8oRcR53rry900zMqJjRRixrwX3KX962/h/Wwjteg=
-gopkg.in/check.v1 v0.0.0-20161208181325-20d25e280405 h1:yhCVgyC4o1eVCa2tZl7eS0r+SDo693bJlVdllGtEeKM=
 gopkg.in/check.v1 v0.0.0-20161208181325-20d25e280405/go.mod h1:Co6ibVJAznAaIkqp8huTwlJQCZ016jof/cbN4VW5Yz0=
 gopkg.in/yaml.v3 v3.0.0-20200313102051-9f266ea9e77c h1:dUUwHk2QECo/6vqA44rthZ8ie2QXMNeKRTHCNY2nXvo=
 gopkg.in/yaml.v3 v3.0.0-20200313102051-9f266ea9e77c/go.mod h1:K4uyk7z7BCEPqu6E+C64Yfv1cQ7kz7rIZviUmN+EgEM=

hash_test.go

@@ -32,3 +32,10 @@ func Test_HMGet(t *testing.T) {
 	t.Log(err)
 
 }
+
+func Test_HGetAll(t *testing.T) {
+	RedisPassword = "123456"
+	ret3, err := HGetAll("60007_user")
+	t.Log(ret3)
+	t.Log(err)
+}

init.go

@@ -16,7 +16,7 @@ var RedisServerUrl string = "127.0.0.1:6379"
 // redis密码，如需更改，在api服务中设置
 var RedisPassword string = ""
 
-var MaxActive, MaxIdle int
+var MaxActive, MaxIdle int = 1, 1 //最大的激活连接数,最大的空闲连接数
 
 // func init() {
 // 	if Pool == nil {

string_test.go

@@ -0,0 +1,17 @@
+package redis
+
+import (
+	// "strconv"
+	"testing"
+	// "tgo/helper"
+)
+
+func Test_Exists(t *testing.T) {
+
+	RedisInit("127.0.0.1:6379", "123456")
+
+	ret3, err := Exists("60007_product")
+	t.Log(ret3)
+	t.Log(err)
+
+}

zset.go

@@ -42,6 +42,25 @@ func ZAdd(key string, score, member interface{}) (int64, error) {
 
 }
 
+/*
+ * 存值
+ * key 域
+ * member 成员
+ * score 分值
+ */
+func ZAddFloat(key string, score, member interface{}) (float64, error) {
+	c := GetConn()
+
+	reply, err := c.Do("ZADD", key, score, member)
+	CloseConn(c)
+	if err != nil {
+		return 0, err
+	} else {
+		return redisdb.Float64(reply, nil)
+	}
+
+}
+
 /*
  * 删除hash值
  */
@@ -98,6 +117,26 @@ func ZIncrBy(key string, inc, member interface{}) (int64, error) {
 
 }
 
+/*
+ * 自增
+ * key 域
+ * member 成员
+ * inc 分值
+ */
+func ZIncrByFloat(key string, inc, member interface{}) (float64, error) {
+	c := GetConn()
+
+	reply, err := c.Do("ZINCRBY", key, inc, member)
+	CloseConn(c)
+
+	if err != nil {
+		return 0, err
+	} else {
+		return redisdb.Float64(reply, nil)
+	}
+
+}
+
 func ZRange(key string, start, stop int64) ([]map[string]string, error) {
 	c := GetConn()
 	defer CloseConn(c)