大家好,又见面了,我是你们的朋友全栈君。如果您正在找激活码,请点击查看最新教程,关注关注公众号 “全栈程序员社区” 获取激活教程,可能之前旧版本教程已经失效.最新Idea2022.1教程亲测有效,一键激活。
Jetbrains全系列IDE使用 1年只要46元 售后保障 童叟无欺
<dependency>
<groupId>redis.clients</groupId>
<artifactId>jedis</artifactId>
</dependency>
spring:
redis:
password: 123456
database: 0
cluster:
nodes:
- 192.168.119.101:6111
- 192.168.119.101:6112
- 192.168.119.101:6113
- 192.168.119.101:6114
- 192.168.119.101:6115
- 192.168.119.101:6116
maxAttempts: 3
password: mypassword
jedis:
pool:
max-active: 1000
max-idle: 10
max-wait: -1
min-idle: 5
timeout: 6000
@Data
@Configuration
@ConfigurationProperties(prefix = "spring.redis")
@NoArgsConstructor
public class RedisProperties {
private int database = 0;
private String password;
private Duration timeout;
private String host="localhost";
private Integer port = 6379;
private RedisProperties.Cluster cluster;
private final RedisProperties.Jedis jedis = new RedisProperties.Jedis();
@Getter
@NoArgsConstructor
public static class Jedis {
private final RedisProperties.Pool pool = new RedisProperties.Pool();
}
@Data
@NoArgsConstructor
public static class Cluster {
private List<String> nodes;
private String password;
private Integer maxAttempts;
}
@Data
@NoArgsConstructor
public static class Pool {
private int maxIdle = 8;
private int minIdle = 0;
private int maxActive = 8;
private Duration maxWait = Duration.ofMillis(-1L);
}
}
@Slf4j
@Configuration
public class RedisConfig extends CachingConfigurerSupport {
@Autowired
private RedisProperties redisProperties;
@Bean
public JedisPoolConfig jedisPoolConfig() {
RedisProperties.Pool pool = redisProperties.getJedis().getPool();
JedisPoolConfig jedisPoolConfig = new JedisPoolConfig();
jedisPoolConfig.setMaxTotal(pool.getMaxActive());
jedisPoolConfig.setMaxIdle(pool.getMaxIdle());
jedisPoolConfig.setMinIdle(pool.getMinIdle());
jedisPoolConfig.setMaxWait(pool.getMaxWait());
return jedisPoolConfig;
}
@Bean
public JedisPool jedisPool(JedisPoolConfig jedisPoolConfig) {
log.info("=====创建JedisPool连接池=====");
if(StringUtils.isNotEmpty(redisProperties.getPassword())) {
return new JedisPool(jedisPoolConfig, redisProperties.getHost(), redisProperties.getPort(),
redisProperties.getTimeout().getNano(), redisProperties.getPassword());
}
return new JedisPool(jedisPoolConfig, redisProperties.getHost(), redisProperties.getPort(),
redisProperties.getTimeout().getNano());
}
@Bean
public JedisCluster jedisCluster(){
RedisProperties.Cluster cluster = redisProperties.getCluster();
Set<HostAndPort> set = new HashSet<>();
HostAndPort hp = null;
List<String> nodes =cluster.getNodes();
if(nodes!=null&&nodes.size()>0){
for(int i=0;i<nodes.size();i++){
String[] hostPort = nodes.get(i).split(":");
if(hostPort!=null&&hostPort.length>0){
hp = new HostAndPort(hostPort[0],Integer.valueOf(hostPort[1]));
set.add(hp);
}
}
}
JedisCluster jedisCluster = new JedisCluster(set, redisProperties.getTimeout().getNano(),
redisProperties.getTimeout().getNano(), cluster.getMaxAttempts(), cluster.getPassword(), jedisPoolConfig());
/* JedisCluster jedisCluster = new JedisCluster(set);*/
return jedisCluster;
}
}
@Autowired
private JedisPool jedisPool;
@Cleanup Jedis jedis = jedisPool.getResource();
jedis.set("name","sgh");
@Autowired
private JedisCluster jedisCluster;
jedisCluster.set("name","sgh");
发布者:全栈程序员-用户IM,转载请注明出处:https://javaforall.cn/195666.html原文链接:https://javaforall.cn
【正版授权,激活自己账号】: Jetbrains全家桶Ide使用,1年售后保障,每天仅需1毛
【官方授权 正版激活】: 官方授权 正版激活 支持Jetbrains家族下所有IDE 使用个人JB账号...