From 519df676329c87af23e285a448a94dc734b6094c Mon Sep 17 00:00:00 2001 From: liuxx Date: Tue, 9 Jul 2019 11:13:47 +0800 Subject: [PATCH] Redis metadata supports setting database properties. (#4476) --- .../dubbo/metadata/store/redis/RedisMetadataReport.java | 4 +++- 1 file changed, 3 insertions(+), 1 deletion(-) diff --git a/dubbo-metadata-report/dubbo-metadata-report-redis/src/main/java/org/apache/dubbo/metadata/store/redis/RedisMetadataReport.java b/dubbo-metadata-report/dubbo-metadata-report-redis/src/main/java/org/apache/dubbo/metadata/store/redis/RedisMetadataReport.java index 85e95acbc0..86eb254c70 100644 --- a/dubbo-metadata-report/dubbo-metadata-report-redis/src/main/java/org/apache/dubbo/metadata/store/redis/RedisMetadataReport.java +++ b/dubbo-metadata-report/dubbo-metadata-report-redis/src/main/java/org/apache/dubbo/metadata/store/redis/RedisMetadataReport.java @@ -44,6 +44,7 @@ import static org.apache.dubbo.metadata.identifier.MetadataIdentifier.META_DATA_ */ public class RedisMetadataReport extends AbstractMetadataReport { + private final static String REDIS_DATABASE_KEY = "database"; private final static Logger logger = LoggerFactory.getLogger(RedisMetadataReport.class); JedisPool pool; @@ -62,7 +63,8 @@ public class RedisMetadataReport extends AbstractMetadataReport { jedisClusterNodes.add(new HostAndPort(tmpUrl.getHost(), tmpUrl.getPort())); } } else { - pool = new JedisPool(new JedisPoolConfig(), url.getHost(), url.getPort(), timeout, url.getPassword()); + int database = url.getParameter(REDIS_DATABASE_KEY, 0); + pool = new JedisPool(new JedisPoolConfig(), url.getHost(), url.getPort(), timeout, url.getPassword(), database); } }