Springboot整合Jedis实现单机版或哨兵版可切换配置方法
作者：如来神掌十八式
这篇文章主要介绍了Springboot整合Jedis实现单机版或哨兵版可切换配置方法,本文通过实例代码给大家介绍的非常详细，对大家的学习或工作具有一定的参考借鉴价值，需要的朋友可以参考下
Springboot整合Jedis实现单机版或哨兵版可切换配置
前言
前文写到借助redis实现Shiro实现session限制登录数量踢人下线，本文就写一下Jedis的配置，可切换单机版和集群哨兵版，方便开发测试。
实现
很简单，直接上代码，通过@ConditionalOnProperty获取配置文件设置的值从而实例化我们所需要的连接池。
import org.slf4j.Logger;
import org.slf4j.LoggerFactory;
import org.springframework.beans.factory.annotation.Value;
import org.springframework.boot.SpringBootConfiguration;
import org.springframework.boot.autoconfigure.condition.ConditionalOnProperty;
import org.springframework.context.annotation.Bean;
import redis.clients.jedis.JedisPool;
import redis.clients.jedis.JedisPoolConfig;
import redis.clients.jedis.JedisSentinelPool;
import java.util.HashSet;
@SpringBootConfiguration
public class RedisConfig {
private static Logger logger = LoggerFactory.getLogger(RedisConfig.class);
@Value("${redis.maxIdle}")
private Integer maxIdle;
@Value("${redis.maxTotal}")
private Integer maxTotal;
@Value("${redis.host}")
private String host;
@Value("${redis.password}")
private String password;
@Value("${redis.port}")
private Integer port;
@Value("${redis.sentinels.set}")
private HashSet<String> sentinels;
@Value("${redis.sentinels.master}")
private String sentinelsMaster;
@Value("${redis.sentinels.password}")
private String sentinelsPassword;
public JedisPoolConfig jedisPoolConfig(){ //这个是修改redis性能的时候需要的对象
JedisPoolConfig jedisPoolConfig = new JedisPoolConfig();
jedisPoolConfig.setMaxIdle(maxIdle);
jedisPoolConfig.setMaxTotal(maxTotal);
jedisPoolConfig.setTestOnBorrow(true);
return jedisPoolConfig;
}
@Bean
@ConditionalOnProperty(value = "redis.sentinel.enable", havingValue = "false", matchIfMissing = true)
public JedisPool jedisPool(){
logger.info("加载JedisPool");
JedisPoolConfig jedisPoolConfig = jedisPoolConfig();
return new JedisPool(jedisPoolConfig, host, port, 10000, password);
}
@Bean
@ConditionalOnProperty(value = "redis.sentinel.enable", havingValue = "true", matchIfMissing = false)
public JedisSentinelPool jedisSentinelPool() {
logger.info("加载JedisSentinelPool");
JedisPoolConfig config = jedisPoolConfig();
JedisSentinelPool jedisPool = new JedisSentinelPool(sentinelsMaster, sentinels, config, 10000, sentinelsPassword);
return jedisPool;
}
}JedisUtils 加入这段以选择所用的连接池
public class JedisUtils {
private static Logger logger = LoggerFactory.getLogger(JedisUtils.class);
private static Pool jedisPool = null;
static {
try {
jedisPool = SpringContextHolder.getBean(JedisSentinelPool.class);
} catch (Exception e) {
logger.warn("切换为JedisPool");
jedisPool = SpringContextHolder.getBean(JedisPool.class);
}
}
}配置
# false:直连单机 true:连接哨兵 redis.sentinel.enable=true redis.sentinels.set=127.0.0.1:6390,127.0.0.1:6391,127.0.0.1:6392 redis.sentinels.master=bbq redis.sentinels.password=123456 redis.host=127.0.0.1 redis.password=123456 redis.port=6379 #最大连接数 redis.maxTotal=60000 #最大空闲连接 redis.maxIdle=300 #最小空闲连接 redis.minIdle=5
最后
只需修改redis.sentinel.enable配置值就可以切换项目连接池。
到此这篇关于Springboot整合Jedis实现单机版或哨兵版可切换配置的文章就介绍到这了,更多相关Springboot整合Jedis内容请搜索脚本之家以前的文章或继续浏览下面的相关文章希望大家以后多多支持脚本之家！