SpingBoot之集成Redis集群

一、安装Redis集群

安装步骤参照网上教程，Mac安装步骤参照https://github.com/muyl/mac-docker-redis-cluster

二、创建SpringBoot工程

1. 创建Redis配置类

   package com.example.chapterredis.common.config;
   
   import org.apache.commons.pool2.impl.GenericObjectPoolConfig;
   import org.slf4j.Logger;
   import org.slf4j.LoggerFactory;
   import org.springframework.beans.factory.annotation.Value;
   import org.springframework.context.annotation.Bean;
   import org.springframework.context.annotation.Configuration;
   import redis.clients.jedis.HostAndPort;
   import redis.clients.jedis.JedisCluster;
   
   import java.util.HashSet;
   import java.util.Set;
   
   /**
   * @author tony
   */
   @Configuration
   public class RedisConfiguration {
   
   private static final Logger logger = LoggerFactory.getLogger(RedisConfiguration.class);
   
   @Value("${spring.redis.clusterNodes}")
   private String  clusterNodes;
   @Value("${spring.redis.password}")
   private String  auth;
   @Value("${spring.redis.pool.maxActive}")
   private Integer maxTotal;
   @Value("${spring.redis.pool.minIdle}")
   private Integer minIdle;
   @Value("${spring.redis.pool.maxIdle}")
   private Integer maxIdle;
   @Value("${spring.redis.pool.maxWait}")
   private Long    maxWaitMillis;
   @Value("${spring.redis.pool.commandTimeout}")
   private int     commandTimeout;
   
   @Bean
   public JedisCluster jedisCluster() {
   String[] serverArray = clusterNodes.split(",");
   Set<HostAndPort> nodes = new HashSet<>();
   for (String ipPort : serverArray) {
   String[] ipPortPair = ipPort.split(":");
   nodes.add(new HostAndPort(ipPortPair[0].trim(), Integer.valueOf(ipPortPair[1].trim())));
   }
   
   if (!nodes.isEmpty()) {
   String password = getAuth(auth);
   logger.info("redis password:{}", password);
   GenericObjectPoolConfig pool = new GenericObjectPoolConfig();
   pool.setMaxTotal(maxTotal);
   pool.setMinIdle(minIdle);
   pool.setMaxIdle(maxIdle);
   pool.setMaxWaitMillis(maxWaitMillis);
   return new JedisCluster(nodes, commandTimeout, commandTimeout, 5, password, pool);
   }
   return null;
   }
   
   private String getAuth(String auth) {
   return "".equals(auth) ? null : auth;
   }
   }

2. SpringBoot属性文件

   spring.redis.clusterNodes=localhost:7000,localhost:7001,localhost:7002,localhost:7003,localhost:7004,localhost:7005
   spring.redis.password=
   spring.redis.pool.maxActive=5
   spring.redis.pool.minIdle=5
   spring.redis.pool.maxIdle=1
   spring.redis.pool.maxWait=3000
   spring.redis.pool.commandTimeout=5000

3. SpringBoot启动类

   package com.example.chapterredis;
   
   import org.springframework.boot.SpringApplication;
   import org.springframework.boot.autoconfigure.SpringBootApplication;
   
   @SpringBootApplication
   public class ChapterRedisApplication {
   
   public static void main(String[] args) {
   SpringApplication.run(ChapterRedisApplication.class, args);
   }
   }

4. 测试类

   package com.example.chapterredis;
   
   import org.junit.Test;
   import org.junit.runner.RunWith;
   import org.springframework.beans.factory.annotation.Autowired;
   import org.springframework.boot.test.context.SpringBootTest;
   import org.springframework.test.context.junit4.SpringRunner;
   import redis.clients.jedis.JedisCluster;
   
   @RunWith(SpringRunner.class)
   @SpringBootTest(classes={ChapterRedisApplication.class})
   public class ChapterRedisApplicationTests {
   
   @Autowired
   private JedisCluster jedisCluster;
   
   @Test
   public void test2() {
   jedisCluster.set("aaa","123");
   System.out.println(jedisCluster.get("aaa"));
   }
   
   }

三、工程源代码

https://gitee.com/shanksV/chapter-redis.git

比你优秀的人比你还努力，你有什么资格不去奋斗!!!