optimize redis config

Author: ellios

hedwig-redis-client/src/main/java/me/ellios/jedis/support/AbstractRedisClient.java

@@ -119,10 +119,16 @@ public <T> T executeWithJedis(OpType type, JedisCallback<T> callback) {
                 //Redis Connection is broken
                 broken = true;
                 if(tryCount < 3){
-                    LOG.warn("fail to execute callback in redis host : {} port : {}, error : {}, try again tryCount : {}",
-                            jedisLocal.get().getKey().getClient().getHost(),
-                            jedisLocal.get().getKey().getClient().getPort(),
-                            e.getMessage(), tryCount);
+                    if(jedisLocal.get() != null){
+                        LOG.warn("fail to execute callback in redis host : {} port : {}, error : {}, try again tryCount : {}",
+                                jedisLocal.get().getKey().getClient().getHost(),
+                                jedisLocal.get().getKey().getClient().getPort(),
+                                e.getMessage(), tryCount);
+                    }else{
+                        LOG.warn("fail to execute callback in redis for redis not found. error : {}, try again tryCount : {}",
+                                e.getMessage(), tryCount);
+                    }
+
                     try {
                         Thread.sleep(50);
                     } catch (InterruptedException e1) {

hedwig-redis-client/src/test/java/me/ellios/redis/RedisClientTest.java

@@ -20,6 +20,16 @@ public class RedisClientTest {
 
     RedisClient client = RedisClientFactory.getRedisClient("test");
 
+    @Test
+    public void testAuth() throws Exception {
+        client.set("ellios1", "hello".getBytes());
+        String result = client.get("ellios1");
+
+        System.out.println("====================================");
+        System.out.println(result);
+        System.out.println("====================================");
+    }
+
     @Test
     public void testGet() throws Exception {
         client.set("ellios1", "hello".getBytes());

hedwig-redis-client/src/test/resources/hedwig.properties

@@ -1,2 +1,2 @@
-hedwig.env=test
+hedwig.env=prod
 hedwig.zk.group=

hedwig-registry/src/main/java/me/ellios/hedwig/rpc/core/ServiceConfig.java

@@ -12,7 +12,7 @@
 public class ServiceConfig {
 
     public static final int DEFAULT_SERVICE_PORT = 8888;
-    public static final int DEFAULT_MAX_FRAME_SIZE = 2 * 1024 * 1024; //2M
+    public static final int DEFAULT_MAX_FRAME_SIZE = 3 * 1024 * 1024; //3M
     public static final String DEFAULT_SERVICE_GROUP = "";
     private int maxFrameSize = DEFAULT_MAX_FRAME_SIZE;
     private String name;