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 查询时，在没有数据时，会自动建立一条记录.