spring boot 1.5.9 整合redis

redis概述

Redis可以存储键与5种不同数据结构类型之间的映射，这5种数据结构类型分别为 
STRING（字符串）、LIST（列表）、SET（集合）、HASH（散列）和ZSET（有序集合）。 
有一部分Redis命令对于这5种结构都是通用的，如DEL、TYPE、RENAME等；但也有一部分Redis命令只能对特定的一种或者两种结构使用；

一些数据库和缓存服务器的特性与功能

---

==表格样式不是我能决定的，凑合看吧==

Redis提供的5种结构

---

redis特性

---

源码简单 ，约23000行C语言源代码。

1. 速度快 
   Redis是用C语言实现的；Redis的所有数据存储在内存中，用于快速地读写访问。
2. 持久化 
   Redis的所有数据存储在内存中，对数据的更新将异步地保存到磁盘上； 
   redis的持久化有两种方式：AOF与RDB两种模式
3. 支持多种数据结构 
   Redis支持五种数据结构：String、List、Set、Hash、Zset
4. 支持多种编程语言 
   Java、php、Python、Ruby、Lua、Node.js等
5. 功能丰富 
   除了支持五种数据结构之外，还支持缓存、事务、流水线、发布/订阅、消息队列等功能。 
   发布/订阅模型： Redis支持创建发布和订阅通道，这样Redis客户端可以订阅任意的通道来进行数据消费，并且任何已订阅该通道的客户端可以发布数据。
6. 主从复制 
   主服务器（master）执行写入（增删改），从（slave）服务器执行查询。复制提供可伸缩性和可用性。任何一个slave宕机，其他的slave还可以提供数据访问。
7. 虚拟内存 
   Redis使用RAM作为内存式存储。但是，在内存不足的情况下，它使用虚拟内存来保存数据。
8. 高可用及分布式 
   Redis-Sentinel（v2.8）支持高可用
   Redis-Cluster（v3.0）支持分布式

redis部分命令

flushdb：清空当前数据库； 
select [index]：选择索引数据库，index为索引值名，如：select 1； 
del [key]：删除一条指定key的值； 
keys *：查看数据库内所有的key； 
flushall：清空所有数据库； 
quit：退出客户端连接。 
==友情提示：部分命令慎用，线上一定不能用==

redis安装

redis下载安装

1. windows版本下载：https://github.com/MicrosoftArchive/redis/releases ，目前是redis-3.2.100版本。 
   
2. 解压下载的zip压缩包： 
    
   Redis on Windows.docx:关于Redis的描述文档
   redis.windeows.conf：默认的配置文件
   RedisService.docx：安装手册
   redis-server.exe：redis服务启动执行文件
   redis-cli.exe：redis客户端启动执行文件
3. 注册redis服务到本机系统中 
   在当前redis解压文件目录下...\Redis-x64-3.2.100\，本机系统中注册服务：

redis-server --service-install redis.windows.conf --loglevel verbose 
卸载服务： 
redis-server --service-uninstall 
启动Redis： 
redis-server.exe 
指定配置文件启动，适用于多个redis数据库的时候 
redis-server.exe redis.windows.conf

停止Redis: 
redis-server --service-stop

安装成功： 
 
启动redis: 

1. redis客户端测试
   • 双击redis客户端执行文件：redis-cli.exe
   • 测试：ping 
     

redis桌面可视化工具

• Redis可视化工具，RedisDesktopManager 
  它是开源的，托管在github上：https://github.com/uglide/RedisDesktopManager 
   
  下载地址：https://redisdesktop.com/download
• 安装：双击默认安装
• 连接测试：
  

redis Java客户端

redis支持的语言，可在官网查看！重点看下redis的java客户端jedis:

github地址：https://github.com/xetorthio/jedis

spring boot 整合redis

spring boot整合redis有两种方式： 
其一：使用外部配置，通过jedis技术框架实现； 
其二：通过spring boot提供的数据访问框架Spring Data Redis实现，它是基于Jedis的。

第一种方式，可以参考SSM框架整合jedis进行操作配置；重点是第二种实现方式！

spring data redis

通过spring boot中的redis自动配置类，关于redis自动配置类RedisAutoConfiguration.java

//排除redis自动配置注解
@EnableAutoConfiguration(exclude = RedisAutoConfiguration.class)

查看其源码： 

spring boot在Spring Data Redis提供了两个模板：

• RedisTemplate
• StringRedisTemplate

RedisTemplate会使用JdkSerializationRedisSerializer处理数据，这意味着key和value都会通过Java进行序列化。 
StringRedisTemplate默认会使用StringRedisSerializer处理数据。

要是操作字符串的话，用StringRedisTemplate就可以满足。但要是想要存储一个对象Object,我们就需要使用RedisTemplate，并对key采用String序列化方式，对value采用json序列化方式，这时候就需要对redisTemplate自定义配置，项目源码片段：

/**
     * 实例化 RedisTemplate 对象
     *
     * @return RedisTemplate
     */
    @Bean
    public RedisTemplate<String, Object> functionDomainRedisTemplate() {
        RedisTemplate<String, Object> redisTemplate = new RedisTemplate<>();
        redisTemplate.setConnectionFactory(redisConnectionFactory);
        initDomainRedisTemplate(redisTemplate);
        redisTemplate.afterPropertiesSet();
        return redisTemplate;
    }
 
    /**
     * 设置数据存入 redis 的序列化方式
         * </br>redisTemplate 序列化默认使用的jdkSerializeable, 存储二进制字节码, 导致key会出现乱码，所以自定义
         * 序列化类
     *
     * @param redisTemplate
     * @param factory
     */
    private void initDomainRedisTemplate(RedisTemplate<String, Object> redisTemplate) {
        // 使用Jackson2JsonRedisSerialize 替换默认序列化
        Jackson2JsonRedisSerializer jackson2JsonRedisSerializer = new Jackson2JsonRedisSerializer(Object.class);
        ObjectMapper om = new ObjectMapper();
        om.setVisibility(PropertyAccessor.ALL, JsonAutoDetect.Visibility.ANY);
        om.enableDefaultTyping(ObjectMapper.DefaultTyping.NON_FINAL);
        jackson2JsonRedisSerializer.setObjectMapper(om);
         string结构的数据，设置value的序列化规则和 key的序列化规则
        //StringRedisSerializer解决key中乱码问题。//Long类型不可以会出现异常信息;
        redisTemplate.setKeySerializer(new StringRedisSerializer());
        //value乱码问题：Jackson2JsonRedisSerializer
        redisTemplate.setValueSerializer(jackson2JsonRedisSerializer);
 
        //设置Hash结构的key和value的序列化方式
        //redisTemplate.setHashKeySerializer(jackson2JsonRedisSerializer);
        //redisTemplate.setHashValueSerializer(jackson2JsonRedisSerializer);
    }

RedisTempalte类API

spring boot缓存管理

spring boot集成redis进行数据缓存功能；有两种实现： 
1，通过在代码中调用redis API实现数据的CRUD； 
【参考RedisUtils工具类,该工具类支持redis的其他业务场景】 
2，通过在方法上添加缓存注解实现； 
【重点介绍，只支持redis作为缓存管理时使用】

Spring 提供了很多缓存管理器，例如：

• SimpleCacheManager
• EhCacheCacheManager
• CaffeineCacheManager
• GuavaCacheManager
• CompositeCacheManager
• RedisCacheManager Spring Data提供的缓存管理器：RedisCacheManager

在Spring Boot中通过@EnableCaching注解自动化配置合适的缓存管理器（CacheManager），默认情况下Spring Boot根据下面的顺序自动检测缓存提供者：

• Generic
• JCache (JSR-107)
• EhCache 2.x
• Hazelcast
• Infinispan
• Redis
• Guava
• Simple

因为之前已经配置了RedisTemplate了，Spring Boot就无法自动给RedisCacheManager设置RedisTemplate了，所以要自己配置CacheManager。

---

1， 修改RedisConfig配置类，添加@EnableCaching注解，并继承CachingConfigurerSupport，重写CacheManager 方法：

/**
 * 实例化 CacheManager 对象，指定使用RedisCacheManager作缓存管理
 *
 * @return CacheManager
 */
@Bean
public CacheManager cacheManager(RedisTemplate redisTemplate) {
    RedisCacheManager rcm = new RedisCacheManager(redisTemplate);
    // 设置缓存过期时间（单位:秒），60秒
    rcm.setDefaultExpiration(120);
    return rcm;
}

Spring提供了如下注解来声明缓存规则：

• @Cacheable triggers cache population
• @cacheevict triggers cache eviction
• @cacheput updates the cache without interfering with the method execution
• @caching regroups multiple cache operations to be applied on a method
• @cacheconfig shares some common cache-related settings at class-level

@Cacheable和@cacheput有一些共有的属性：

---

2， 通过注解@Cacheable，对数据进行缓存处理：
代码片段：

/**
     * 通过缓存注解，添加数据到redis中
     * </br>实现数据缓存！
     * @param cat 对象
     */
    @Cacheable
    @RequestMapping(value = "/getCat/{catId}", method = RequestMethod.GET)
    @ResponseBody
    public Cat add(@PathVariable("catId") int catId){
        return this.catService.getCat(catId);
    }

注意：Cat对象必须实现implements Serializable接口！ 
启动访问：http://127.0.0.1:8066/redis/getCat/1

java.lang.IllegalStateException: No cache could be resolved for 'Builder[public com.wyait.redis.pojo.Cat com.wyait.redis.controller.RedisCacheController.add(int)] caches=[] | key='' | keyGenerator='' | cacheManager='' | cacheResolver='' | condition='' | unless='' | sync='false'' using resolver 'org.springframework.cache.interceptor.SimpleCacheResolver@5e67a11d'. At least one cache should be provided per cache operation.
    at org.springframework.cache.interceptor.CacheAspectSupport.getCaches(CacheAspectSupport.java:244) ~[spring-context-4.3.13.RELEASE.jar:4.3.13.RELEASE]

这个错误，是由于@Cacheable注解没有指定缓存名称导致的。加上value值，再试：

@Cacheable(value = "catCache")

测试访问成功！多次访问，走redis缓存。

---

3， redis缓存key生成策略

键的生成策略有两种，一种是默认策略，一种是自定义策略。

• ----------------------------默认策略：

  If no params are given, return SimpleKey.EMPTY.
  If only one param is given, return that instance.
  If more the one param is given, return a SimpleKey containing all parameters.
  

  默认的key是通过KeyGenerator生成的，其默认策略如下： 
  1.如果方法没有参数，则使用0作为key; 
  2.如果只有一个参数的话则使用该参数作为key; 
  3.如果参数多于一个则使用所有参数的hashcode作为key;

• ----------------------------自定义策略： 
  自定义策略是指我们通过Spring的EL表达式来指定我们的key。这里的EL表达式可以使用参数以及它们对应的属性。使用方法参数时我们可以直接使用“#参数名”或者“#p参数index”。

之前在redisTemplate里设置了template.setKeySerializer(new StringRedisSerializer()),需要key是string类型。也可以使用SpEL表达式生成Key， 
（SpEL表达式：http://itmyhome.com/spring/expressions.html） 
返回结果需要是string类型（比如#root.methodName就是，#root.method不是String），通用办法是重写keyGenerator定制Key默认生成策略（按照缓存名称+id方式生成key,同时确保更新操作的时候，操作的是同一条数据），也可以在使用缓存注解时指定key:

/**
     * 指定key的生成策略
     * @return KeyGenerator
     */
    @Bean public KeyGenerator keyGenerator() {
        return new KeyGenerator() {
            @Override public Object generate(Object target, Method method,
                    Object... params) {
                StringBuilder sb = new StringBuilder();
                String[] value = new String[1];
                // sb.append(target.getClass().getName());
                // sb.append(":" + method.getName());
                Cacheable cacheable = method.getAnnotation(Cacheable.class);
                if (cacheable != null) {
                    value = cacheable.value();
                }
                CachePut cachePut = method.getAnnotation(CachePut.class);
                if (cachePut != null) {
                    value = cachePut.value();
                }
                CacheEvict cacheEvict = method.getAnnotation(CacheEvict.class);
                if (cacheEvict != null) {
                    value = cacheEvict.value();
                }
                sb.append(value[0]);
                //获取参数值
                for (Object obj : params) {
                    sb.append(":" + obj.toString());
                }
                return sb.toString();
            }
        };
    }

注意： 
1，在使用缓存注解时，也可以指定统一规则的key 
（比如：@Cacheable(value = "catCache", key = "#root.caches[0].name + ':' + #id")）； 
就可以不走KeyGenerator默认规则；同样可以实现，更新和查询都是同一个key的数据； 
2，使用注解进行数据缓存，指定数据过期时间需要百度普及下！

---

4， 更新缓存数据

更新与删除Redis缓存需要用到@cacheput和@cacheevict。必须保证keyGenerator生成同一个key,否则更新的不是同一条的数据；

/**
     * 更新redis中的缓存数据
     *</br> #root. 是spEL表达式
     * </br>如果参数是个对象，就通过“#对象.变量”获取到对应的key中需要的值；比如：#cat.id
     * @param id 主键
     */
    @CachePut(value = "catCache", key = "#root.caches[0].name + ':' + #id")
    @RequestMapping(value = "/updateCat", method = RequestMethod.POST)
    @ResponseBody
    public Cat update(@RequestParam int id){
        System.out.println("==========请求参数："+id);
        return this.catService.updateCat(id);
    }
 
 
本文转自 wyait 51CTO博客，原文链接：http://blog.51cto.com/wyait/2048478，如需转载请自行联系原作者