`

spring-data-redis详解

spring-data-redis详解 
阅读更多

使用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?
  1. redis.host=192.168.1.20//redis的服务器地址  
  2. redis.port=6400//redis的服务端口  
  3. redis.pass=1234xxxxx//密码  
  4. redis.default.db=0//链接数据库  
  5. redis.timeout=100000//客户端超时时间单位是毫秒  
  6. redis.maxActive=300// 最大连接数  
  7. 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?
  1. redis.maxWait=1000//最大建立连接等待时间  
  2. redis.testOnBorrow=true//<span style="font-size: 12px;">指明是否在从池中取出连接前进行检验,如果检验失败,则从池中去除连接并尝试取出另一个</span>  
redis.maxWait=1000//最大建立连接等待时间
redis.testOnBorrow=true//指明是否在从池中取出连接前进行检验,如果检验失败,则从池中去除连接并尝试取出另一个

spring 中配置

[html] view plaincopyprint?
  1. <bean id="propertyConfigurerRedis" class="org.springframework.beans.factory.config.PropertyPlaceholderConfigurer">  
  2.         <property name="order" value="1" />  
  3.         <property name="ignoreUnresolvablePlaceholders" value="true" />  
  4.         <property name="locations">  
  5.             <list>  
  6.                 <value>classpath:config/redis-manager-config.properties</value>  
  7.             </list>  
  8.         </property>  
  9.     </bean>  
  10.       
  11.         <!-- jedis pool配置 -->  
  12.     <bean id="jedisPoolConfig" class="redis.clients.jedis.JedisPoolConfig">  
  13.         <property name="maxActive" value="${redis.maxActive}" />  
  14.         <property name="maxIdle" value="${redis.maxIdle}" />  
  15.         <property name="maxWait" value="${redis.maxWait}" />  
  16.         <property name="testOnBorrow" value="${redis.testOnBorrow}" />  
  17.     </bean>  
  18.   
  19.     <!-- spring data redis -->  
  20.     <bean id="jedisConnectionFactory" class="org.springframework.data.redis.connection.jedis.JedisConnectionFactory">  
  21.         <property name="usePool" value="true"></property>  
  22.         <property name="hostName" value="${redis.host}" />  
  23.         <property name="port" value="${redis.port}" />  
  24.         <property name="password" value="${redis.pass}" />  
  25.         <property name="timeout" value="${redis.timeout}" />  
  26.         <property name="database" value="${redis.default.db}"></property>  
  27.         <constructor-arg index="0" ref="jedisPoolConfig" />  
  28.     </bean>  
  29.       
  30.     <bean id="redisTemplate" class="org.springframework.data.redis.core.StringRedisTemplate">  
  31.         <property name="connectionFactory" ref="jedisConnectionFactory" />  
  32.     </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?
  1.    
 
[html] view plaincopyprint?
  1. <!--配置一个基础类（之后的业务类继承于该类）、将redisTemplate注入 -->  
<!--配置一个基础类（之后的业务类继承于该类）、将redisTemplate注入 -->
[html] view plaincopyprint?
  1. <bean id="redisBase" abstract="true">  
  2.   <property name="template" ref="redisTemplate"></property>  
  3.  </bean>  
<bean id="redisBase" abstract="true">
  <property name="template" ref="redisTemplate"></property>
 </bean>


java代码：

[java] view plaincopyprint?
  1. public class RedisBase {  
  2.   
  3.     private StringRedisTemplate template;  
  4.   
  5.     /** 
  6.      * @return the template 
  7.      */  
  8.     public StringRedisTemplate getTemplate() {  
  9.         return template;  
  10.     }  
  11.   
  12.     /** 
  13.      * @param template the template to set 
  14.      */  
  15.     public void setTemplate(StringRedisTemplate template) {  
  16.         this.template = template;  
  17.     }  
  18.   
  19. }  
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?
  1. public class StudentCountDO {  
  2.   
  3.     private Long id;  
  4.   
  5.        private String studentId;  
  6.   
  7.         private Long commentHeadCount;  
  8.   
  9.        private Long docAttitudeScores;  
  10.   
  11.        private Long guideServiceScores;  
  12.   
  13.         private Long treatEffectCount;  
  14.   
  15.        private Long treatEffectScores;  
  16.   
  17.     private String gmtModified;  
  18.   
  19.     private String gmtCreated;  
  20.   
  21.         private Long waitingTimeScores;  
  22.   
  23.    }  
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?
  1. StringRedisTemplate template = getTemplate();//获得上面注入的template  
  2.        // save as hash 一般key都要加一个前缀，方便清除所有的这类key  
  3.        BoundHashOperations<String, String, String> ops = template.boundHashOps("student:"+studentCount.getStudentId());  
  4.   
  5.        Map<String, String> data = new HashMap<String, String>();  
  6.        data.put("studentId", CommentUtils.convertNull(studentCount.getStudentId()));  
  7.        data.put("commentHeadCount", CommentUtils.convertLongToString(studentCount.getCommentHeadCount()));  
  8.        data.put("docAttitudeScores", CommentUtils.convertLongToString(studentCount.getDocAttitudeScores()));  
  9.        data.put("guideServicesScores", CommentUtils.convertLongToString(studentCount.getGuideServiceScores()));  
  10.        data.put("treatEffectCount", CommentUtils.convertLongToString(studentCount.getTreatEffectCount()));  
  11.        data.put("treatEffectScores", CommentUtils.convertLongToString(studentCount.getTreatEffectScores()));  
  12.        data.put("waitingTimeScores", CommentUtils.convertLongToString(studentCount.getWaitingTimeScores()));  
  13.        try {  
  14.            ops.putAll(data);  
  15.        } catch (Exception e) {  
  16.            logger.error(CommentConstants.WRITE_EXPERT_COMMENT_COUNT_REDIS_ERROR + studentCount.studentCount(), e);  
  17.        }  
 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?
  1. public StudentCountDO getStudentCommentCountInfo(String studentId) {  
  2.        final String strkey = "student:"+ studentId;  
  3.        return getTemplate().execute(new RedisCallback<StudentCountDO>() {  
  4.            @Override  
  5.            public StudentCountDO doInRedis(RedisConnection connection) throws DataAccessException {  
  6.                byte[] bkey = getTemplate().getStringSerializer().serialize(strkey);  
  7.                if (connection.exists(bkey)) {  
  8.                    List<byte[]> value = connection.hMGet(bkey,  
  9.                            getTemplate().getStringSerializer().serialize("studentId"), getTemplate()  
  10.                                    .getStringSerializer().serialize("commentHeadCount"), getTemplate()  
  11.                                    .getStringSerializer().serialize("docAttitudeScores"), getTemplate()  
  12.                                    .getStringSerializer().serialize("guideServicesScores"), getTemplate()  
  13.                                    .getStringSerializer().serialize("treatEffectCount"), getTemplate()  
  14.                                    .getStringSerializer().serialize("treatEffectScores"), getTemplate()  
  15.                                    .getStringSerializer().serialize("waitingTimeScores"));  
  16.                    StudentCountDO studentCommentCountDO = new StudentCountDO();  
  17.                    studentCommentCountDO.setExpertId(getTemplate().getStringSerializer().deserialize(value.get(0)));  
  18.                    studentCommentCountDO.setCommentHeadCount(Long.parseLong(getTemplate().getStringSerializer()  
  19.                            .deserialize(value.get(1))));  
  20.                    studentCommentCountDO.setDocAttitudeScores(Long.parseLong(getTemplate().getStringSerializer()  
  21.                            .deserialize(value.get(2))));  
  22.                    studentCommentCountDO.setGuideServiceScores(Long.parseLong(getTemplate().getStringSerializer()  
  23.                            .deserialize(value.get(3))));  
  24.                    studentCommentCountDO.setTreatEffectCount(Long.parseLong(getTemplate().getStringSerializer()  
  25.                            .deserialize(value.get(4))));  
  26.                    studentCommentCountDO.setTreatEffectScores(Long.parseLong(getTemplate().getStringSerializer()  
  27.                            .deserialize(value.get(5))));  
  28.                    studentCommentCountDO.setWaitingTimeScores(Long.parseLong(getTemplate().getStringSerializer()  
  29.                            .deserialize(value.get(6))));  
  30.                    return studentCommentCountDO;  
  31.                }  
  32.                return null;  
  33.            }  
  34.        });  
  35.    }  
 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?
  1. private void clear(String pattern) {  
  2.        StringRedisTemplate template = getTemplate();  
  3.        Set<String> keys = template.keys(pattern);  
  4.        if (!keys.isEmpty()) {  
  5.            template.delete(keys);  
  6.        }  
  7.    }  
 private void clear(String pattern) {
        StringRedisTemplate template = getTemplate();
        Set<String> keys = template.keys(pattern);
        if (!keys.isEmpty()) {
            template.delete(keys);
        }
    }

pattern传入为student: 就可以将该类型的所有缓存清除掉喽！

 

 

 

 

 

 

 

 

 

 

 

 

分享到：
| redis研究-java连接操作redis
评论
发表评论

您还没有登录,请您登录后再发表评论

相关推荐

    spring-data-redis实例

    《Spring Data Redis实战详解》 在现代Web应用中，数据的高效存储和访问是至关重要的。Spring Data Redis作为Spring框架的一部分，为开发者提供了强大的Redis支持，使得我们可以充分利用Redis的高性能特性，实现...

    spring-boot-整合redis

    ### Spring Boot 整合 Redis 实现详解 #### 一、Redis 概述 Redis 是一款高性能的开源非关系型数据库，使用 C 语言编写。它将数据存储在内存中，这意味着相较于传统的磁盘存储数据库，Redis 提供了更快的数据访问...

    Spring-data-redis使用指南

    ### Spring Data Redis 使用指南知识点详解 #### 一、Spring Data Redis 概览 **Spring Data Redis** 是 **Spring Data** 家族中的一个模块，它为 **Redis** 提供了一套方便的操作接口，使得开发人员可以更加高效...

    spring-boot2集成redis

    **Spring Boot 2 集成 Redis 知识点详解** Spring Boot 2 提供了对 Redis 的便捷集成，使得开发者能够快速地在 Spring 应用中利用 Redis 的高性能存储特性。以下将详细介绍如何在 Spring Boot 2 项目中集成 Redis，...

    spring-boot-demo-cluster-redis-websocket.zip

    《Spring Boot、Redis与WebSocket构建集群应用详解》 在现代Web开发中，实时通信功能日益重要，Spring Boot作为Java领域中的轻量级框架，结合WebSocket和Redis可以构建出高效的实时推送系统。本项目"spring-boot-...

    spring-data-redis-example

    《Spring Data Redis实战详解》 在当今的软件开发领域，数据存储和检索是核心环节，而Redis作为一种高性能的键值数据库，因其高速读写、丰富的数据结构以及支持主从复制和事务等特性，被广泛应用于缓存、消息队列、...

    Springboot 2.X中Spring-cache与redis整合

    **Spring Boot 2.X 中 Spring Cache 与 Redis 整合详解** 在现代的 Web 应用开发中，缓存机制是提升系统性能的关键技术之一。Spring Cache 是 Spring 框架提供的一种统一的缓存抽象，它允许开发者通过简单的注解来...

    spring-boot+redis+mybatis.zip

    《Spring Boot + Redis + MyBatis 整合实践详解》 在现代Java开发中，Spring Boot以其简洁的配置、快速的开发效率以及丰富的生态而备受青睐。本项目案例结合了Spring Boot、Redis缓存和MyBatis持久层框架，旨在提供...

    pring-data-redisjar和源文件

    《Spring Data Redis 深入解析与实战指南》 在当今大数据时代，Redis作为一个高性能的键值数据库，因其高效的数据处理能力以及丰富的数据结构而备受青睐。Spring Data Redis是Spring框架的一部分，它为Redis提供了...

    spring-redis jar

    《Spring与Redis的集成应用详解》 在现代的Web开发中，数据缓存技术起着至关重要的作用，它能够显著提升应用的性能和响应速度。Spring框架作为Java领域中的主流开发框架，提供了丰富的扩展性，使得与其他技术的集成...

    spring-data的学习笔记

    ### SpringData知识点详解 #### SpringData简介 SpringData是Spring框架下的一个重要子项目，它的主要目标是为开发者提供一种统一的方式来访问不同的数据存储系统。通过SpringData，开发者能够以一致的方式处理不同...

    8-Redis常用命令-list-set-zset.docx

    Redis 常用命令 - List 类型详解 Redis 是一个开源的、基于内存的数据结构存储系统，支持五种数据类型：string（字符串）、hash（哈希）、list（列表）、set（集合）及 zset（有序集合）。本文将详细介绍 Redis 的 ...

    spring boot - redis-1

    **Spring Boot 集成 Redis 知识点详解** 在现代Web开发中，Spring Boot以其简洁的配置和强大的功能成为了Java开发者的首选框架之一。在处理高并发、数据持久化等场景时，Redis作为一个高性能的键值存储系统，被广泛...

    springboot-mybatis-mysql-redis demo.zip

    SpringData Redis提供了一套丰富的API，如StringTemplate、HashTemplate等，便于我们在业务代码中操作Redis。 五、SpringBoot、MyBatis与Redis整合实战 在实际项目中，我们常常会结合这三大技术进行数据处理。例如...

    Spring Data Redis中文参考文档

    ### Spring Data Redis中文参考文档知识点总结 #### 一、Spring Data Redis概述 **Spring Data Redis** 是Spring Data项目的一部分，它为开发人员提供了利用Redis这一高性能键值存储数据库的能力。该文档介绍了...

    详解Spring Data操作Redis数据库

    Spring Data Redis是Spring框架的一部分，专门用于简化与Redis数据库的交互。Redis是一个高效、高性能的键值存储系统，常被用作数据库、缓存和消息中间件。它支持丰富的数据结构，包括字符串、散列、列表、集合、...

    Spring Boot Redis 实现分布式锁的方法详解.docx

    1. `spring-boot-starter-data-redis`：提供 Spring Boot 对 Redis 的支持。 2. `spring-boot-starter-integration`：包含 Spring Integration 框架的基础功能。 3. `spring-integration-redis`：包含 Redis 相关的...

    spring-boot级spring-cloud视频教学

    例如，如果你想要在项目中添加Redis缓存支持，只需要添加`spring-boot-starter-data-redis`依赖即可。 2. **自动配置**：Spring Boot会根据添加的依赖来自动配置Bean，开发者无需过多配置即可实现所需功能。 #### ...

    spring-5.2.0.RELEASE-dist.zip

    《Spring框架5.2.0.RELEASE源码详解》 Spring框架是Java开发中的核心工具集，它为构建可重用、松耦合且易于测试的软件提供了基础。Spring 5.2.0.RELEASE是该框架的一个重要版本，带来了许多新特性、改进和优化。在...

Magicbox
Global site tag (gtag.js) - Google Analytics