美文网首页程序员
SPRING-CLOUD集成REDIS-CLUSTER

SPRING-CLOUD集成REDIS-CLUSTER

作者: BLACKMAMBAR | 来源:发表于2020-04-07 17:04 被阅读0次

    写在前面

    也不复杂,大家就按照步骤操作,如果有问题请留言哈

    依赖库引入

    <dependency>
       <groupId>org.springframework.boot</groupId>
       <artifactId>spring-boot-starter-data-redis</artifactId>
    </dependency>
    

    启动类配置

    @EnableScheduling
    @EnableCaching
    @MapperScan("com.haier.smarthome.intelligentfamilyconsole.mapper")
    public class IntelligentFamilyConsoleApplication {
    
       public static void main(String[] args) {
          SpringApplication.run(IntelligentFamilyConsoleApplication.class, args);
       }
    
    }
    

    配置类

    package com.haier.smarthome.intelligentfamilyconsole.config;
    
    import com.fasterxml.jackson.annotation.JsonAutoDetect;
    import com.fasterxml.jackson.annotation.PropertyAccessor;
    import com.fasterxml.jackson.databind.ObjectMapper;
    import org.springframework.boot.autoconfigure.condition.ConditionalOnClass;
    import org.springframework.context.annotation.Bean;
    import org.springframework.context.annotation.Configuration;
    import org.springframework.data.redis.connection.RedisClusterConfiguration;
    import org.springframework.data.redis.connection.RedisConnectionFactory;
    import org.springframework.data.redis.connection.RedisNode;
    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 redis.clients.jedis.JedisCluster;
    import redis.clients.jedis.JedisPoolConfig;
    
    import javax.annotation.Resource;
    import java.util.ArrayList;
    import java.util.List;
    
    /**
     * @Author:zhanghongpeng
     * @Description:Redis 配置类
     * @CreateDate:13:48 2018/7/4
     */
    @Configuration
    @ConditionalOnClass(JedisCluster.class)
    public class RedisClusterConfig {
    
        @Resource
        private RedisProperties redisProperties;
    
        /**
         * 配置 Redis 连接池信息
         */
    //    @Bean
    //    public JedisPoolConfig getJedisPoolConfig() {
    //        JedisPoolConfig jedisPoolConfig =new JedisPoolConfig();
    //        jedisPoolConfig.setMaxIdle(redisProperties.getMaxIdle());
    //        jedisPoolConfig.setMaxWaitMillis(redisProperties.getMaxWait());
    //        jedisPoolConfig.setTestOnBorrow(redisProperties.isTestOnBorrow());
    //
    //        return jedisPoolConfig;
    //    }
    
        /**
         * 配置 Redis Cluster 信息
         */
        @Bean
        public RedisClusterConfiguration getJedisCluster() {
            RedisClusterConfiguration redisClusterConfiguration = new RedisClusterConfiguration();
            redisClusterConfiguration.setMaxRedirects(redisProperties.getMaxRedirects());
    
            List<RedisNode> nodeList = new ArrayList<>();
    
            String[] cNodes = redisProperties.getNodes().split(",");
            //分割出集群节点
            for(String node : cNodes) {
                String[] hp = node.split(":");
                nodeList.add(new RedisNode(hp[0], Integer.parseInt(hp[1])));
            }
            redisClusterConfiguration.setClusterNodes(nodeList);
    
            return redisClusterConfiguration;
        }
    
        /**
         * 配置 Redis 连接工厂
         */
        @Bean
        public JedisConnectionFactory getJedisConnectionFactory(RedisClusterConfiguration redisClusterConfiguration, JedisPoolConfig jedisPoolConfig) {
            JedisConnectionFactory jedisConnectionFactory = new JedisConnectionFactory(redisClusterConfiguration, jedisPoolConfig);
            return jedisConnectionFactory;
        }
    
        /**
         * 设置数据存入redis 的序列化方式
         *  redisTemplate序列化默认使用的jdkSerializeable
         *  存储二进制字节码,导致key会出现乱码,所以自定义序列化类
         */
        @Bean
        public RedisTemplate<Object, Object> redisTemplate(RedisConnectionFactory redisConnectionFactory) {
            RedisTemplate<Object, Object> redisTemplate = new RedisTemplate<>();
            redisTemplate.setConnectionFactory(redisConnectionFactory);
            Jackson2JsonRedisSerializer jackson2JsonRedisSerializer = new Jackson2JsonRedisSerializer(Object.class);
            ObjectMapper objectMapper = new ObjectMapper();
            objectMapper.setVisibility(PropertyAccessor.ALL, JsonAutoDetect.Visibility.ANY);
            objectMapper.enableDefaultTyping(ObjectMapper.DefaultTyping.NON_FINAL);
            jackson2JsonRedisSerializer.setObjectMapper(objectMapper);
    
            redisTemplate.setValueSerializer(jackson2JsonRedisSerializer);
            redisTemplate.setKeySerializer(new StringRedisSerializer());
            redisTemplate.setHashKeySerializer(new StringRedisSerializer());
            redisTemplate.afterPropertiesSet();
    
            return redisTemplate;
        }
    
    }
    
    package com.haier.smarthome.intelligentfamilyconsole.config;
    
    import lombok.Data;
    import org.springframework.boot.context.properties.ConfigurationProperties;
    import org.springframework.stereotype.Component;
    
    /**
     * @Author:zhanghongpeng
     * @Description:Redis 基本环境信息
     * @CreateDate:13:48 2018/7/4
     */
    @Component
    //
    @ConfigurationProperties(prefix = "spring.redis.cluster")
    @Data
    public class RedisProperties {
    
        private String nodes;
    
        private Integer commandTimeout;
    
        private Integer maxAttempts;
    
        private Integer maxRedirects;
    
        private Integer maxActive;
    
        private Integer maxWait;
    
        private Integer maxIdle;
    
        private Integer minIdle;
    
        private boolean testOnBorrow;
    
        public String getNodes() {
            return nodes;
        }
    
        public void setNodes(String nodes) {
            this.nodes = nodes;
        }
    
        public Integer getCommandTimeout() {
            return commandTimeout;
        }
    
        public void setCommandTimeout(Integer commandTimeout) {
            this.commandTimeout = commandTimeout;
        }
    
        public Integer getMaxAttempts() {
            return maxAttempts;
        }
    
        public void setMaxAttempts(Integer maxAttempts) {
            this.maxAttempts = maxAttempts;
        }
    
        public Integer getMaxRedirects() {
            return maxRedirects;
        }
    
        public void setMaxRedirects(Integer maxRedirects) {
            this.maxRedirects = maxRedirects;
        }
    
        public Integer getMaxActive() {
            return maxActive;
        }
    
        public void setMaxActive(Integer maxActive) {
            this.maxActive = maxActive;
        }
    
        public Integer getMaxWait() {
            return maxWait;
        }
    
        public void setMaxWait(Integer maxWait) {
            this.maxWait = maxWait;
        }
    
        public Integer getMaxIdle() {
            return maxIdle;
        }
    
        public void setMaxIdle(Integer maxIdle) {
            this.maxIdle = maxIdle;
        }
    
        public Integer getMinIdle() {
            return minIdle;
        }
    
        public void setMinIdle(Integer minIdle) {
            this.minIdle = minIdle;
        }
    
        public boolean isTestOnBorrow() {
            return testOnBorrow;
        }
    
        public void setTestOnBorrow(boolean testOnBorrow) {
            this.testOnBorrow = testOnBorrow;
        }
    }
    

    使用测试

    package com.haier.smarthome.intelligentfamilyconsole.service;
    
    import com.haier.smarthome.intelligentfamilyconsole.entity.TestModel;
    import net.sf.json.JSONArray;
    import org.springframework.beans.factory.annotation.Autowired;
    import org.springframework.cache.annotation.CachePut;
    import org.springframework.cache.annotation.Cacheable;
    import org.springframework.data.redis.core.RedisTemplate;
    import org.springframework.stereotype.Service;
    
    import java.util.ArrayList;
    import java.util.List;
    
    /**
     * 接口实现类 - Test
     * Created by zhanghongpeng on 2018/9/13.
     */
    @Service
    public class RedisClusterServiceImpl implements RedisClusterService{
    
            @Autowired
            private RedisTemplate redisTemplate;
    
            @Override
            @Cacheable(value = "TestmodelCache", key = "#key")
            public List<TestModel> getTestmodel(String key) {
    
                return new ArrayList<TestModel>();
            }
    
            @Override
            @CachePut(value = "TestmodelCache", key = "#key")
            public List<TestModel> updateTestmodel(String key, List<TestModel> testModelList) {
                redisTemplate.opsForValue().set(key, testModelList);
                return testModelList;
            }
    }
    

    相关文章

      网友评论

        本文标题:SPRING-CLOUD集成REDIS-CLUSTER

        本文链接:https://www.haomeiwen.com/subject/pobnphtx.html