|
|
@ -16,7 +16,7 @@ import org.springframework.context.annotation.Configuration; |
|
|
|
* redisson 配置类 |
|
|
|
*/ |
|
|
|
@Slf4j |
|
|
|
//@Configuration
|
|
|
|
@Configuration |
|
|
|
public class RedissonConfig { |
|
|
|
|
|
|
|
@Value("${spring.redis.host}") |
|
|
@ -25,18 +25,14 @@ public class RedissonConfig { |
|
|
|
private String port; |
|
|
|
@Value("${spring.redis.password}") |
|
|
|
private String password; |
|
|
|
@Value("${spring.redis.cluster.nodes}") |
|
|
|
private String clusterNodesStr; |
|
|
|
@Value("${spring.redis.cluster.max-redirects}") |
|
|
|
private Integer rediTimes; |
|
|
|
|
|
|
|
|
|
|
|
@Bean |
|
|
|
public RedissonClient getRedisson() { |
|
|
|
//if (StringUtils.isBlank(host)) {
|
|
|
|
// log.warn("getRedisson redis param is null,don't need to init redissonClient");
|
|
|
|
// return null;
|
|
|
|
//}
|
|
|
|
if (StringUtils.isBlank(host)) { |
|
|
|
log.warn("getRedisson redis param is null,don't need to init redissonClient"); |
|
|
|
return null; |
|
|
|
} |
|
|
|
|
|
|
|
try { |
|
|
|
Config config = new Config(); |
|
|
@ -45,18 +41,10 @@ public class RedissonConfig { |
|
|
|
config.setNettyThreads(NumConstant.FOUR); |
|
|
|
//redis://ip:port
|
|
|
|
//redis的部署方式有单节点部署、主从方式部署、哨兵方式部署、集群方式部署
|
|
|
|
|
|
|
|
//单机模式
|
|
|
|
config.useSingleServer().setAddress("redis://".concat(host).concat(StrConstant.COLON).concat(port)); |
|
|
|
config.useSingleServer().setPassword(password); |
|
|
|
config.useSingleServer().setConnectTimeout(NumConstant.ONE_THOUSAND * NumConstant.FIVE); |
|
|
|
config.useSingleServer().setDatabase(NumConstant.TEN); |
|
|
|
|
|
|
|
//集群模式
|
|
|
|
// config.useClusterServers().addNodeAddress(getClusterNodes());
|
|
|
|
// config.useClusterServers().setPassword(password);
|
|
|
|
// config.useClusterServers().setConnectTimeout(NumConstant.ONE_THOUSAND * NumConstant.FIVE);
|
|
|
|
|
|
|
|
return Redisson.create(config); |
|
|
|
} catch (Exception e) { |
|
|
|
log.error("初始化redisson失败", e); |
|
|
@ -65,20 +53,4 @@ public class RedissonConfig { |
|
|
|
|
|
|
|
} |
|
|
|
|
|
|
|
/** |
|
|
|
* @Description 获取集群节点列表 |
|
|
|
* @param |
|
|
|
* @return java.lang.String[] |
|
|
|
* @author wxz |
|
|
|
* @date 2021.08.23 15:21:28 |
|
|
|
*/ |
|
|
|
private String[] getClusterNodes() { |
|
|
|
log.info("RedssionClient::clusterNodes:{}", clusterNodesStr); |
|
|
|
String[] nodeArray = clusterNodesStr.split(","); |
|
|
|
for (int index = 0; index < nodeArray.length; index++) { |
|
|
|
nodeArray[index] = "redis://".concat(nodeArray[index]); |
|
|
|
} |
|
|
|
return nodeArray; |
|
|
|
} |
|
|
|
|
|
|
|
} |
|
|
|
} |