spring-data-redis详解

豆包ko

　　使用spring-data-redis实现java和redis的连接及操作
　　官方文档：http://projects.spring.io/spring-data-redis/#quick-start
　　1 下载 spring-data-redis的jar包

<dependencies>
<dependency>
<groupId>org.springframework.data</groupId>
<artifactId>spring-data-redis</artifactId>
<version>1.5.0.RELEASE</version>
</dependency>
</dependencies>
　　http://grepcode.com/snapshot/repo1.maven.org/maven2/org.springframework.data/spring-data-redis/1.4.0.RELEASE

[html] view plaincopyprint?

• 
  redis.host=192.168.1.20//redis的服务器地址  
  
• 
  redis.port=6400//redis的服务端口  
  
• 
  redis.pass=1234xxxxx//密码  
  
• 
  redis.default.db=0//链接数据库  
  
• 
  redis.timeout=100000//客户端超时时间单位是毫秒  
  
• 
  redis.maxActive=300// 最大连接数  
  
• 
  redis.maxIdle=100//最大空闲数  
  

redis.host=192.168.1.20//redis的服务器地址
redis.port=6400//redis的服务端口
redis.pass=1234xxxxx//密码
redis.default.db=0//链接数据库
redis.timeout=100000//客户端超时时间单位是毫秒
redis.maxActive=300// 最大连接数
redis.maxIdle=100//最大空闲数

[html] view plaincopyprint?

• 
  redis.maxWait=1000//最大建立连接等待时间  
  
• 
  redis.testOnBorrow=true//<span style="font-size: 12px;">指明是否在从池中取出连接前进行检验,如果检验失败,则从池中去除连接并尝试取出另一个</span>  
  

redis.maxWait=1000//最大建立连接等待时间
redis.testOnBorrow=true//指明是否在从池中取出连接前进行检验,如果检验失败,则从池中去除连接并尝试取出另一个
　　spring 中配置

[html] view plaincopyprint?

• 
  <bean id="propertyConfigurerRedis" class="org.springframework.beans.factory.config.PropertyPlaceholderConfigurer">  
  
•         <property name="order" value="1" />  
  
•         <property name="ignoreUnresolvablePlaceholders" value="true" />  
  
•         <property name="locations">  
  
•             <list>  
  
•                 <value>classpath:config/redis-manager-config.properties</value>  
  
•             </list>  
  
•         </property>  
  
•     </bean>  
  
•       
  
•         <!-- jedis pool配置 -->  
  
•     <bean id="jedisPoolConfig" class="redis.clients.jedis.JedisPoolConfig">  
  
•         <property name="maxActive" value="${redis.maxActive}" />  
  
•         <property name="maxIdle" value="${redis.maxIdle}" />  
  
•         <property name="maxWait" value="${redis.maxWait}" />  
  
•         <property name="testOnBorrow" value="${redis.testOnBorrow}" />  
  
•     </bean>  
  
•   
  
•     <!-- spring data redis -->  
  
•     <bean id="jedisConnectionFactory" class="org.springframework.data.redis.connection.jedis.JedisConnectionFactory">  
  
•         <property name="usePool" value="true"></property>  
  
•         <property name="hostName" value="${redis.host}" />  
  
•         <property name="port" value="${redis.port}" />  
  
•         <property name="password" value="${redis.pass}" />  
  
•         <property name="timeout" value="${redis.timeout}" />  
  
•         <property name="database" value="${redis.default.db}"></property>  
  
•         <constructor-arg index="0" ref="jedisPoolConfig" />  
  
•     </bean>  
  
•       
  
•     <bean id="redisTemplate" class="org.springframework.data.redis.core.StringRedisTemplate">  
  
•         <property name="connectionFactory" ref="jedisConnectionFactory" />  
  
•     </bean>  
  

<bean id="propertyConfigurerRedis" class="org.springframework.beans.factory.config.PropertyPlaceholderConfigurer">
<property name="order" value="1" />
<property name="ignoreUnresolvablePlaceholders" value="true" />
<property name="locations">
<list>
<value>classpath:config/redis-manager-config.properties</value>
</list>
</property>
</bean>
<!-- jedis pool配置 -->
<bean id="jedisPoolConfig" class="redis.clients.jedis.JedisPoolConfig">
<property name="maxActive" value="${redis.maxActive}" />
<property name="maxIdle" value="${redis.maxIdle}" />
<property name="maxWait" value="${redis.maxWait}" />
<property name="testOnBorrow" value="${redis.testOnBorrow}" />
</bean>
<!-- spring data redis -->
<bean id="jedisConnectionFactory" class="org.springframework.data.redis.connection.jedis.JedisConnectionFactory">
<property name="usePool" value="true"></property>
<property name="hostName" value="${redis.host}" />
<property name="port" value="${redis.port}" />
<property name="password" value="${redis.pass}" />
<property name="timeout" value="${redis.timeout}" />
<property name="database" value="${redis.default.db}"></property>
<constructor-arg index="0" ref="jedisPoolConfig" />
</bean>
<bean id="redisTemplate" class="org.springframework.data.redis.core.StringRedisTemplate">
<property name="connectionFactory" ref="jedisConnectionFactory" />
</bean>

[html] view plaincopyprint?

•    
  

 

[html] view plaincopyprint?

• 
  <!--配置一个基础类（之后的业务类继承于该类）、将redisTemplate注入 -->  
  

<!--配置一个基础类（之后的业务类继承于该类）、将redisTemplate注入 -->

[html] view plaincopyprint?

• 
  <bean id="redisBase" abstract="true">  
  
•   <property name="template" ref="redisTemplate"></property>  
  
•  </bean>  
  

<bean id="redisBase" abstract="true">
  <property name="template" ref="redisTemplate"></property>
 </bean>
　　
java代码：

[java] view plaincopyprint?

• 
  public class RedisBase {  
  
•   
  
•     private StringRedisTemplate template;  
  
•   
  
•     /** 
  
• 
       * @return the template 
  
• 
       */  
  
•     public StringRedisTemplate getTemplate() {  
  
•         return template;  
  
•     }  
  
•   
  
•     /** 
  
• 
       * @param template the template to set 
  
• 
       */  
  
•     public void setTemplate(StringRedisTemplate template) {  
  
•         this.template = template;  
  
•     }  
  
•   
  
• }  
  

public class RedisBase {
private StringRedisTemplate template;
/**
* @return the template
*/
public StringRedisTemplate getTemplate() {
return template;
}
/**
* @param template the template to set
*/
public void setTemplate(StringRedisTemplate template) {
this.template = template;
}
}
　　继续：
　　下面就是具体redis的值的写入、读出、清除缓存喽！
　　第一：写入

[java] view plaincopyprint?

• 
  public class StudentCountDO {  
  
•   
  
•     private Long id;  
  
•   
  
•        private String studentId;  
  
•   
  
•         private Long commentHeadCount;  
  
•   
  
•        private Long docAttitudeScores;  
  
•   
  
•        private Long guideServiceScores;  
  
•   
  
•         private Long treatEffectCount;  
  
•   
  
•        private Long treatEffectScores;  
  
•   
  
•     private String gmtModified;  
  
•   
  
•     private String gmtCreated;  
  
•   
  
•         private Long waitingTimeScores;  
  
•   
  
•    }  
  

public class StudentCountDO {
private Long id;
private String studentId;
private Long commentHeadCount;
private Long docAttitudeScores;
private Long guideServiceScores;
private Long treatEffectCount;
private Long treatEffectScores;
private String gmtModified;
private String gmtCreated;
private Long waitingTimeScores;
}
　　
 

[java] view plaincopyprint?

• StringRedisTemplate template = getTemplate();//获得上面注入的template  
  
•        // save as hash 一般key都要加一个前缀，方便清除所有的这类key  
  
•        BoundHashOperations<String, String, String> ops = template.boundHashOps("student:"+studentCount.getStudentId());  
  
•   
  
•        Map<String, String> data = new HashMap<String, String>();  
  
•        data.put("studentId", CommentUtils.convertNull(studentCount.getStudentId()));  
  
•        data.put("commentHeadCount", CommentUtils.convertLongToString(studentCount.getCommentHeadCount()));  
  
•        data.put("docAttitudeScores", CommentUtils.convertLongToString(studentCount.getDocAttitudeScores()));  
  
•        data.put("guideServicesScores", CommentUtils.convertLongToString(studentCount.getGuideServiceScores()));  
  
•        data.put("treatEffectCount", CommentUtils.convertLongToString(studentCount.getTreatEffectCount()));  
  
•        data.put("treatEffectScores", CommentUtils.convertLongToString(studentCount.getTreatEffectScores()));  
  
•        data.put("waitingTimeScores", CommentUtils.convertLongToString(studentCount.getWaitingTimeScores()));  
  
•        try {  
  
•            ops.putAll(data);  
  
•        } catch (Exception e) {  
  
•            logger.error(CommentConstants.WRITE_EXPERT_COMMENT_COUNT_REDIS_ERROR + studentCount.studentCount(), e);  
  
•        }  
  

StringRedisTemplate template = getTemplate();//获得上面注入的template
// save as hash 一般key都要加一个前缀，方便清除所有的这类key
BoundHashOperations<String, String, String> ops = template.boundHashOps("student:"+studentCount.getStudentId());
Map<String, String> data = new HashMap<String, String>();
data.put("studentId", CommentUtils.convertNull(studentCount.getStudentId()));
data.put("commentHeadCount", CommentUtils.convertLongToString(studentCount.getCommentHeadCount()));
data.put("docAttitudeScores", CommentUtils.convertLongToString(studentCount.getDocAttitudeScores()));
data.put("guideServicesScores", CommentUtils.convertLongToString(studentCount.getGuideServiceScores()));
data.put("treatEffectCount", CommentUtils.convertLongToString(studentCount.getTreatEffectCount()));
data.put("treatEffectScores", CommentUtils.convertLongToString(studentCount.getTreatEffectScores()));
data.put("waitingTimeScores", CommentUtils.convertLongToString(studentCount.getWaitingTimeScores()));
try {
ops.putAll(data);
} catch (Exception e) {
logger.error(CommentConstants.WRITE_EXPERT_COMMENT_COUNT_REDIS_ERROR + studentCount.studentCount(), e);
}
　　第二、 取出

[java] view plaincopyprint?

• 
  public StudentCountDO getStudentCommentCountInfo(String studentId) {  
  
•        final String strkey = "student:"+ studentId;  
  
•        return getTemplate().execute(new RedisCallback<StudentCountDO>() {  
  
•            @Override  
  
•            public StudentCountDO doInRedis(RedisConnection connection) throws DataAccessException {  
  
•                byte[] bkey = getTemplate().getStringSerializer().serialize(strkey);  
  
•                if (connection.exists(bkey)) {  
  
•                    List<byte[]> value = connection.hMGet(bkey,  
  
•                            getTemplate().getStringSerializer().serialize("studentId"), getTemplate()  
  
•                                    .getStringSerializer().serialize("commentHeadCount"), getTemplate()  
  
•                                    .getStringSerializer().serialize("docAttitudeScores"), getTemplate()  
  
•                                    .getStringSerializer().serialize("guideServicesScores"), getTemplate()  
  
•                                    .getStringSerializer().serialize("treatEffectCount"), getTemplate()  
  
•                                    .getStringSerializer().serialize("treatEffectScores"), getTemplate()  
  
•                                    .getStringSerializer().serialize("waitingTimeScores"));  
  
•                    StudentCountDO studentCommentCountDO = new StudentCountDO();  
  
•                    studentCommentCountDO.setExpertId(getTemplate().getStringSerializer().deserialize(value.get(0)));  
  
•                    studentCommentCountDO.setCommentHeadCount(Long.parseLong(getTemplate().getStringSerializer()  
  
•                            .deserialize(value.get(1))));  
  
•                    studentCommentCountDO.setDocAttitudeScores(Long.parseLong(getTemplate().getStringSerializer()  
  
•                            .deserialize(value.get(2))));  
  
•                    studentCommentCountDO.setGuideServiceScores(Long.parseLong(getTemplate().getStringSerializer()  
  
•                            .deserialize(value.get(3))));  
  
•                    studentCommentCountDO.setTreatEffectCount(Long.parseLong(getTemplate().getStringSerializer()  
  
•                            .deserialize(value.get(4))));  
  
•                    studentCommentCountDO.setTreatEffectScores(Long.parseLong(getTemplate().getStringSerializer()  
  
•                            .deserialize(value.get(5))));  
  
•                    studentCommentCountDO.setWaitingTimeScores(Long.parseLong(getTemplate().getStringSerializer()  
  
•                            .deserialize(value.get(6))));  
  
•                    return studentCommentCountDO;  
  
•                }  
  
•                return null;  
  
•            }  
  
•        });  
  
•    }  
  

public StudentCountDO getStudentCommentCountInfo(String studentId) {
final String strkey = "student:"+ studentId;
return getTemplate().execute(new RedisCallback<StudentCountDO>() {
@Override
public StudentCountDO doInRedis(RedisConnection connection) throws DataAccessException {
byte[] bkey = getTemplate().getStringSerializer().serialize(strkey);
if (connection.exists(bkey)) {
List<byte[]> value = connection.hMGet(bkey,
getTemplate().getStringSerializer().serialize("studentId"), getTemplate()
.getStringSerializer().serialize("commentHeadCount"), getTemplate()
.getStringSerializer().serialize("docAttitudeScores"), getTemplate()
.getStringSerializer().serialize("guideServicesScores"), getTemplate()
.getStringSerializer().serialize("treatEffectCount"), getTemplate()
.getStringSerializer().serialize("treatEffectScores"), getTemplate()
.getStringSerializer().serialize("waitingTimeScores"));
StudentCountDO studentCommentCountDO = new StudentCountDO();
studentCommentCountDO.setExpertId(getTemplate().getStringSerializer().deserialize(value.get(0)));
studentCommentCountDO.setCommentHeadCount(Long.parseLong(getTemplate().getStringSerializer()
.deserialize(value.get(1))));
studentCommentCountDO.setDocAttitudeScores(Long.parseLong(getTemplate().getStringSerializer()
.deserialize(value.get(2))));
studentCommentCountDO.setGuideServiceScores(Long.parseLong(getTemplate().getStringSerializer()
.deserialize(value.get(3))));
studentCommentCountDO.setTreatEffectCount(Long.parseLong(getTemplate().getStringSerializer()
.deserialize(value.get(4))));
studentCommentCountDO.setTreatEffectScores(Long.parseLong(getTemplate().getStringSerializer()
.deserialize(value.get(5))));
studentCommentCountDO.setWaitingTimeScores(Long.parseLong(getTemplate().getStringSerializer()
.deserialize(value.get(6))));
return studentCommentCountDO;
}
return null;
}
});
}
　　这个存和取的过程其实是把对象中的各个字段序列化之后存入到hashmap 、取出来的时候在进行按照存入进去的顺序进行取出。
　　第三 清除
　　这个就根据前面的前缀很简单了，一句代码就搞定啦！

[java] view plaincopyprint?

• 
  private void clear(String pattern) {  
  
•        StringRedisTemplate template = getTemplate();  
  
•        Set<String> keys = template.keys(pattern);  
  
•        if (!keys.isEmpty()) {  
  
•            template.delete(keys);  
  
•        }  
  
•    }  
  

private void clear(String pattern) {
StringRedisTemplate template = getTemplate();
Set<String> keys = template.keys(pattern);
if (!keys.isEmpty()) {
template.delete(keys);
}
}
　　pattern传入为student: 就可以将该类型的所有缓存清除掉喽！