快捷導(dǎo)航

Spring Boot不同版本Redis設(shè)置JedisConnectionFactory詳解

更新時(shí)間：2023年09月25日 10:39:03 作者：manongjc

本文章向大家介紹Spring Boot不同版本Redis設(shè)置JedisConnectionFactory,主要內(nèi)容包括1.X 版本、2.X 版本、2.、基本概念、基礎(chǔ)應(yīng)用、原理機(jī)制和需要注意的事項(xiàng)等,并結(jié)合實(shí)例形式分析了其使用技巧,希望通過本文能幫助到大家理解應(yīng)用這部分內(nèi)容

Spring Boot不同版本Redis設(shè)置JedisConnectionFactory的方式

最近重構(gòu)項(xiàng)目想引入Redis，之前1.0版本看項(xiàng)目里用的本地緩存Guava，這次重構(gòu)后考慮要不要加入Redis。打算試試~

因?yàn)槲乙郧白龅捻?xiàng)目用的Spring Boot版本比較低。還是老的 1.5.X版本的。之前設(shè)置 JedisConnectionFactory 的方式與現(xiàn)在 2.X 版本有點(diǎn)不一樣，所以記錄一下，方便以后查看。

1.X 版本

設(shè)置 JedisConnectionFactory 方法：

    @Bean
    public JedisConnectionFactory jedisConnectionFactory(JedisPoolConfig jedisPoolConfig){
        String[] hostAndPorts = env.getProperty("spring.redis.cluster.nodes").split(",");
        JedisConnectionFactory jedisConnectionFactory = null;
        if(hostAndPorts.length==1){
            //單機(jī)版
            String host = hostAndPorts[0].split(":")[0];
            int port = Integer.valueOf(hostAndPorts[0].split(":")[1]);
            String password = env.getProperty("spring.redis.password");
            jedisConnectionFactory = new JedisConnectionFactory();
            jedisConnectionFactory.setPoolConfig(jedisPoolConfig);
            jedisConnectionFactory.setDatabase(1);
            jedisConnectionFactory.setHostName(host);
            jedisConnectionFactory.setPassword(password);
            jedisConnectionFactory.setPort(port);
            jedisConnectionFactory.setTimeout(5000);
            jedisConnectionFactory.afterPropertiesSet();
        }else{
            //集群版
            RedisClusterConfiguration redisClusterConfiguration = new RedisClusterConfiguration();
            String password = env.getProperty("spring.redis.password");
            Set<RedisNode> nodes = new HashSet<RedisNode>();
            for (String ipPort:hostAndPorts){
                String[] ipAndPort = ipPort.split(":");
                nodes.add(new RedisNode(ipAndPort[0].trim(),Integer.valueOf(ipAndPort[1])));
            }
            redisClusterConfiguration.setClusterNodes(nodes);
            redisClusterConfiguration.setMaxRedirects(200);
            jedisConnectionFactory = new JedisConnectionFactory(redisClusterConfiguration,jedisPoolConfig);
            jedisConnectionFactory.setPassword(password);
            jedisConnectionFactory.afterPropertiesSet();
        }
        return jedisConnectionFactory;
    }

在 2.X 版本使用的話會(huì)提示方法已過期，推薦使用下面的方法。

2.X 版本

2.X 版本可以使用 RedisStandaloneConfiguration 來配置連接信息。

    @Bean
    public JedisConnectionFactory redisConnectionFactory() {
        RedisStandaloneConfiguration redisStandaloneConfiguration = new RedisStandaloneConfiguration();
        redisStandaloneConfiguration.setHostName(env.getProperty("spring.redis.host"));
        redisStandaloneConfiguration.setPort(Integer.parseInt(env.getProperty("spring.redis.port")));
        redisStandaloneConfiguration.setPassword(env.getProperty("spring.redis.password"));
        redisStandaloneConfiguration.setDatabase(Integer.parseInt(env.getProperty("spring.redis.database")));
        return new JedisConnectionFactory(redisStandaloneConfiguration);
    }

以上配置使用的是直接連接 Redis 的方式，即每次連接都創(chuàng)建新的連接。當(dāng)并發(fā)量劇增時(shí)，這會(huì)帶來性能上開銷，同時(shí)由于沒有對(duì)連接數(shù)進(jìn)行限制，則可能使服務(wù)器崩潰導(dǎo)致無法響應(yīng)。

所以一般情況下都會(huì)建立連接池，事先初始化一組連接，供需要 Redis 連接的線程取用。

    @Bean
    public JedisConnectionFactory redisConnectionFactory() {
        JedisPoolConfig jedisPoolConfig = new JedisPoolConfig();
        jedisPoolConfig.setMaxTotal(200);
        jedisPoolConfig.setMaxIdle(150);
        jedisPoolConfig.setMinIdle(50);
        RedisStandaloneConfiguration redisStandaloneConfiguration = new RedisStandaloneConfiguration();
        redisStandaloneConfiguration.setHostName(env.getProperty("spring.redis.host"));
        redisStandaloneConfiguration.setPort(Integer.parseInt(env.getProperty("spring.redis.port")));
        redisStandaloneConfiguration.setPassword(env.getProperty("spring.redis.password"));
        redisStandaloneConfiguration.setDatabase(Integer.parseInt(env.getProperty("spring.redis.database")));
        JedisClientConfiguration.JedisClientConfigurationBuilder configurationBuilder = JedisClientConfiguration.builder();
        JedisClientConfiguration jedisClientConfiguration = configurationBuilder.usePooling().poolConfig(jedisPoolConfig).build();
        return new JedisConnectionFactory(redisStandaloneConfiguration, jedisClientConfiguration);
    }

以上就是Spring Boot不同版本Redis設(shè)置JedisConnectionFactory詳解的詳細(xì)內(nèi)容，更多關(guān)于Spring Boot Redis設(shè)置JedisConnectionFactory的資料請(qǐng)關(guān)注腳本之家其它相關(guān)文章！

您可能感興趣的文章: