SpringBoot项目如何接入Redis集群

今天小编给大家分享一下SpringBoot项目如何接入Redis集群的相关知识点，内容详细，逻辑清晰，相信大部分人都还太了解这方面的知识，所以分享这篇文章给大家参考一下，希望大家阅读完这篇文章后有所收获，下面我们一起来了解一下吧。

配置参数

因为这篇文章不介绍 Redis 集群的搭建，这里我们假设已经有了一个 Redis 的集群环境，我们项目中需要调整以下几个部分

1. 修改配置参数，集群的节点和密码配置；

2. 确保引入的 Jedis 版本支持设置密码，spring-data-redis 1.8 以上，SpringBoot 1.5 以上才支持设置密码；

3. 注入 RedisTemplate；

4. 编写工具类；

修改配置参数

############### Redis 集群配置 #########################spring.custome.redis.cluster.nodes=172.20.0.1:7001,172.20.0.2:7002,172.20.0.3:7003spring.custome.redis.cluster.max-redirects=3spring.custome.redis.cluster.max-active=500spring.custome.redis.cluster.max-wait=-1spring.custome.redis.cluster.max-idle=500spring.custome.redis.cluster.min-idle=20spring.custome.redis.cluster.timeout=3000spring.custome.redis.cluster.password=redis.cluster.password

引入依赖（如果需要）

确保 SpringBoot 的版本大于 1.4.x 如果不是的话，采用如下配置，先排除 SpringBoot 中旧版本 Jedis 和 spring-data-redis，再依赖高版本的 Jedis 和 spring-data-redis。

               org.springframework.boot            spring-boot-starter-data-redis                                                            redis.clients                    jedis                                                    org.springframework.data                    spring-data-redis                                                                redis.clients            jedis            2.9.0                            org.springframework.data            spring-data-redis            1.8.0.RELEASE

注入 RedisTemplate

注入 RedisTemplate 我们需要三个组件，分别是JedisConnectionFactory 、RedisClusterConfiguration、JedisPoolConfig，下面是注入RedisTempalte 的代码。先根据配置创建 JedisConnectFactory 同时需要配置 RedisClusterConfiguration、JedisPoolConfig，最后将JedisConnectionFactory 返回用于创建RedisTemplate

import com.fasterxml.jackson.annotation.JsonAutoDetect;import com.fasterxml.jackson.annotation.PropertyAccessor;import com.fasterxml.jackson.databind.ObjectMapper;import org.apache.commons.pool2.impl.GenericObjectPoolConfig;import org.springframework.beans.factory.annotation.Value;import org.springframework.context.annotation.Bean;import org.springframework.context.annotation.Primary;import org.springframework.data.redis.connection.RedisClusterConfiguration;import org.springframework.data.redis.connection.RedisNode;import org.springframework.data.redis.connection.jedis.JedisClientConfiguration;import org.springframework.data.redis.connection.jedis.JedisConnectionFactory;import org.springframework.data.redis.core.RedisTemplate;import org.springframework.data.redis.serializer.Jackson2JsonRedisSerializer;import org.springframework.data.redis.serializer.StringRedisSerializer;import java.time.Duration;import java.util.ArrayList;import java.util.List;public class RedisClusterConfig {    @Bean(name = "redisTemplate")    @Primary    public RedisTemplate redisClusterTemplate(@Value("${spring.custome.redis.cluster.nodes}") String host,                                     @Value("${spring.custome.redis.cluster.password}") String password,                                     @Value("${spring.custome.redis.cluster.timeout}") long timeout,                                     @Value("${spring.custome.redis.cluster.max-redirects}") int maxRedirect,                                     @Value("${spring.custome.redis.cluster.max-active}") int maxActive,                                     @Value("${spring.custome.redis.cluster.max-wait}") int maxWait,                                     @Value("${spring.custome.redis.cluster.max-idle}") int maxIdle,                                     @Value("${spring.custome.redis.cluster.min-idle}") int minIdle) {        JedisConnectionFactory connectionFactory =  jedisClusterConnectionFactory(host, password,                timeout, maxRedirect, maxActive, maxWait, maxIdle, minIdle);        return createRedisClusterTemplate(connectionFactory);    }    private JedisConnectionFactory jedisClusterConnectionFactory(String host, String password,                                                                   long timeout, int maxRedirect, int maxActive, int maxWait, int maxIdle, int minIdle) {        RedisClusterConfiguration redisClusterConfiguration = new RedisClusterConfiguration();        List nodeList = new ArrayList();        String[] cNodes = host.split(",");        //分割出集群节点        for (String node : cNodes) {            String[] hp = node.split(":");            nodeList.add(new RedisNode(hp[0], Integer.parseInt(hp[1])));        }        redisClusterConfiguration.setClusterNodes(nodeList);        redisClusterConfiguration.setPassword(password);        redisClusterConfiguration.setMaxRedirects(maxRedirect);        // 连接池通用配置        GenericObjectPoolConfig genericObjectPoolConfig = new GenericObjectPoolConfig();        genericObjectPoolConfig.setMaxIdle(maxIdle);        genericObjectPoolConfig.setMaxTotal(maxActive);        genericObjectPoolConfig.setMinIdle(minIdle);        genericObjectPoolConfig.setMaxWaitMillis(maxWait);        genericObjectPoolConfig.setTestWhileIdle(true);        genericObjectPoolConfig.setTimeBetweenEvictionRunsMillis(300000);        JedisClientConfiguration.DefaultJedisClientConfigurationBuilder builder = (JedisClientConfiguration.DefaultJedisClientConfigurationBuilder) JedisClientConfiguration                .builder();        builder.connectTimeout(Duration.ofSeconds(timeout));        builder.usePooling();        builder.poolConfig(genericObjectPoolConfig);        JedisConnectionFactory connectionFactory = new JedisConnectionFactory(redisClusterConfiguration, builder.build());        // 连接池初始化        connectionFactory.afterPropertiesSet();        return connectionFactory;    }    private RedisTemplate createRedisClusterTemplate(JedisConnectionFactory redisConnectionFactory) {        RedisTemplate redisTemplate = new RedisTemplate();        redisTemplate.setConnectionFactory(redisConnectionFactory);        Jackson2JsonRedisSerializer