...
|
...
|
@@ -33,7 +33,7 @@ public class RedisTask extends Task { |
|
|
this.requests = requests;
|
|
|
|
|
|
try {
|
|
|
client = new Jedis(this.getIp(), this.getPort(), 2 * 1000);
|
|
|
client = new Jedis(this.getIp(), this.getPort(), 5 * 1000);
|
|
|
|
|
|
client.connect();
|
|
|
|
...
|
...
|
@@ -275,8 +275,6 @@ public class RedisTask extends Task { |
|
|
//写主 读主
|
|
|
client.set(testKey.getBytes(), testValue.getBytes());
|
|
|
|
|
|
Thread.sleep(1000);
|
|
|
|
|
|
String testResult = new String(client.get(testKey.getBytes()));
|
|
|
|
|
|
if (StringUtils.equals(testValue, testResult)) {
|
...
|
...
|
|