spring boot redis 整合

摘要: spring boot redis

又很久没有更新博客了，今天再写一点吧.spring boot 使用越来越多，redis 也是很普及的cache, 现在用把两者做一下整合.

环境：　spring boot 1.4.2,redis3.0.1, maven 3.3.9, jdk1.8, IDEA2016.3.3

redis布署环境可以参考： redis 安装配置

maven 布署环境可以参考: Maven 构建web工程

spring boot 部署环境可以参考:spring boot first

IDEA 部署环境 ，我的博客里暂时没有参考.

step 1: 配置 pom.xml

<modelVersion>4.0.0</modelVersion>
<groupId>spring-boottest</groupId>
<artifactId>spring-boottest</artifactId>
<version>1.0-SNAPSHOT</version>
<!--父依赖-->
<parent>
<groupId>org.springframework.boot</groupId>
<artifactId>spring-boot-starter-parent</artifactId>
<version>1.4.2.RELEASE</version>
</parent>

<dependency>
<groupId>org.springframework.boot</groupId>
<artifactId>spring-boot-starter-web</artifactId>

</dependency>

<dependency>
<groupId>org.springframework.boot</groupId>
<artifactId>spring-boot-starter-velocity</artifactId>
</dependency>

<dependency>
<groupId>org.springframework.data</groupId>
<artifactId>spring-data-redis</artifactId>
<version>1.7.0.RELEASE</version>
<exclusions>
<exclusion>
<groupId>org.slf4j</groupId>
<artifactId>slf4j-log4j12</artifactId>
</exclusion>
<exclusion>
<groupId>log4j</groupId>
<artifactId>log4j</artifactId>
</exclusion>
</exclusions>
</dependency>

<dependency>
<groupId>org.springframework.boot</groupId>
<artifactId>spring-boot-starter-redis</artifactId>
</dependency>

倒数第三个依赖，可以看出模板用的velocity,exclusions 因为我的项目里其它的依赖已经用到slf4j，会提示重复的引用，所以这里去掉。最后2个依赖是redis需要用到的，这个项目的核心.

setp2:

application.properties 配置

# 服务端口
server.port=8081

spring.velocity.resource-loader-path=classpath:/templates/

# REDIS (RedisProperties)

spring.redis.host=127.0.0.1

spring.redis.port=7001

spring.redis.pool.max-idle=8
spring.redis.pool.min-idle=0
spring.redis.pool.max-active=8
spring.redis.pool.max-wait=-1

没有用默认的端口，用的是7001。

step3 : 建立操作redis的service

@Service
public class DemoService {

@Cacheable(value = "user",key = "'user_'+#user.getId()")
public User findUserCache(User  user){
System.out.println("findUserCache");

return user;
}

@CachePut(value = "user",key = "'user_'+#user.getId()")
public User editUserCache(User  user){
System.out.println("editUserCache");

return user;
}

@CacheEvict(value = "user",key = "'user_'+#user.getId()")
public User deleteUserCache(User  user){
System.out.println("deleteUserCache");

return user;
}
}

查询时使用：@Cacheable

插入数据使用：@CachePut

删除、更新时使用：@CacheEvict

step 4:

建controller

加入查询,更新,删除页面接口，代码如下：

@RequestMapping("/findUser")
//    @ResponseBody
public String findUserCache( @RequestParam(value="userId",required = false) long userId,Map<String, Object> model){
User user=new User();
user.setId((long)userId);
User user1=  demoService.findUserCache(user);
System.out.println("缓存的数据(如果有Id和名字,是读的缓存,如果没有名字是新建的缓存)");
System.out.println("user:"+"/"+user1.getFirstName()+"/"+user1.getLastName());

Map<String,String> paramValues=new HashMap<String, String>();
paramValues.put("id",String.valueOf(user1.getId()));
paramValues.put("firstName",user1.getFirstName());
paramValues.put("lastName",user1.getLastName());
model.put("paramValues", paramValues);
return  "redisList";
// return  "userId:"+user1.getId().toString()+",userFirstName:"+user1.getFirstName()+",userLastName:"+user1.getLastName();
}

@RequestMapping("/editUser")
@ResponseBody
public String editUserCache( @RequestParam(value="userId",required = false) long userId,
@RequestParam(value="firstName",required = false) String firstName,
@RequestParam(value="lastName",required = false) String lastName
){
User user=new User();
user.setId((long)userId);
user.setFirstName(firstName);
user.setLastName(lastName);
User user1=  demoService.editUserCache(user);
return  "userId:"+user1.getId().toString()+",userFirstName:"+user1.getFirstName()+",userLastName:"+user1.getLastName();
}

@RequestMapping("/deleteUser")
@ResponseBody
public String editUserCache( @RequestParam(value="userId",required = false) long userId){
User user=new User();
user.setId((long)userId);
User user1=  demoService.deleteUserCache(user);
return  "userId:"+user1.getId().toString()+",userFirstName:"+user1.getFirstName()+",userLastName:"+user1.getLastName();
}
}

step5 :

为查询controller建 显示结果页面src/main/resource/templates/redisList.vm,内容：

#foreach($param in ${paramValues.keySet()})
<tr>
<th>$param:</th>
<td>${paramValues.get($param)}</td>
<br>
</tr>
#end

step6 :

启动redis :start redis-server ./7001/redis.conf



打开redis client

redis-cli -h 127.0.0.1 -p 7001

step7:

run 工程

查看结果:

看一下reids 里user_1 里的数据

get user_1



1. 查询



findUser是查询的接口，查询出redis的数据

2. 更新



查看redis



数据被更新

3.删除



查看redis



补充：@Cacheable 查询时，在没有数据时，会自动创建一条记录.