Spring 기반 Redis 구성(독립형 ​​및 클러스터 모드)

이 기사에서 제공하는 내용은 Spring 기반 Redis 구성(독립 실행형 및 클러스터 모드)에 대한 것입니다. 필요한 친구가 참고할 수 있기를 바랍니다.

필수 jar 패키지: spring 버전: 4.3.6.RELEASE, jedis 버전: 2.9.0, spring-data-redis: 1.8.0.RELEASE; jackson 직렬화를 사용하는 경우 jackson-annotations 및 jackson도 필요합니다. Databind 패키지

spring集成redis单机版：
    1.配置RedisTemplate
        <bean id="redisTemplate" class="org.springframework.data.redis.core.RedisTemplate">
            <property name="connectionFactory" ref="connectionFactory"/>
            <property name="defaultSerializer" ref="stringRedisSerializer"/>
            <property name="keySerializer" ref="stringRedisSerializer"/>
            <property name="valueSerializer" ref="valueSerializer"/>
        </bean>
    2.配置connectionFactory
        <bean id="connectionFactory"  class="org.springframework.data.redis.connection.jedis.JedisConnectionFactory">
            <!-- 配置ip -->
            <property name="hostName" value="${redis.host}"/>
            <!-- 配置port -->
            <property name="port" value="${redis.port}"/>
            <!-- 是否使用连接池-->
            <property name="usePool" value="${redis.usePool}"/>
            <!-- 配置redis连接池-->
            <property name="poolConfig" ref="poolConfig"/>
        </bean>
   3.配置连接池
        <bean id="poolConfig" class="redis.clients.jedis.JedisPoolConfig">
            <!--最大空闲实例数-->
            <property name="maxIdle" value="${redis.maxIdle}" />
            <!--最大活跃实例数-->
            <property name="maxTotal" value="${redis.maxTotal}" />
            <!--创建实例时最长等待时间-->
            <property name="maxWaitMillis" value="${redis.maxWaitMillis}" />
            <!--创建实例时是否验证-->
            <property name="testOnBorrow" value="${redis.testOnBorrow}" />
        </bean>

spring集成redis集群
    1.配置RedisTemplate步骤与单机版一致
    2.配置connectionFactory
        <bean id="connectionFactory"  class="org.springframework.data.redis.connection.jedis.JedisConnectionFactory">
            <!-- 配置redis连接池-->    
            <constructor-arg ref="poolConfig"></constructor-arg>
            <!-- 配置redis集群-->  
         <constructor-arg ref="clusterConfig"></constructor-arg>
            <!-- 是否使用连接池-->
            <property name="usePool" value="${redis.usePool}"/>
        </bean>
    3.配置连接池步骤与单机版一致
    4.配置redis集群
        <bean id="clusterConfig" class="org.springframework.data.redis.connection.RedisClusterConfiguration">
            <property name="maxRedirects" value="3"></property>
            <property name="clusterNodes">
                <set>
                    <bean class="org.springframework.data.redis.connection.RedisClusterNode">
                        <constructor-arg value="${redis.host1}"></constructor-arg>
                        <constructor-arg value="${redis.port1}"></constructor-arg>
                    </bean>
                    <bean class="org.springframework.data.redis.connection.RedisClusterNode">
                        <constructor-arg value="${redis.host2}"></constructor-arg>
                        <constructor-arg value="${redis.port2}"></constructor-arg>
                    </bean>
                    ......
                </set>
            </property>
        </bean>
    或者
        <bean name="propertySource" class="org.springframework.core.io.support.ResourcePropertySource">
            <constructor-arg name="location" value="classpath:properties/spring-redis-cluster.properties" />
        </bean>
        <bean id="clusterConfig" class="org.springframework.data.redis.connection.RedisClusterConfiguration">
            <constructor-arg name="propertySource" ref="propertySource"/>
        </bean>

직렬화 구성에 대한 간략한 설명:

1.stringRedisSerializer：由于redis的key是String类型所以一般使用StringRedisSerializer
2.valueSerializer：对于redis的value序列化，spring-data-redis提供了许多序列化类，这里建议使用Jackson2JsonRedisSerializer，默认为JdkSerializationRedisSerializer
3.JdkSerializationRedisSerializer： 使用JDK提供的序列化功能。 优点是反序列化时不需要提供类型信息(class)，但缺点是序列化后的结果非常庞大，是JSON格式的5倍左右，这样就会消耗redis服务器的大量内存。
4.Jackson2JsonRedisSerializer：使用Jackson库将对象序列化为JSON字符串。优点是速度快，序列化后的字符串短小精悍。但缺点也非常致命，那就是此类的构造函数中有一个类型参数，必须提供要序列化对象的类型信息(.class对象)。

스프링 주석을 사용하여 Redis를 구성하세요. 여기에 클러스터 예제만 있습니다

@Configuration
@EnableCaching
public class RedisConfig extends CachingConfigurerSupport {

    //spring3支持注解方式获取value 在application里配置配置文件路径即可获取
    @Value("${spring.redis.cluster.nodes}")
    private String clusterNodes;

    @Value("${spring.redis.cluster.timeout}")
    private Long timeout;

    @Value("${spring.redis.cluster.max-redirects}")
    private int redirects;

    @Value("${redis.maxIdle}")
    private int maxIdle;

    @Value("${redis.maxTotal}")
    private int maxTotal;

    @Value("${redis.maxWaitMillis}")
    private long maxWaitMillis;

    @Value("${redis.testOnBorrow}")
    private boolean testOnBorrow;

    /**
     * 选择redis作为默认缓存工具
     * @param redisTemplate
     * @return
     */
    @Bean
    public CacheManager cacheManager(RedisTemplate redisTemplate) {
        RedisCacheManager cacheManager = new RedisCacheManager(redisTemplate);
        //cacheManager.setDefaultExpiration(60);
        //Map<String,Long> expiresMap=new HashMap<>();
        //expiresMap.put("redisCache",5L);
        //cacheManager.setExpires(expiresMap);
        return cacheManager;
    }

    @Bean
    public RedisClusterConfiguration redisClusterConfiguration(){
        Map<String, Object> source = new HashMap<>();
        source.put("spring.redis.cluster.nodes", clusterNodes);
        source.put("spring.redis.cluster.timeout", timeout);
        source.put("spring.redis.cluster.max-redirects", redirects);
        return new RedisClusterConfiguration(new MapPropertySource("RedisClusterConfiguration", source));
    }

    @Bean
    public JedisConnectionFactory redisConnectionFactory(RedisClusterConfiguration configuration){
        JedisPoolConfig poolConfig = new JedisPoolConfig();
        poolConfig.setMaxIdle(maxIdle);
        poolConfig.setMaxTotal(maxTotal); 
        poolConfig.setMaxWaitMillis(maxWaitMillis);
        poolConfig.setTestOnBorrow(testOnBorrow);
        return new JedisConnectionFactory(configuration,poolConfig);
    }

    /**
     * retemplate相关配置
     * @param factory
     * @return
     */
    @Bean
    public RedisTemplate<String, Object> redisTemplate(JedisConnectionFactory factory) {

        RedisTemplate<String, Object> template = new RedisTemplate<>();
        // 配置连接工厂
        template.setConnectionFactory(factory);

        //使用Jackson2JsonRedisSerializer来序列化和反序列化redis的value值（默认使用JDK的序列化方式）
        Jackson2JsonRedisSerializer jacksonSeial = new Jackson2JsonRedisSerializer(Object.class);

        ObjectMapper om = new ObjectMapper();
        // 指定要序列化的域，field,get和set,以及修饰符范围，ANY是都有包括private和public
        om.setVisibility(PropertyAccessor.ALL, JsonAutoDetect.Visibility.ANY);
        // 指定序列化输入的类型，类必须是非final修饰的，final修饰的类，比如String,Integer等会跑出异常
        //om.enableDefaultTyping(ObjectMapper.DefaultTyping.NON_FINAL);
        jacksonSeial.setObjectMapper(om);

        // 值采用json序列化
        template.setValueSerializer(jacksonSeial);
        //使用StringRedisSerializer来序列化和反序列化redis的key值
        template.setKeySerializer(new StringRedisSerializer());

        // 设置hash key 和value序列化模式
        template.setHashKeySerializer(new StringRedisSerializer());
    
        template.setHashValueSerializer(jacksonSeial);
        template.afterPropertiesSet();

        return template;
    }
}

참고:

1. 주석을 사용하여 Redis를 구성하거나 @Configuration을 사용해야 합니다. 파일은 어떤 패키지에서 스캔할지 지정합니다. 물론, springboot라면 이렇게 말하지 않았습니다...

<context:component-scan base-package="com.*"/>

2. spring3은 값을 얻기 위해 주석 방법을 지원하지만 로드된 파일에서 구성해야 합니다. 경로가 충분하므로 직접 특정 값을 지정할 수 있습니다...

<value>classpath:properties/spring-redis-cluster.properties</value>

3. 우리 회사의 원래 프레임워크는 spring2.5.6을 사용하므로 spring2와 spring2+의 주요 차이점은 다음과 같습니다. 각 모듈은 서로 다른 jar로 나누어져 있습니다. redis를 처리하기 위해 spring-data-redis 템플릿을 사용하는 경우, spring2.5.6과 spring4는 독립 실행형 상황에서 충돌하지 않으며 redis를 구성해야 합니다. 클러스터, jar 패키지 충돌이 발생합니다. 이때 결정하는 방법에 따라 다릅니다. jedisCluster를 사용하여 redis 클러스터에 직접 연결할 수도 있고(단, 많은 메소드를 직접 작성해야 함) spring2.5.6을 다음으로 대체할 수 있습니다. spring4 상위버젼인데 프레임워크 교체시 주의할 점이 더 많네요. 네 (저희 회사에서 직접 전부 교체해도 문제는 없군요, O(∩_∩)O ㅎㅎ~) RedisClusterConfiguration은 아직 시도하지 않았습니다. 이것은 후속 보충 자료로 사용할 수 있습니다...

4 그런데 Spring 4는 더 이상 ibatis를 지원하지 않습니다. spring 4를 사용하고 ibatis에 연결해야 한다면, 가장 조잡한 방법은 spring-orm 패키지를 spring 3 버전으로 바꾸는 것이고, 다른 jar는 여전히 버전 4에 있을 수 있습니다. (물론 여기서 직접 교체해도 문제는 없으나 3번과 같은 잠재적인 문제가 있을 수 있으니 아직은 회사에서 가끔 업데이트를 해줘야 겠지만...)

위 내용은 Spring 기반 Redis 구성(독립형 ​​및 클러스터 모드)의 상세 내용입니다. 자세한 내용은 PHP 중국어 웹사이트의 기타 관련 기사를 참조하세요!