lts==增加redis密码配置，前缀.configs.redis.password=

@@ -141,5 +141,11 @@
             <artifactId>logback-classic</artifactId>
             <artifactId>logback-classic</artifactId>
             <scope>provided</scope>
             <scope>provided</scope>
         </dependency>
         </dependency>
+        <dependency>
+            <groupId>org.projectlombok</groupId>
+            <artifactId>lombok</artifactId>
+            <version>RELEASE</version>
+            <scope>provided</scope>
+        </dependency>
     </dependencies>
     </dependencies>
 </project>
 </project>

@@ -75,6 +75,10 @@ public interface ExtConfig {
     String REGISTRY_RETRY_PERIOD_KEY = "retry.period";
     String REGISTRY_RETRY_PERIOD_KEY = "retry.period";
     String REDIS_SESSION_TIMEOUT = "redis.session.timeout";
     String REDIS_SESSION_TIMEOUT = "redis.session.timeout";
     /**
     /**
+     * Redis 注册中心密码（开启 requirepass 时使用，多个 redis 节点共用同一密码）
+     */
+    String REDIS_PASSWORD = "redis.password";
+    /**
      * JDBC链接相关配置
      * JDBC链接相关配置
      */
      */
     String JDBC_URL = "jdbc.url";
     String JDBC_URL = "jdbc.url";

@@ -16,6 +16,8 @@ import com.github.ltsopensource.core.registry.NodeRegistryUtils;
 import com.github.ltsopensource.core.registry.NotifyEvent;
 import com.github.ltsopensource.core.registry.NotifyEvent;
 import com.github.ltsopensource.core.registry.NotifyListener;
 import com.github.ltsopensource.core.registry.NotifyListener;
 import com.github.ltsopensource.core.support.SystemClock;
 import com.github.ltsopensource.core.support.SystemClock;
+
+import lombok.extern.slf4j.Slf4j;
 import redis.clients.jedis.Jedis;
 import redis.clients.jedis.Jedis;
 import redis.clients.jedis.JedisPool;
 import redis.clients.jedis.JedisPool;
 import redis.clients.jedis.JedisPoolConfig;
 import redis.clients.jedis.JedisPoolConfig;
@@ -27,6 +29,7 @@ import java.util.concurrent.*;
 /**
 /**
  * @author Robert HG (254963746@qq.com) on 5/17/15.
  * @author Robert HG (254963746@qq.com) on 5/17/15.
  */
  */
+@Slf4j
 public class RedisRegistry extends FailbackRegistry {
 public class RedisRegistry extends FailbackRegistry {
 
 
     private static final Logger LOGGER = LoggerFactory.getLogger(RedisRegistry.class);
     private static final Logger LOGGER = LoggerFactory.getLogger(RedisRegistry.class);
@@ -61,13 +64,24 @@ public class RedisRegistry extends FailbackRegistry {
 
 
         this.reconnectPeriod = config.getParameter(ExtConfig.REGISTRY_RECONNECT_PERIOD_KEY, Constants.DEFAULT_REGISTRY_RECONNECT_PERIOD);
         this.reconnectPeriod = config.getParameter(ExtConfig.REGISTRY_RECONNECT_PERIOD_KEY, Constants.DEFAULT_REGISTRY_RECONNECT_PERIOD);
 
 
+        String password = config.getParameter(ExtConfig.REDIS_PASSWORD);
+        log.info("==============redis=====[{}]", password);
+        boolean hasPassword = password != null && password.length() > 0;
+
         String[] addrs = address.split(",");
         String[] addrs = address.split(",");
         for (String addr : addrs) {
         for (String addr : addrs) {
             int i = addr.indexOf(':');
             int i = addr.indexOf(':');
             String host = addr.substring(0, i);
             String host = addr.substring(0, i);
             int port = Integer.parseInt(addr.substring(i + 1));
             int port = Integer.parseInt(addr.substring(i + 1));
-            this.jedisPools.put(addr, new JedisPool(redisConfig, host, port,
-                    Constants.DEFAULT_TIMEOUT));
+            JedisPool pool;
+            if (hasPassword) {
+                pool = new JedisPool(redisConfig, host, port,
+                        Constants.DEFAULT_TIMEOUT, password);
+            } else {
+                pool = new JedisPool(redisConfig, host, port,
+                        Constants.DEFAULT_TIMEOUT);
+            }
+            this.jedisPools.put(addr, pool);
         }
         }
 
 
         this.expirePeriod = config.getParameter(ExtConfig.REDIS_SESSION_TIMEOUT, Constants.DEFAULT_SESSION_TIMEOUT);
         this.expirePeriod = config.getParameter(ExtConfig.REDIS_SESSION_TIMEOUT, Constants.DEFAULT_SESSION_TIMEOUT);