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内容请搜索脚本之家以前的文章或继续浏览下面的相关文章希望大家以后多多支持脚本之家!
相关文章
spring cloud 集成 ribbon负载均衡的实例代码
spring Cloud Ribbon 是一个客户端的负载均衡器,它提供对大量的HTTP和TCP客户端的访问控制。本文给大家介绍spring cloud 集成 ribbon负载均衡,感兴趣的朋友跟随小编一起看看吧2021-11-11
解析SpringBoot中使用LoadTimeWeaving技术实现AOP功能
这篇文章主要介绍了SpringBoot中使用LoadTimeWeaving技术实现AOP功能,AOP面向切面编程,通过为目标类织入切面的方式,实现对目标类功能的增强,本文给大家介绍的非常详细,需要的朋友可以参考下2022-09-09
SpringBoot如何整合Springsecurity实现数据库登录及权限控制
这篇文章主要给大家介绍了关于SpringBoot如何整合Springsecurity实现数据库登录及权限控制的相关资料,文中通过图文以及实例代码介绍的非常详细,对大家的学习或者工作具有一定的参考学习价值,需要的朋友可以参考下2022-01-01
Struts2中validate数据校验的两种方法详解附Struts2常用校验器
这篇文章主要介绍了Struts2中validate数据校验的两种方法及Struts2常用校验器,本文介绍的非常详细,具有参考借鉴价值,感兴趣的朋友一起看看吧2016-09-09


最新评论