更改redis链接方式
This commit is contained in:
@@ -25,8 +25,11 @@ import java.util.List;
|
||||
@Component
|
||||
public class RedisUtilConfig {
|
||||
|
||||
@Value("${redis.host.uri}")
|
||||
private String REDIS_HOST_URI;
|
||||
@Value("${redis.host}")
|
||||
private String host;
|
||||
|
||||
@Value("${redis.password}")
|
||||
private String password;
|
||||
|
||||
@Bean
|
||||
public RedisUtilPool redisUtilPool() {
|
||||
@@ -40,7 +43,8 @@ public class RedisUtilConfig {
|
||||
jedisPoolConfig.setTestOnBorrow(false);
|
||||
|
||||
List<JedisShardInfo> shards = new ArrayList<>();
|
||||
JedisShardInfo jedisShardInfo = new JedisShardInfo(REDIS_HOST_URI);
|
||||
JedisShardInfo jedisShardInfo = new JedisShardInfo(host);
|
||||
jedisShardInfo.setPassword(password);
|
||||
shards.add(jedisShardInfo);
|
||||
redisUtil.setShardedJedisPool(new ShardedJedisPool(jedisPoolConfig, shards));
|
||||
return redisUtil;
|
||||
|
||||
Reference in New Issue
Block a user