Merge branch 'master' of https://git.tetele.net/tgo/redisrpc

go.mod

@@ -4,6 +4,7 @@ go 1.14
 
 require (
 	git.tetele.net/tgo/conf v0.35.3
+	git.tetele.net/tgo/helper v0.2.6
 	github.com/chai2010/protorpc v1.0.0
 	github.com/golang/protobuf v1.5.2
 )

go.sum

@@ -2,6 +2,8 @@ git.tetele.net/tgo/conf v0.25.0 h1:fopDch45xw/di5fLvvzwltFiGiXrilMobZwQNO678Wo=
 git.tetele.net/tgo/conf v0.25.0/go.mod h1:DogEBvxG2fGdukpoobTVFE2b4Fd5OTE9FJ3Xetyn47E=
 git.tetele.net/tgo/conf v0.35.3 h1:OQEa87qN5bAbscjMhaoTRinLnv8xZg1WErl5JXgFZco=
 git.tetele.net/tgo/conf v0.35.3/go.mod h1:AWVIBEDE5dtotthUgR0SWaR2Qa6/f+O5WQ3s7Tj8q7A=
+git.tetele.net/tgo/helper v0.2.6 h1:JC+N+If/bGvcwuUSklva17YDNtKBV2Qpvl5RQpMySOY=
+git.tetele.net/tgo/helper v0.2.6/go.mod h1:89mQwyfqZ+t8YXiVwzSxA70gLlUNqoZGDEUxvV46jXk=
 github.com/chai2010/protorpc v1.0.0 h1:aJ45G9sl1utSKo35EqnBSTs5jqTpdJDJAuZMMYPAtFo=
 github.com/chai2010/protorpc v1.0.0/go.mod h1:woR3WwjaQDqFjlzdVsFEKiK5Ur12QL8mYxVPjfr5z54=
 github.com/golang/protobuf v1.0.0/go.mod h1:6lQm79b+lXiMfvg/cZm0SGofjICqVBUtrP5yJMmIC1U=

redis.proto

@@ -130,6 +130,7 @@ service RedisService {
     rpc SAdd(SSetRequest) returns (SSetResponse); //添加进入集合
     rpc SIsmember(SSetRequest) returns (SSetResponse); //集合中是否存在值
     rpc SRem(SSetRequest) returns (SSetResponse); //集合中删除值
+    rpc SCard(SSetRequest) returns (SSetResponse); //获取集合的成员数
     rpc LLpush(LSetRequest) returns (LSetResponse); //列表头部增加值
     rpc LRpush(LSetRequest) returns (LSetResponse); //列表尾部增加值
     rpc LRange(LRangeRequest) returns (HGetListResponse); //列表尾部增加值

string.go

@@ -95,3 +95,27 @@ func Exists(key string, url ...string)(int64, error){
 
 	return res.GetRet(), nil
 }
+
+
+//设置如果不存在
+func SetNx(key, value string, ttl int64, url ...string) (int64, error) {
+
+	conn, _, err := Conn(url...)
+
+	if err != nil {
+		return 0, err
+	}
+	defer conn.Close()
+
+	req := &SetRequest{proto.String(key), proto.String(value), proto.Int64(ttl), nil}
+
+	res := &DelResponse{}
+
+	err = conn.SetNx(req, res)
+
+	if err != nil {
+		return 0, err
+	}
+
+	return res.GetRet(), nil
+}

string_test.go

@@ -27,4 +27,4 @@ func Test_Del(t *testing.T) {
 	t.Log(c)
 	t.Log(err)
 
-}
+}