修改redis

@@ -45,7 +45,7 @@ public class RedisMonitorImpl {
     @Getter
     private AtomicLong update=new AtomicLong();
 
-    @Scheduled(fixedRate = 20 * 1000)
+    @Scheduled(fixedRate = 15 * 1000)
     public void monitor() {
         update.set(System.currentTimeMillis());
 

@@ -358,8 +358,6 @@ public class RedisTask extends Task {
                         //主写
                         Jedis masterClient = Constants.JEDIS_POOL_MAP.get(masterUrl).getResource();
 
-                        new Jedis(items[0], Integer.valueOf(items[1]), 2000);
-
                         masterClient.set(testKey.getBytes(), testValue.getBytes());
 
                         masterClient.close();

@@ -238,6 +238,8 @@ public class TwemproxyTask extends Task {
 
                     client.set(testKey.getBytes(), testValue.getBytes());
 
+                    Thread.sleep(3 * 1000);
+
                     String testResult = new String(client.get(testKey.getBytes()));
 
                     if (!StringUtils.equals(testResult, testValue)) {