共计 6476 个字符，预计需要花费 17 分钟才能阅读完成。
需要的 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 对象)。
使用 spring 注解式来配置 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, 但是需要在加载的配置文件配置文件路径即可, 具体值自己指定吧 …
<value>classpath:properties/spring-redis-cluster.properties</value>
3. 由于我们公司原有的框架采用的是 spring2.5.6，而对于 spring2 和 spring2+ 主要区别（当然是我自己觉得啊）是把各模块分成了不同的 jar，而对于使用 spring-data-redis 模板化处理 redis 的话，单机情况下 spring2.5.6 和 spring4 不会冲突，而如果使用集群模式需要配置 redis 集群的时候就会出现 jar 包冲突，这个时候就看要如何取决了，可以直接使用 jedisCluster 来连接 redis 集群（不过很多方法都需要自己去写），也可以把 spring2.5.6 替换成高版本的 spring4，只是框架替换需要注意的事情更多了啊（我们公司的直接全部替换没啥毛病好吧，O(∩_∩)O 哈哈~），至于重写 JedisConnectionFactory 和 RedisClusterConfiguration 我还未去尝试，这个可以作为后续补充吧 …
4. 顺便说句，spring4 不在支持 ibatis 了，如果你需要用 spring4，又需要连接 ibatis 的话，最粗暴的方式是把 spring-orm 包换成 spring3 版本，其他的 jar 还是 4 版本即可。（当然我这边直接替换是没啥问题，但同 3 一样可能存在潜在问题啊，所以说嘛，公司有时候还是需要更新换代下吧 …）
