SpringBoot RedisTemplateクラスタ構成の使用

一、構成
1、yml配置

spring:
  redis:
    cluster:
      nodes:
        - ip:port #      redis   IP    
        - ip:port
        - ip:port
        - ip:port
        - ip:port
        - ip:port
      connectionTimeout: 6000
      soTimeout: 6000
      maxAttempts: 5
      password: password #      

2、受信構成

import lombok.Data;

@Component
@ConfigurationProperties(prefix = "spring.redis.cluster")
@Data //   lombok         lombok  getter   setter  
public class RedisClusterConfigProperties {
    private List nodes;
    private Integer maxAttempts;
    private Integer connectionTimeout;
    private Integer soTimeout;
    private String password;
}

3、クラスタ構成

@Configuration
public class RedisConfig extends CachingConfigurerSupport {

    @Resource
    private RedisClusterConfigProperties clusterProperties;

    @Bean
    public RedisClusterConfiguration getClusterConfig() {
        RedisClusterConfiguration rcc = new RedisClusterConfiguration(clusterProperties.getNodes());
        rcc.setMaxRedirects(clusterProperties.getMaxAttempts());
        rcc.setPassword(RedisPassword.of(clusterProperties.getPassword()));
        return rcc;
    }

    @Bean
    public JedisCluster getJedisCluster() {
        JedisPoolConfig poolConfig = new JedisPoolConfig();
        //       
        String[] cluster = clusterProperties.getNodes().toArray(new String[0]);
        //   set  
        Set nodes = new HashSet();
        //             set   
        for (String node : cluster) {
            String[] host = node.split(":");
            //      
            nodes.add(new HostAndPort(host[0], Integer.parseInt(host[1])));
        }
        return new JedisCluster(nodes, clusterProperties.getConnectionTimeout(), clusterProperties.getSoTimeout(), clusterProperties.getMaxAttempts(), clusterProperties.getPassword(), poolConfig);
    }


    @Bean
    public JedisConnectionFactory redisConnectionFactory(RedisClusterConfiguration cluster) {
        return new JedisConnectionFactory(cluster);
    }

    /**
     * RedisTemplate  
     * key   value   String  
     *    Jackson2JsonRedisSerializer     
     */
    @Bean(name = "redisTemplate1")
    public RedisTemplate redisTemplate(RedisConnectionFactory factory) {
        StringRedisTemplate template = new StringRedisTemplate(factory);
        Jackson2JsonRedisSerializer jackson2JsonRedisSerializer = new Jackson2JsonRedisSerializer<>(Object.class);
        ObjectMapper om = new ObjectMapper();
        om.setVisibility(PropertyAccessor.ALL, JsonAutoDetect.Visibility.ANY);
        om.enableDefaultTyping(ObjectMapper.DefaultTyping.NON_FINAL);
        jackson2JsonRedisSerializer.setObjectMapper(om);
        template.setValueSerializer(jackson2JsonRedisSerializer);
        template.afterPropertiesSet();
        return template;
    }

    /**
     * RedisTemplate  
     * key  String  
     * value   Object   
     *    Jackson2JsonRedisSerializer     
     */
    @Bean(name = "redisTemplate2")
    public RedisTemplate redisTemplate2(RedisConnectionFactory factory) {
        RedisTemplate template = new RedisTemplate<>();
        RedisSerializer stringSerializer = new StringRedisSerializer();
        Jackson2JsonRedisSerializer jackson2JsonRedisSerializer = new Jackson2JsonRedisSerializer<>(Object.class);
        ObjectMapper om = new ObjectMapper();
        template.setConnectionFactory(factory);
        template.afterPropertiesSet();
        template.setKeySerializer(stringSerializer);
        template.setHashKeySerializer(stringSerializer);
        template.setHashValueSerializer(stringSerializer);
        om.setVisibility(PropertyAccessor.ALL, JsonAutoDetect.Visibility.ANY);
        om.enableDefaultTyping(ObjectMapper.DefaultTyping.NON_FINAL);
        jackson2JsonRedisSerializer.setObjectMapper(om);
        template.setValueSerializer(jackson2JsonRedisSerializer);
        template.afterPropertiesSet();
        return template;
    }
}

RedisTemplate構成の説明:1⃣10.、シーケンス化ソースコードのデフォルトはJdkSerializationRedisSerializerです.そうするとredis-clientで見ると、対応する値が読めません.分かりやすいようにjackson2JsonRedisSerializerを使います.2⃣️、redisTemplate1とredisTemplate2の違いは、異なる業務状況に対して、異なるvalueを書きやすくするためであり、もちろん自分が必要とするredisTemplate3などを配置することができる.
二、使用
1、redisTemplate1の使用例はいくつかの例にすぎない

import lombok.extern.slf4j.Slf4j;

@Component
@Slf4j //   lombok         
public class RedisStringUtils {

    @Resource(name = "redisTemplate1")
    private RedisTemplate redisTemplate;

     public Object getObject(String key) {
        return redisTemplate.opsForValue().get(key);
    }

    public void saveWithExpireTime(String key, String object, long timeout) {
        redisTemplate.opsForValue().set(key, object, timeout, TimeUnit.SECONDS);
    }

    /**
     * List     
     */
    public List range(String key) {
        try {
            return redisTemplate.opsForList().range(key, 0, -1);
        } catch (Exception e) {
            log.error(e.getMessage(), e);
        }
        return null;
    }

    /**
     * hash     
     *    field        
     */
    public void hsetIfAbsent(String key, String field, String value) {
        try {
            redisTemplate.opsForHash().putIfAbsent(key, field, value);
        } catch (Exception e) {
            log.error(e.getMessage(), e);
        }
    }
   
    public boolean hasKey(String key) {
        return redisTemplate.hasKey(key);
    }

    /**
     *         score         key   
     * O(M*log(N))， N        ， M             
     *
     * @param key    key
     * @param value  member
     * @param source score
     * @return     
     */
    public Boolean zAdd(String key, String value, double source) {
        try {
            return redisTemplate.opsForZSet().add(key, value, source);
        } catch (Exception e) {
            log.error(e.getMessage(), e);
        }
        return null;
    }
}

2、redisTemplate2使用の違いは注入の違いです

import lombok.extern.slf4j.Slf4j;
@SuppressWarnings({"WeakerAccess", "unused"})
@Component
@Slf4j //   lombok         
public class RedisUtils {
    @Resource(name = "redisTemplate2")
    private RedisTemplate redisTemplate;
}