springboot使用redis集群整合redisTemplate

蔚落 2022-04-08 09:26 563阅读 0赞

找了好久都没有找到相关的资料，所以就根据xml配置redis集群的方式，自己对比源码搞了一下，成功整合。分享一下
直接贴出代码：

代码中的参数都是通过
@Value注解进行注入

  1. import org.apache.commons.lang3.StringUtils;
  2. import org.springframework.beans.factory.annotation.Value;
  3. import org.springframework.boot.autoconfigure.EnableAutoConfiguration;
  4. import org.springframework.cache.annotation.CachingConfigurerSupport;
  5. import org.springframework.context.annotation.Bean;
  6. import org.springframework.context.annotation.Configuration;
  7. import org.springframework.data.redis.cache.RedisCacheManager;
  8. import org.springframework.data.redis.connection.RedisClusterConfiguration;
  9. import org.springframework.data.redis.connection.RedisNode;
  10. import org.springframework.data.redis.connection.jedis.JedisConnectionFactory;
  11. import org.springframework.data.redis.core.RedisTemplate;
  12. import org.springframework.data.redis.serializer.JdkSerializationRedisSerializer;
  13. import org.springframework.data.redis.serializer.StringRedisSerializer;
  14. import org.springframework.web.client.RestTemplate;
  16. import java.util.HashSet;
  17. import java.util.Set;
  18. /**
  19. 使用redis集群或者单机初始化redisTemplate
  20. */
  21. @Configuration
  22. public class RedisConfig extends CachingConfigurerSupport {
  24.     @Value("${redis.model:single}")
  25.     private String model;
  27.     @Value("${redis.cluster:127.0.0.1:6379}")
  28.     private String clusterNodes;
  30.     @Value("${redis.single:127.0.0.1:6379}")
  31.     private String singNode;
  33.     @Value("${redis.password:111111}")
  34.     private String password;
  36.     /**
  37.      * Redis集群的配置
  38.      *
  39.      * @return RedisClusterConfiguration
  40.      * @throws
  41.      */
  42.     @Bean
  43.     public RedisClusterConfiguration redisClusterConfiguration() {
  44.         RedisClusterConfiguration redisClusterConfiguration = new RedisClusterConfiguration();
  45.         String[] serverArray = clusterNodes.split(",");
  46.         Set<RedisNode> nodes = new HashSet<RedisNode>();
  47.         for (String ipPort : serverArray) {
  48.             String[] ipAndPort = ipPort.split(":");
  49.             nodes.add(new RedisNode(ipAndPort[0].trim(), Integer.valueOf(ipAndPort[1])));
  50.         }
  51.         redisClusterConfiguration.setClusterNodes(nodes);
  52.         return redisClusterConfiguration;
  53.     }
  55.     /**
  56.      * @param
  57.      * @return
  58.      * @Description:redis连接工厂类
  59.      * @date 2018/10/25 19:45
  60.      */
  61.     @Bean
  62.     public JedisConnectionFactory jedisConnectionFactory() {
  63.         JedisConnectionFactory factory = null;
  64.         //集群模式
  65.         if (StringUtils.equals("cluster", model)) {
  66.             factory = new JedisConnectionFactory(redisClusterConfiguration());
  67.         } else {
  68.             String[] ipAndPort = singNode.split(":");
  69.             factory = new JedisConnectionFactory();
  70.             factory.setHostName(ipAndPort[0]);
  71.             factory.setPassword(password);
  72.             factory.setPort(Integer.parseInt(ipAndPort[1]));
  73.         }
  74.         factory.setUsePool(true);
  75.         return factory;
  76.     }
  78.     /**
  79.      * 实例化 RedisTemplate 对象
  80.      *
  81.      * @return
  82.      */
  83.     @Bean
  84.     public RedisTemplate<String, Object> redisTemplate() {
  85.         RedisTemplate<String, Object> redisTemplate = new RedisTemplate<>();
  86.         initDomainRedisTemplate(redisTemplate);
  87.         return redisTemplate;
  88.     }
  90.     /**
  91.      * 设置数据存入 redis 的序列化方式,并开启事务
  92.      */
  93.     private void initDomainRedisTemplate(RedisTemplate<String, Object> redisTemplate) {
  94.         redisTemplate.setKeySerializer(new StringRedisSerializer());
  95.         redisTemplate.setValueSerializer(new JdkSerializationRedisSerializer());
  96.         redisTemplate.setEnableTransactionSupport(false);
  97.         redisTemplate.setConnectionFactory(jedisConnectionFactory());
  98.     }
  100.     /**
  101.      * @param
  102.      * @return
  103.      * @Description:redis缓存管理器
  104.      * @date 2018/10/25 21:18
  105.      */
  106.     @Override
  107.     @Bean
  108.     public RedisCacheManager cacheManager() {
  109.         RedisCacheManager redisCacheManager = new RedisCacheManager(redisTemplate());
  110.         redisCacheManager.setUsePrefix(true);
  111.         return redisCacheManager;
  112.     }
  114.     @Bean
  115.     public RestTemplate restTemplate() {
  116.         return new RestTemplate();
  117.     }
  118. }

redis配置文件配置如下：

  1. ##redis集群
  2. spring.redis.cluster.nodes=168.181.211.220:6379,168.181.211.221:6380,168.181.211.222:6379,168.181.211.223:6380,168.181.211.225:6379,168.181.211.228:6380
  3. spring.redis.cluster.max-redirects=6
  4. #客户端超时时间单位是毫秒 默认是2000
  5. redis.timeout=10000
  6. #最大空闲数
  7. redis.maxIdle=300
  8. #控制一个pool可分配多少个jedis实例,用来替换上面的redis.maxActive,如果是jedis 2.4以后用该属性
  9. redis.maxTotal=1000
  10. #最大建立连接等待时间。如果超过此时间将接到异常。设为-1表示无限制。
  11. redis.maxWaitMillis=1000
  12. #连接的最小空闲时间 默认1800000毫秒(30分钟)
  13. redis.minEvictableIdleTimeMillis=300000
  14. #每次释放连接的最大数目,默认3
  15. redis.numTestsPerEvictionRun=1024
  16. #逐出扫描的时间间隔(毫秒) 如果为负数,则不运行逐出线程, 默认-1
  17. redis.timeBetweenEvictionRunsMillis=30000
  18. #是否在从池中取出连接前进行检验,如果检验失败,则从池中去除连接并尝试取出另一个
  19. redis.testOnBorrow=true
  20. #在空闲时检查有效性, 默认false
  21. redis.testWhileIdle=true

在需要使用redisTemplate的地方直接注入即可使用：

  1. @Autowired
  2.  RedisTemplate<String, Object> redisTemplate; //泛型可以根据自己的需求进行定义

发表评论

表情：
评论列表 （有 0 条评论，563人围观）

还没有评论，来说两句吧...

相关阅读

    相关 SpringBoot整合redis集群

    一：缓存的应用场景 1：什么是缓存？ 在互联网场景下，尤其 2C 端大流量场景下，需要将一些经常展现和不会频繁变更的数据，存放在存取速率更快的地方。缓存就是一个存储器，在技

    叁歲伎倆叁歲伎倆/ 0 赞/ 425 阅读

    相关 springboot整合redis集群

    一、redis集群原理 redis集群中的所有节点彼此互联，节点内部采用二进制协议优化传输速度和带宽，每个节点都可以与Java客户端连接。redis集群的数据分配采用哈希

    以你之姓@以你之姓@/ 0 赞/ 452 阅读