新增redis

RO_Server_Trunk-branch_0.1.39/rorank/client.go

@@ -18,7 +18,7 @@ func Test() {
 	if er != nil {
 		panic(er)
 	}
-	data := myta.Datas{Test: "aaaaa"}
+	data := myta.Datas{Member: "aaaaa", ServerIndex: 1, Score: 555555}
 	var reply int
 	err := c.Call("Rank.Add", data, &reply)
 	if err != nil {

RO_Server_Trunk-branch_0.1.39/rorank/go.mod

@@ -1,8 +1,3 @@
 module rorank
 
 go 1.21.1
-replace rocommon => ../rocommon
-
-require (
-		rocommon v0.0.1
-)

RO_Server_Trunk-branch_0.1.39/rorank/myta/rpc.go

@@ -1,6 +1,7 @@
 package myta
 
 import (
+	"encoding/json"
 	"fmt"
 	"github.com/go-redis/redis"
 	"rocommon/service"
@@ -22,6 +23,25 @@ type Datas struct {
 func (r *Rank) Add(data *Datas, reply *int) error {
 	fmt.Println(data)
 	*reply = 8
-	service.GetRedis().ZAdd(rankTest, redis.Z{Member: data.Member, Score: data.Score})
+	key := rankTest
+	service.GetRedis().ZAdd(key, redis.Z{Member: data.Member, Score: data.Score})
+	return nil
+}
+
+func (r *Rank) GetRankInfo(page, limit int64, reply []Datas) error {
+	key := rankTest
+	s, er := service.GetRedis().ZRange(key, (page-1)*limit, page*limit).Result()
+	if er != nil {
+		return er
+	}
+	reply = make([]Datas, 0)
+	for _, v := range s {
+		d := Datas{}
+		err := json.Unmarshal([]byte(v), &d)
+		if err != nil {
+			return err
+		}
+		reply = append(reply, d)
+	}
 	return nil
 }

RO_Server_Trunk-branch_0.1.39/rorank/redis/init.go

@@ -5,6 +5,6 @@ import (
 )
 
 func init() {
-	cli := service.NewNetRedisConnector([]string{"127.0.0.1:7014"}, "", 127, 0)
+	cli := service.NewNetRedisConnector([]string{"124.222.49.98:6379"}, "", 12, 0)
 	service.SetRedis(cli)
 }