快捷導(dǎo)航

Springboot整合Jedis實(shí)現(xiàn)單機(jī)版或哨兵版可切換配置方法

更新時(shí)間：2023年11月11日 11:37:02 作者：如來(lái)神掌十八式

這篇文章主要介紹了Springboot整合Jedis實(shí)現(xiàn)單機(jī)版或哨兵版可切換配置方法,本文通過(guò)實(shí)例代碼給大家介紹的非常詳細(xì)，對(duì)大家的學(xué)習(xí)或工作具有一定的參考借鑒價(jià)值，需要的朋友可以參考下

Springboot整合Jedis實(shí)現(xiàn)單機(jī)版或哨兵版可切換配置

前言

前文寫到借助redis實(shí)現(xiàn)Shiro實(shí)現(xiàn)session限制登錄數(shù)量踢人下線，本文就寫一下Jedis的配置，可切換單機(jī)版和集群哨兵版，方便開(kāi)發(fā)測(cè)試。

實(shí)現(xiàn)

很簡(jiǎn)單，直接上代碼，通過(guò)@ConditionalOnProperty獲取配置文件設(shè)置的值從而實(shí)例化我們所需要的連接池。

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(){    //這個(gè)是修改redis性能的時(shí)候需要的對(duì)象
        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:直連單機(jī) 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
#最大連接數(shù)
redis.maxTotal=60000
#最大空閑連接
redis.maxIdle=300
#最小空閑連接
redis.minIdle=5

最后

只需修改redis.sentinel.enable配置值就可以切換項(xiàng)目連接池。

到此這篇關(guān)于Springboot整合Jedis實(shí)現(xiàn)單機(jī)版或哨兵版可切換配置的文章就介紹到這了,更多相關(guān)Springboot整合Jedis內(nèi)容請(qǐng)搜索腳本之家以前的文章或繼續(xù)瀏覽下面的相關(guān)文章希望大家以后多多支持腳本之家！

您可能感興趣的文章: