From d2e16752cd0f82d039f0587d24f4a3a4bae8bd67 Mon Sep 17 00:00:00 2001
From: withchao <993506633@qq.com>
Date: Mon, 26 Aug 2024 15:28:38 +0800
Subject: [PATCH] feat: online status supports redis cluster

---
 pkg/common/storage/cache/redis/online.go      |  2 +-
 pkg/common/storage/cache/redis/online_test.go | 26 +++++++++----------
 2 files changed, 14 insertions(+), 14 deletions(-)

diff --git a/pkg/common/storage/cache/redis/online.go b/pkg/common/storage/cache/redis/online.go
index 713e84e5c..ee1db7e23 100644
--- a/pkg/common/storage/cache/redis/online.go
+++ b/pkg/common/storage/cache/redis/online.go
@@ -82,7 +82,7 @@ func (s *userOnline) SetUserOnline(ctx context.Context, userID string, online, o
 	for _, platformID := range online {
 		argv = append(argv, platformID)
 	}
-	keys := []string{s.getUserOnlineKey(userID), userID}
+	keys := []string{s.getUserOnlineKey(userID)}
 	platformIDs, err := s.rdb.Eval(ctx, script, keys, argv).StringSlice()
 	if err != nil {
 		log.ZError(ctx, "redis SetUserOnline", err, "userID", userID, "online", online, "offline", offline)
diff --git a/pkg/common/storage/cache/redis/online_test.go b/pkg/common/storage/cache/redis/online_test.go
index 2bda46582..0306f6f5d 100644
--- a/pkg/common/storage/cache/redis/online_test.go
+++ b/pkg/common/storage/cache/redis/online_test.go
@@ -18,18 +18,18 @@ maxRetry: 10
 */
 func TestName111111(t *testing.T) {
 	conf := config.Redis{
-		//Address: []string{
-		//	"172.16.8.48:7001",
-		//	"172.16.8.48:7002",
-		//	"172.16.8.48:7003",
-		//	"172.16.8.48:7004",
-		//	"172.16.8.48:7005",
-		//	"172.16.8.48:7006",
-		//},
-		//ClusterMode: true,
-		//Password:    "passwd123",
-		Address:  []string{"localhost:16379"},
-		Password: "openIM123",
+		Address: []string{
+			"172.16.8.124:7001",
+			"172.16.8.124:7002",
+			"172.16.8.124:7003",
+			"172.16.8.124:7004",
+			"172.16.8.124:7005",
+			"172.16.8.124:7006",
+		},
+		ClusterMode: true,
+		Password:    "passwd123",
+		//Address:  []string{"localhost:16379"},
+		//Password: "openIM123",
 	}
 	ctx, cancel := context.WithTimeout(context.Background(), time.Second*1000)
 	defer cancel()
@@ -39,7 +39,7 @@ func TestName111111(t *testing.T) {
 	}
 	online := NewUserOnline(rdb)
 
-	userID := "123456"
+	userID := "a123456"
 	t.Log(online.GetOnline(ctx, userID))
 	t.Log(online.SetUserOnline(ctx, userID, []int32{1, 2, 3, 4}, nil))
 	t.Log(online.GetOnline(ctx, userID))