1. 首页
  2. 文章中心
  3. Redis

10、Spring技术栈-整合Redis，使用RedisTemplate实现数据缓存实战

81 阅读 0 评论
我是靠谱客的博主 潇洒小松鼠，这篇文章主要介绍10、Spring技术栈-整合Redis，使用RedisTemplate实现数据缓存实战，现在分享给大家，希望可以做个参考。

关于Redis的介绍，我们不做过多讲解，有兴趣可直接参考Redis官方网站（百度一下，你就知道）。

1、整合准备工作

在本机安装Redis，windows版本Redis下载链接：https://github.com/MSOpenTech/redis，下载之后按照一般安装方式默认安装就可以了，安装完之后启动Redis。

  1. 示例所使用spring-data-redis版本：1.7.5.RELEASE
  2. redis-clients版本：2.9.0
  3. zkclient版本：0.10
  4. dubbo版本：2.8.4

本文是即（Spring技术栈-整合dubbo、zookeeper）之后的一个实际应用场景，也是采用分布式的方式进行开发实现，如果对dubbo或者zookeeper不熟悉，可先阅读上文了解。

2、示例场景介绍

我们通过一个实例来介绍如何整合Redis并使用RedisTemplate实现数据缓存。我们有这样一个需求，在博客系统中，用户发表一篇博客，我们需要将博客存到MySQL的同时保存一份到Redis中，读取博客内容时先从Redis里查询，如果Redis中已经缓存，则从缓存直接读取，否则从数据库读取并缓存到Redis中，下次读取则直接从缓存读取。

发布博客流程如下图所示：

这里写图片描述

查看博客流程如下图所示：

这里写图片描述

3、在博客服务项目中添加依赖

复制代码
1
2
3
4
5
6
7
8
9
10
<dependency>
<groupId>redis.clients</groupId>
<artifactId>jedis</artifactId>
<version>${redis_clients_version}</version>
</dependency>
<dependency>
<groupId>org.springframework.data</groupId>
<artifactId>spring-data-redis</artifactId>
<version>${spring_data_redis_version}</version>
</dependency>

注意：redis_clients_version为2.9.0，spring_data_redis_version版本为1.7.5.RELEASE

4、在resources目录添加spring-context-redis.xml，并写入如下内容

复制代码
1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27
28
29
30
31
32
33
34
35
36
37
38
39
40
41
42
43
44
45
46
47
48
49
50
51
52
53
54
55
56
57
<?xml version="1.0" encoding="UTF-8"?>
<beans xmlns="http://www.springframework.org/schema/beans"
xmlns:xsi="http://www.w3.org/2001/XMLSchema-instance" xmlns:context="http://www.springframework.org/schema/context"
xmlns:jdbc="http://www.springframework.org/schema/jdbc" xmlns:jee="http://www.springframework.org/schema/jee"
xmlns:tx="http://www.springframework.org/schema/tx" xmlns:util="http://www.springframework.org/schema/util"
xmlns:task="http://www.springframework.org/schema/task" xmlns:cache="http://www.springframework.org/schema/cache"
xmlns:c='http://www.springframework.org/schema/c' xmlns:p="http://www.springframework.org/schema/p"
xsi:schemaLocation="
http://www.springframework.org/schema/beans http://www.springframework.org/schema/beans/spring-beans-4.0.xsd
http://www.springframework.org/schema/context http://www.springframework.org/schema/context/spring-context-4.0.xsd
http://www.springframework.org/schema/jdbc http://www.springframework.org/schema/jdbc/spring-jdbc-4.0.xsd
http://www.springframework.org/schema/jee http://www.springframework.org/schema/jee/spring-jee-4.0.xsd
http://www.springframework.org/schema/tx http://www.springframework.org/schema/tx/spring-tx-4.0.xsd
http://www.springframework.org/schema/util http://www.springframework.org/schema/util/spring-util-4.0.xsd
http://www.springframework.org/schema/task http://www.springframework.org/schema/task/spring-task-4.0.xsd
http://www.springframework.org/schema/cache http://www.springframework.org/schema/cache/spring-cache-3.1.xsd"
default-lazy-init="true">
<!-- 开启spring cache注解功能 -->
<cache:annotation-driven cache-manager="redisCacheManager" />
<context:annotation-config />
<context:property-placeholder

ignore-unresolvable="true" location="classpath:config.properties" />
<!-- Redis -->
<bean id="poolConfig" class="redis.clients.jedis.JedisPoolConfig" >
<property name="maxTotal" value="${redis.maxTotal}"/>
<property name="maxIdle" value="${redis.maxIdle}" />
<property name="maxWaitMillis" value="${redis.maxWait}" />
<property name="testOnBorrow" value="${redis.testOnBorrow}" />
</bean>
<!-- redis服务器中心 -->
<bean id="jedisConnectionFactory"
class="org.springframework.data.redis.connection.jedis.JedisConnectionFactory" >
<property name="poolConfig" ref="poolConfig" />
<property name="port" value="${redis.port}" />
<property name="hostName" value="${redis.host}" />
<property name="timeout" value="${redis.timeout}" ></property>
</bean>
<bean id="redisTemplate" class="org.springframework.data.redis.core.RedisTemplate">
<property name="connectionFactory" ref="jedisConnectionFactory" />
<property name="keySerializer">
<bean

class="org.springframework.data.redis.serializer.StringRedisSerializer" />
</property>
<property name="valueSerializer">
<bean

class="org.springframework.data.redis.serializer.JdkSerializationRedisSerializer" />
</property>
</bean>
<!-- redis缓存管理器 -->
<bean id="redisCacheManager" class="org.springframework.data.redis.cache.RedisCacheManager">
<constructor-arg name="redisOperations" ref="redisTemplate" />
</bean>
<bean id="redisUtils" class="ron.blog.blog_service.utils.RedisUtils" />
</beans>

5、在spring-context.xml中引入spring-context-redis.xml文件
spring-context.xml中添加如下内容：

复制代码
1
<import resource="classpath:spring-context-redis.xml" />

6、在resources目录添加config.properties，并写入如下内容

复制代码
1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
#Redis信息配置
#绑定的主机地址

redis.host=127.0.0.1
#Redis监听端口，默认端口为6379

redis.port=6379
#授权密码（本例子没有使用）

redis.password=123456
#最大空闲数：空闲链接数大于maxIdle时，将进行回收

redis.maxIdle=100
#最大连接数：能够同时建立的“最大链接个数”

redis.maxTotal=300
#最大等待时间：单位ms

redis.maxWait=1000
#使用连接时，检测连接是否成功

redis.testOnBorrow=true
#当客户端闲置多长时间后关闭连接，如果指定为0，表示关闭该功能

redis.timeout=10000
redis.usePool=true

7、实现RedisUtils工具类

由于我们使用RedisTemplate来实现数据的写入、删除、读取等操作，但是如果在每个需要用到RedisTemplate的地方都是用RedisTemplate对象的话，相对比较麻烦，会重复写很多代码，所以我们自己封装一个RedisUtils工具类来实现数据的写入、读取等操作。具体实现如下：

复制代码
1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27
28
29
30
31
32
33
34
35
36
37
38
39
40
41
42
43
44
45
46
47
48
49
50
51
52
53
54
55
56
57
58
59
60
61
62
63
64
65
66
67
68
69
70
71
72
73
74
75
76
77
78
79
80
81
82
83
84
85
86
87
88
89
90
91
92
93
94
95
96
97
98
99
100
101
102
103
104
105
106
107
108
109
110
111
112
113
114
115
116
117
118
119
120
121
122
123
124
125
public class RedisUtils {
/**
* RedisTemplate是一个简化Redis数据访问的一个帮助类，
* 此类对Redis命令进行高级封装，通过此类可以调用ValueOperations和ListOperations等等方法。
*/
@Autowired
private RedisTemplate<Serializable, Object> redisTemplate;
/**
* 批量删除对应的value
*
* @param keys
*/
public void remove(final String... keys) {
for (String key : keys) {
remove(key);
}
}
/**
* 批量删除key
*
* @param pattern
*/
public void removePattern(final String pattern) {
Set<Serializable> keys = redisTemplate.keys(pattern);
if (keys.size() > 0)
redisTemplate.delete(keys);
}
/**
* 删除对应的value
* @param key
*/
public void remove(final String key) {
if (exists(key)) {
redisTemplate.delete(key);
}
}
/**
* 缓存是否存在
* @param key
* @return
*/
public boolean exists(final String key) {
return redisTemplate.hasKey(key);
}
/**
* 读取缓存
* @param key
* @return
*/
public Object get(final String key) {
Object result = null;
ValueOperations<Serializable, Object> operations = redisTemplate.opsForValue();
result = operations.get(key);
return result;
}
/**
*
* @Author Ron
* @param key
* @param hashKey
* @return
*/
public Object get(final String key, final String hashKey){
Object result = null;
HashOperations<Serializable,Object,Object> operations = redisTemplate.opsForHash();
result = operations.get(key, hashKey);
return result;
}
/**
* 写入缓存
*
* @param key
* @param value
* @return
*/
public boolean set(final String key, Object value) {
boolean result = false;
try {
ValueOperations<Serializable, Object> operations = redisTemplate.opsForValue();
operations.set(key, value);
result = true;
} catch (Exception e) {
e.printStackTrace();
}
return result;
}
/**
*
* @Author Ron
* @param key
* @param hashKey
* @param value
* @return
*/
public boolean set(final String key, final String hashKey, Object value) {
boolean result = false;
try {
HashOperations<Serializable,Object,Object> operations = redisTemplate.opsForHash();
operations.put(key, hashKey, value);
result = true;
} catch (Exception e) {
e.printStackTrace();
}
return result;
}
/**
* 写入缓存
*
* @param key
* @param value
* @return
*/
public boolean set(final String key, Object value, Long expireTime) {
boolean result = false;
try {
ValueOperations<Serializable, Object> operations = redisTemplate.opsForValue();
operations.set(key, value);
redisTemplate.expire(key, expireTime, TimeUnit.SECONDS);
result = true;
} catch (Exception e) {
e.printStackTrace();
}
return result;
}
}

项目源码：http://download.csdn.net/download/zyhlwzy/10108090

注意：数据脚本在源码文件的blog/database下；

由于系统所使用的dubbo版本是2.8.4，但是此版本的dubbo官方并没有更新到Maven仓库，所以必须下载dubbo源码编译并上传到自己的私有库，示例源码的私服地址为http://192.168.199.252:8081/nexus/content/groups/public/，读者需要自己建私服，自行编译，具体操作方法读者自行百度，方法很多。

相似文章： Spring整合Redis实现数据缓存

最后

以上就是潇洒小松鼠最近收集整理的关于10、Spring技术栈-整合Redis，使用RedisTemplate实现数据缓存实战的全部内容，更多相关10、Spring技术栈-整合Redis内容请搜索靠谱客的其他文章。

本图文内容来源于网友提供，作为学习参考使用，或来自网络收集整理，版权属于原作者所有。
点赞(54)

相关文章

在一台机器上搭多个redis实例
在一台机器上搭多个redis实例
RedisTemplate的使用
RedisTemplate的使用
SpringBoot+RedisTemplate多数据源
SpringBoot+RedisTemplate多数据源
spring boot 之 redis多数据源一、依赖引入二、application配置文件三、Java配置四、使用示例
spring boot 之 redis多数据源一、依赖引入二、application配置文件三、Java配置四、使用示例
10、Spring技术栈-整合Redis，使用RedisTemplate实现数据缓存实战
10、Spring技术栈-整合Redis，使用RedisTemplate实现数据缓存实战
.NET平台下Redis使用(七)【StackExchange.Redis测试Redis五种数据类型】信念之于人，犹翅膀之于鸟，信念是飞翔的翅膀Program.cs代码:RedisDemo.cs代码:RedisHelper.cs代码:UserInfoDto.cs代码:运行结果如图:
.NET平台下Redis使用(七)【StackExchange.Redis测试Redis五种数据类型】信念之于人，犹翅膀之于鸟，信念是飞翔的翅膀Program.cs代码:RedisDemo.cs代码:RedisHelper.cs代码:UserInfoDto.cs代码:运行结果如图:
springboot访问多个redis库
springboot访问多个redis库
Redise篇-记一次Redise的封装（基础篇）
Redise篇-记一次Redise的封装（基础篇）

评论列表共有 0 条评论

立即
投稿
返回
顶部