From 6e2d8bf02f8348d7e07fe0e5136ae034d40ad3ff Mon Sep 17 00:00:00 2001
From: renkaige <renkaige@iie.ac.cn>
Date: Sun, 2 Dec 2018 17:20:34 +0600
Subject: [PATCH] =?UTF-8?q?=E6=B7=BB=E5=8A=A0=E6=B3=A8=E9=87=8A?=
MIME-Version: 1.0
Content-Type: text/plain; charset=UTF-8
Content-Transfer-Encoding: 8bit

---
 .../java/com/nis/web/task/SyncRedisToCluster.java | 15 ++++++++++++---
 1 file changed, 12 insertions(+), 3 deletions(-)

diff --git a/src/main/java/com/nis/web/task/SyncRedisToCluster.java b/src/main/java/com/nis/web/task/SyncRedisToCluster.java
index 8be178f..e9dffc7 100644
--- a/src/main/java/com/nis/web/task/SyncRedisToCluster.java
+++ b/src/main/java/com/nis/web/task/SyncRedisToCluster.java
@@ -87,6 +87,7 @@ public class SyncRedisToCluster {
 		}
 	}
 
+	// 删除之前的key
 	public void deleteRedisKeyStartWith(String redisKeyStartWith) {
 		try {
 			Map<String, JedisPool> clusterNodes = jedisCluster.getClusterNodes();
@@ -142,9 +143,9 @@ public class SyncRedisToCluster {
 				connection.close();// 用完一定要close这个链接！！！
 			}
 		}
-		 for (String string : keys) {
-		 System.out.println(string);
-		 }
+		for (String string : keys) {
+			System.out.println(string);
+		}
 		logger.debug("Keys gotten!");
 		return keys;
 	}
@@ -189,6 +190,7 @@ public class SyncRedisToCluster {
 				}
 				min = Double.parseDouble(start + "");
 				max = Double.parseDouble(end + "");
+				//分批获取,避免一次性获取太多,造成redis阻塞
 				zrangeByScoreWithScores = resource.zrangeByScoreWithScores("MAAT_UPDATE_STATUS", min, max);// 获取所有的maat_update_status
 				syncData(zrangeByScoreWithScores);
 			}
@@ -264,6 +266,13 @@ public class SyncRedisToCluster {
 		return false;
 	}
 
+	/**
+	 * 利用scan模糊匹配key
+	 * 
+	 * @param pattern
+	 * @param resource
+	 * @return
+	 */
 	public List<String> getKeyByScan(String pattern, Jedis resource) {
 		List<String> list = new ArrayList<>();
 		int count = 1000;