spring整合redis

本文涉及的产品
云原生内存数据库 Tair,内存型 2GB
云数据库 RDS MySQL,集群版 2核4GB 100GB
推荐场景:
搭建个人博客
云数据库 Redis 版,社区版 2GB
推荐场景:
搭建游戏排行榜
简介:

spring 整合redis

导入依赖

<dependency>
    <groupId>redis.clients</groupId>
    <artifactId>jedis</artifactId>
    <version>2.9.0</version>
</dependency>
<dependency>
    <groupId>org.springframework.data</groupId>
    <artifactId>spring-data-redis</artifactId>
    <version>1.7.5.RELEASE</version>
</dependency>

配置文件

redis.properties

redis相关参数文件:

#ip地址  
redis.host.ip=127.0.0.1
#端口号  
redis.port=6379  
#如果有密码  
redis.password=  
#客户端超时时间单位是毫秒 默认是2000  
redis.timeout=3000  

#最大空闲数  
redis.maxIdle=6  
#连接池的最大数据库连接数。设为0表示无限制,如果是jedis 2.4以后用redis.maxTotal  
#redis.maxActive=600  
#控制一个pool可分配多少个jedis实例,用来替换上面的redis.maxActive,如果是jedis 2.4以后用该属性  
redis.maxTotal=20  
#最大建立连接等待时间。如果超过此时间将接到异常。设为-1表示无限制。  
redis.maxWaitMillis=3000  
#连接的最小空闲时间 默认1800000毫秒(30分钟)  
redis.minEvictableIdleTimeMillis=300000  
#每次释放连接的最大数目,默认3  
redis.numTestsPerEvictionRun=4  
#逐出扫描的时间间隔(毫秒) 如果为负数,则不运行逐出线程, 默认-1  
redis.timeBetweenEvictionRunsMillis=30000  

applicationContext-redis.xml

spring整合redis配置文件:

    <!--1,如果你有多个数据源需要通过<context:property-placeholder管理,且不愿意放在一个配置文件里,那么一定要加上ignore-unresolvable=“true" -->
    <context:property-placeholder location="classpath:redis.properties"
        ignore-unresolvable="true" />

    <!--2,注意新版本2.3以后,JedisPoolConfig的property name,不是maxActive而是maxTotal,而且没有maxWait属性,建议看一下Jedis源码或百度。 -->
    <!-- redis连接池配置 -->
    <bean id="jedisPoolConfig" class="redis.clients.jedis.JedisPoolConfig">
        <!--最大空闲数 -->
        <property name="maxIdle" value="${redis.maxIdle}" />
        <!--连接池的最大数据库连接数 -->
        <property name="maxTotal" value="${redis.maxTotal}" />
        <!--最大建立连接等待时间 -->
        <property name="maxWaitMillis" value="${redis.maxWaitMillis}" />
        <!--逐出连接的最小空闲时间 默认1800000毫秒(30分钟) -->
        <property name="minEvictableIdleTimeMillis" value="${redis.minEvictableIdleTimeMillis}" />
        <!--每次逐出检查时 逐出的最大数目 如果为负数就是 : 1/abs(n), 默认3 -->
        <property name="numTestsPerEvictionRun" value="${redis.numTestsPerEvictionRun}" />
        <!--逐出扫描的时间间隔(毫秒) 如果为负数,则不运行逐出线程, 默认-1 -->
        <property name="timeBetweenEvictionRunsMillis" value="${redis.timeBetweenEvictionRunsMillis}" />
    </bean>

    <!--redis连接工厂 -->
    <bean id="jedisConnectionFactory"
        class="org.springframework.data.redis.connection.jedis.JedisConnectionFactory"
        destroy-method="destroy">
        <property name="poolConfig" ref="jedisPoolConfig"></property>
        <!--IP地址 -->
        <property name="hostName" value="${redis.host.ip}"></property>
        <!--端口号 -->
        <property name="port" value="${redis.port}"></property>
        <!--如果Redis设置有密码 -->
        <!-- <property name="password" value="${redis.password}" /> -->
        <!--客户端超时时间单位是毫秒 -->
        <property name="timeout" value="${redis.timeout}"></property>
    </bean>

    <!-- redis操作模板,这里采用尽量面向对象的模板 -->
    <bean id="redisTemplate" class="org.springframework.data.redis.core.RedisTemplate">
        <property name="connectionFactory" ref="jedisConnectionFactory" />
        <!-- 指定redis中key-value的序列化方式(此处省略) -->
    </bean>

    <!--redis工具类 (也可以通过注解的方式注入) -->
    <bean id="redisUtil" class="com.spring.redis.utils.RedisUtil">
        <property name="redisTemplate" ref="redisTemplate" />
    </bean>

RedisUtils工具类

代码片段:

package com.spring.redis.util;

import java.util.List;
import java.util.Map;
import java.util.Set;
import java.util.concurrent.TimeUnit;

import org.apache.commons.lang3.StringUtils;
import org.springframework.data.redis.core.RedisTemplate;
import org.springframework.util.CollectionUtils;

/** 
 * 
 * @项目名称:common
 * @类名称:RedisUtil
 * @类描述:基于spring和redis的redisTemplate工具类;
 * @创建人:wyait
 * @创建时间:2017年12月8日 下午3:32:38 
 * @version:V1.0
 */
// @Component
public class RedisUtil {
    // 通过构造方法注入
    // @Autowired
    private RedisTemplate<String, Object> redisTemplate;

    /*
     * 如果使用注解注入RedisTemplate对象,则不需要该setter方法
     */
    public void setRedisTemplate(RedisTemplate<String, Object> redisTemplate) {
        this.redisTemplate = redisTemplate;
    }

    /** 
     * String类型缓存获取 
     * @param key 键 
     * @return 值 
     */
    public Object get(String key) {
        return key == null ? null : redisTemplate.opsForValue().get(key);
    }

    /** 
     * String类型缓存保存 
     * @param key 键 
     * @param value 值 
     * @return true:成功;false:失败 
     */
    public boolean set(String key, Object value) {
        try {
            if (StringUtils.isNotEmpty(key) && null != value) {
                redisTemplate.opsForValue().set(key, value);
                return true;
            }
        } catch (Exception e) {
            e.printStackTrace();
        }
        return false;
    }

   // ... ...

}

测试

  • 访问:http://127.0.0.1:8063/add 
    结果:hello world 
    查看redis桌面工具,已有数据,虽然看不懂。。。如图: 
    image 
    乱码的原因是:RedisTemplate默认的使用org.springframework.data.redis.serializer.JdkSerializationRedisSerializer这个类进行序列化导致的,如果单独指定了redis的key-value序列化方式,就不会出现乱码的情况。 (源码中已解决乱码问题)

访问:http://127.0.0.1:8063/get 
结果:aaa

Caused by: redis.clients.jedis.exceptions.JedisDataException: WRONGTYPE Operation against a key holding the wrong kind of value
    at redis.clients.jedis.Protocol.processError(Protocol.java:127)

因为redis数据库中已经存在了相同的key, 而且key对应的值类型并不是HashMap或Object;再调用setHash时,就会抛出此错误。

解决:更改key的值;

访问:http://127.0.0.1:8063/getHash 
结果:{"user":{"id":1,"age":11,"name":"李四"}}

使用redis API做缓存管理

这里用RedisUtils工具类实现数据缓存; 
使用缓存注解,请参考:《spring boot 整合redis之缓存》之redis缓存管理;

项目中使用redis

项目中查询业务做缓存,必须在不影响正常业务的情况下,对数据进行缓存;具体做法:

  • 1,查mysql数据库和redis缓存结合使用; 
    查询业务:先查询redis缓存,有就返回数据;没有,直接查询mysql数据库; 
    代码片段:
// 从redis中缓存中获取详情数据
String redisString = "";
try {
    //避免redis异常影响到正常业务
    redisString=this.redisUtil.get("aaa:bbb");
} catch (Exception e) {
    //TODO
    LOGGER.error("redis get error");
}
if (StringUtils.isEmpty(redisString)) {
    //查询数据库
    //TODO
}

更新业务:先更新mysql数据库中的数据,更新成功;更新redis缓存中的数据;比如:添加数据,先添加到mysql中;在添加一条数据在redis中; 
代码片段:

//TODO
//更新数据OK
try {
    //避免redis异常影响到正常业务
    //更新redis中数据,并指定保存时间
    redisString=this.redisUtil.set("aaa:bbb","值",3600);
} catch (Exception e) {
    //TODO
    LOGGER.error("redis set error");
}
  • 2,对于redis操作,进行try...catch...处理;保证应用程序的可用性,如上面两段代码;

redis中key使用策略

Redis上踩过的一些坑-美团:http://blog.csdn.net/chenleixing/article/details/50530419 
redis内存使用优化:http://carlosfu.iteye.com/blog/2254572

(1) 使用Redis字符串数据结构, userId为key, weiboCount作为Value 
(2) 使用Redis哈希结构,hashkey只有一个, key="allUserWeiboCount",field=userId,fieldValue= weiboCount 
(3) 使用Redis哈希结构, hashkey为多个, key=userId/100, field=userId%100, fieldValue= weiboCount 
前两种比较容易理解,第三种方案解释一下:每个hashKey存放100个hash-kv,field=userId%100。。。

实际使用根据具体的业务而定,数据量没那么大的情况下,不用考虑内存优化的问题;

另外在使用String类型的key的时候,推荐用:

aaa:bbb

这种格式,这样在redis桌面工具中查看方便直观,针对key中有:的情况,redis桌面工具会对其进行统一分类,方便查看! 
image

注意

spring data redis会有版本冲突问题,导致启动异常;

异常情况:

aused by: java.lang.NoSuchMethodError: org.springframework.core.serializer.support.DeserializingConverter.<init>(Ljava/lang/ClassLoader;)V
    at org.springframework.data.redis.serializer.JdkSerializationRedisSerializer.<init>(JdkSerializationRedisSerializer.java:53)
  • 原因: 
    spring-data-redis版本:1.7.2.RELEASE ,不兼容spring 版本:4.1.3.RELEASE
  • 解决方案: 
    spring data redis版本不能高于:1.7.1.RELEASE

稳定版本:

spring版本:4.2.3.RELEASE - 4.3.9.RELEASE 
spring-data-redis版本:1.7.2.RELEASE - 1.7.11.RELEASE
jedis版本:2.9.0



本文转自 wyait 51CTO博客,原文链接:http://blog.51cto.com/wyait/2049866,如需转载请自行联系原作者

相关实践学习
基于Redis实现在线游戏积分排行榜
本场景将介绍如何基于Redis数据库实现在线游戏中的游戏玩家积分排行榜功能。
云数据库 Redis 版使用教程
云数据库Redis版是兼容Redis协议标准的、提供持久化的内存数据库服务,基于高可靠双机热备架构及可无缝扩展的集群架构,满足高读写性能场景及容量需弹性变配的业务需求。 产品详情:https://www.aliyun.com/product/kvstore &nbsp; &nbsp; ------------------------------------------------------------------------- 阿里云数据库体验:数据库上云实战 开发者云会免费提供一台带自建MySQL的源数据库&nbsp;ECS 实例和一台目标数据库&nbsp;RDS实例。跟着指引,您可以一步步实现将ECS自建数据库迁移到目标数据库RDS。 点击下方链接,领取免费ECS&amp;RDS资源,30分钟完成数据库上云实战!https://developer.aliyun.com/adc/scenario/51eefbd1894e42f6bb9acacadd3f9121?spm=a2c6h.13788135.J_3257954370.9.4ba85f24utseFl
相关文章
|
15天前
|
缓存 NoSQL Java
Redis Spring配置集群
【7月更文挑战第5天】
45 10
|
25天前
|
NoSQL Java 应用服务中间件
蓝易云 - Spring redis使用报错Read timed out排查解决
以上都是可能的解决方案,具体的解决方案可能会因具体情况而异。
19 1
|
27天前
|
NoSQL Java 应用服务中间件
蓝易云 - Spring redis使用报错Read timed out排查解决
以上都是可能的解决方案,具体的解决方案可能会因具体情况而异。
15 2
|
21天前
|
缓存 NoSQL Java
Spring Boot整合Redis缓存的最佳实践
Spring Boot整合Redis缓存的最佳实践
|
24天前
|
缓存 NoSQL Java
Spring Boot与Redis的缓存一致性问题
Spring Boot与Redis的缓存一致性问题
|
24天前
|
消息中间件 NoSQL Java
Spring Boot中使用Redis和Lua脚本实现延时队列
Spring Boot中使用Redis和Lua脚本实现延时队列
|
1月前
|
NoSQL Java Redis
Spring Boot2 系列教程(二十六)Spring Boot 整合 Redis
Spring Boot2 系列教程(二十六)Spring Boot 整合 Redis
|
存储 缓存 NoSQL
Redis 缓存 + Spring 的集成示例
SpringSession和Redis实现Session跨域 http://www.ithao123.cn/content-11111681.html   tomcat中创建session很耗服务器内存 原生session与session in redis对比下面是从stackoverflo...
1364 0
|
存储 缓存 NoSQL
Redis 缓存 + Spring 的集成示例(转)
《整合 spring 4(包括mvc、context、orm) + mybatis 3 示例》一文简要介绍了最新版本的 Spring MVC、IOC、MyBatis ORM 三者的整合以及声明式事务处理。
1429 0