SpingBoot之集成Redis集群

2019-11-18 16:03:23来源:博客园 阅读 ()

新老客户大回馈,云服务器低至5折

SpingBoot之集成Redis集群

一、安装Redis集群

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

二、创建SpringBoot工程

file

  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

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


原文链接:https://www.cnblogs.com/muyl/p/11886481.html
如有疑问请与原作者联系

标签:

版权申明:本站文章部分自网络,如有侵权,请联系:west999com@outlook.com
特别注意:本站所有转载文章言论不代表本站观点,本站所提供的摄影照片,插画,设计作品,如需使用,请与原作者联系,版权归原作者所有

上一篇:JVM 运行参数 &amp; 代码监控

下一篇:3. 彤哥说netty系列之Java BIO NIO AIO进化史