Parcourir la source

fix:redis集群

Roc il y a 1 an
Parent
commit
a89dd837dd
2 fichiers modifiés avec 6 ajouts et 8 suppressions
  1. 3 4
      utils/redis/cluster_redis.go
  2. 3 4
      utils/redis/standalone_redis.go

+ 3 - 4
utils/redis/cluster_redis.go

@@ -186,11 +186,10 @@ func (rc *ClusterRedisClient) IsExist(key string) bool {
 		return false
 	}
 	if result == 0 {
-		err = rc.redisClient.HDel(context.TODO(), DefaultKey, key).Err()
-		if err != nil {
-			return false
-		}
+		_ = rc.redisClient.HDel(context.TODO(), DefaultKey, key).Err()
+		return false
 	}
+
 	return true
 }
 

+ 3 - 4
utils/redis/standalone_redis.go

@@ -178,11 +178,10 @@ func (rc *StandaloneRedisClient) IsExist(key string) bool {
 		return false
 	}
 	if result == 0 {
-		err = rc.redisClient.HDel(context.TODO(), DefaultKey, key).Err()
-		if err != nil {
-			return false
-		}
+		_ = rc.redisClient.HDel(context.TODO(), DefaultKey, key).Err()
+		return false
 	}
+
 	return true
 }