文档章节

SpringBoot集成Redis--配置自定义的RedisCacheManager

k
 karma123
发布于 07/17 22:27
字数 1794
阅读 189
收藏 13

配置自定义的RedisCacheManager--1自定义键生成规则

默认的键生成器

当不指定缓存的key时,SpringBoot会使用SimpleKeyGenerator生成key。

SimpleKeyGenerator

SimpleKey

查看源码可以发现,它是使用方法参数组合生成的一个key。

通过SpEL自定义键生成规则

诸如下面红框的代码,SpEL实际上可以写非常复杂的生成规则。

自定义键生成器

@Configuration 标注的类中,可以根据自己设计的规则自定义键生成器。

自定义键生成器代码

/**

 * 新的键生成规则

 */

@Bean 

@Override 

public KeyGenerator keyGenerator() {

return new KeyGenerator(){

public Object generate(Object target, Method method, Object... params){

StringBuilder sb = new StringBuilder();

sb.append(target.getClass().getName());

sb.append("::" + method.getName() + ":");

for (Object obj : params) {

sb.append(obj.toString());

}

return sb.toString();

}

};

}

代码分析

上面自定义的键生成器键的生成规则是:包名+方法名+参数列表。

配置自定义的RedisCacheManager--2创建RedisTemplate模板时自定义序列化器

RedisTemplate默认提供的序列化器

RedisSerializer redis序列化的接口类

OxmSerializer xml到object的序列化/反序列化

StringRedisSerializer string字符串的序列化/反序列化

JacksonJsonRedisSerializer json到object的序列化/反序列化

Jackson2JsonRedisSerializer json到object的序列化/反序列化

JdkSerializationRedisSerializer java对象的序列化/反序列化

RedisTemplate默认使用的是JdkSerializationRedisSerializer

常见序列化方式的特点

JdkSerializationRedisSerializer:JDK自带的序列化方式、存储的字符串内容在序列化的情况下偏长,会占用过多的内存

OxmSerializer:序列化的时间相对较长

Jackson2JsonRedisSerializer:json数据格式、序列化时间和序列化之后内容的长度都要优于前两种

自定义序列化器--使用Jackson2JsonRedisSerializer

代码

/**

 * RedisTemplate 使用 Jackson2JsonRedisSerializer 作为序列化器

 * @return

 */

@Bean 

public RedisTemplate<String, String> redisTemplate() {

StringRedisTemplate redisTemplate = new StringRedisTemplate(jedisConnectionFactory);


Jackson2JsonRedisSerializer<Object> jackson2JsonRedisSerializer = new Jackson2JsonRedisSerializer<Object>(Object.class);

ObjectMapper om = new ObjectMapper();

om.setVisibility(PropertyAccessor.ALL, JsonAutoDetect.Visibility.ANY);

om.enableDefaultTyping(ObjectMapper.DefaultTyping.NON_FINAL);

jackson2JsonRedisSerializer.setObjectMapper(om);


redisTemplate.setValueSerializer(jackson2JsonRedisSerializer);

redisTemplate.afterPropertiesSet();

return redisTemplate;

}

Jackson2JsonRedisSerializer的序列化器需要引入Jackson的依赖

<dependency>

      <groupId>com.fasterxml.jackson.core</groupId>

      <artifactId>jackson-databind</artifactId>

      <version>2.6.7</version>

</dependency>

配置自定义的RedisCacheManager--3示例代码

总体项目结构

POM文件

<project xmlns="http://maven.apache.org/POM/4.0.0" xmlns:xsi="http://www.w3.org/2001/XMLSchema-instance"

xsi:schemaLocation="http://maven.apache.org/POM/4.0.0 http://maven.apache.org/xsd/maven-4.0.0.xsd">

<modelVersion>4.0.0</modelVersion>

<groupId>com.ding.data</groupId>

<artifactId>RedisCacheCase</artifactId>

<version>0.0.1-SNAPSHOT</version>



<properties>

<project.build.sourceEncoding>UTF-8</project.build.sourceEncoding>

<boot.version>1.3.5.RELEASE</boot.version>

</properties>


<dependencies>

<dependency>

<groupId>org.springframework.boot</groupId>

<artifactId>spring-boot-starter-web</artifactId>

<version>${boot.version}</version>

</dependency>

<dependency>

<groupId>org.springframework.boot</groupId>

<artifactId>spring-boot-starter-test</artifactId>

<version>${boot.version}</version>

<scope>test</scope>

</dependency>

<dependency>

<groupId>org.springframework.boot</groupId>

<artifactId>spring-boot-starter-cache</artifactId>

<version>${boot.version}</version>

</dependency>

<dependency>

<groupId>org.springframework.boot</groupId>

<artifactId>spring-boot-starter-redis</artifactId>

<version>${boot.version}</version>

</dependency>

<dependency>

      <groupId>com.fasterxml.jackson.core</groupId>

      <artifactId>jackson-databind</artifactId>

      <version>2.6.7</version>

</dependency>

<!-- <dependency>

<groupId>com.google.guava</groupId>

<artifactId>guava</artifactId>

<version>19.0</version>

</dependency> -->

</dependencies>

</project>

配置文件application.yml

    

spring:

      cache:

        #缓存名称

        #cache-names: guavaDemo

        #缓存最大数量500条, 缓存失效时间 6个小时

        #guava.spec: maximumSize=500,expireAfterWrite=360m

      # REDIS (RedisProperties)  

      redis :

        host : localhost # server host  

        port : 6379 # connection port  

        password : 123

        database : 1

        pool.max-idle : 8 # pool settings ...  

        pool.min-idle : 1

        pool.max-active : 8  

        pool.max-wait : -1

 

主启动类

package com.ding.data;


import java.text.SimpleDateFormat;

import java.util.Date;


import org.springframework.beans.factory.annotation.Autowired;

import org.springframework.boot.SpringApplication;

import org.springframework.boot.autoconfigure.SpringBootApplication;

import org.springframework.cache.annotation.EnableCaching;

import org.springframework.web.bind.annotation.RequestMapping;

import org.springframework.web.bind.annotation.RestController;


import com.ding.data.cache.DataCache;


/**

 * 是Spring Boot项目的核心注解,主要是开启自动配置

 */

@SpringBootApplication // same as @Configuration @EnableAutoConfiguration @ComponentScan

@RestController

// 开启缓存

@EnableCaching

public class RedisCacheCase {


@Autowired

private DataCache dataCache;


public static void main(String[] args) {

SpringApplication.run(RedisCacheCase.class, args);

}


@RequestMapping("/put")

public String put(Long id, String value) {

SimpleDateFormat sdf = new SimpleDateFormat("yyyy-MM-dd HH:mm:ss");

return  sdf.format(new Date()) + " : value is " + dataCache.put(id, value) ;

}


@RequestMapping("/get")

public String query(Long id){

SimpleDateFormat sdf = new SimpleDateFormat("yyyy-MM-dd HH:mm:ss");

return sdf.format(new Date()) + " : value is " +dataCache.query(id) ;

}


@RequestMapping("/remove")

public String remove(Long id) {

SimpleDateFormat sdf = new SimpleDateFormat("yyyy-MM-dd HH:mm:ss");

dataCache.remove(id) ;

return sdf.format(new Date()) + " : success " ;

}


}

配置类代码

package com.ding.data.config;

import java.lang.reflect.Method;


import org.springframework.beans.factory.annotation.Autowired;

import org.springframework.cache.CacheManager;

import org.springframework.cache.annotation.CachingConfigurerSupport;

import org.springframework.cache.interceptor.KeyGenerator;

import org.springframework.context.annotation.Bean;

import org.springframework.context.annotation.Configuration;

import org.springframework.data.redis.cache.RedisCacheManager;

import org.springframework.data.redis.connection.jedis.JedisConnectionFactory;

import org.springframework.data.redis.core.RedisTemplate;

import org.springframework.data.redis.core.StringRedisTemplate;

import org.springframework.data.redis.serializer.Jackson2JsonRedisSerializer;


import com.fasterxml.jackson.annotation.JsonAutoDetect;

import com.fasterxml.jackson.annotation.PropertyAccessor;

import com.fasterxml.jackson.databind.ObjectMapper;


@Configuration

public class MyRedisCacheConfig extends CachingConfigurerSupport{


@Autowired

private JedisConnectionFactory jedisConnectionFactory;


@Bean

public CacheManager cacheManager() {

RedisCacheManager redisCacheManager = new RedisCacheManager(redisTemplate());

redisCacheManager.setDefaultExpiration(86400);

return redisCacheManager;

}


/**

 * RedisTemplate 使用 Jackson2JsonRedisSerializer 作为序列化器

 * @return

 */

@Bean 

public RedisTemplate<String, String> redisTemplate() {

StringRedisTemplate redisTemplate = new StringRedisTemplate(jedisConnectionFactory);


Jackson2JsonRedisSerializer<Object> jackson2JsonRedisSerializer = new Jackson2JsonRedisSerializer<Object>(Object.class);

ObjectMapper om = new ObjectMapper();

om.setVisibility(PropertyAccessor.ALL, JsonAutoDetect.Visibility.ANY);

om.enableDefaultTyping(ObjectMapper.DefaultTyping.NON_FINAL);

jackson2JsonRedisSerializer.setObjectMapper(om);


redisTemplate.setValueSerializer(jackson2JsonRedisSerializer);

redisTemplate.afterPropertiesSet();

return redisTemplate;

}


/**

 * 新的键生成规则

 */

@Bean 

@Override 

public KeyGenerator keyGenerator() {

return new KeyGenerator(){

public Object generate(Object target, Method method, Object... params){

StringBuilder sb = new StringBuilder();

sb.append(target.getClass().getName());

sb.append("::" + method.getName() + ":");

for (Object obj : params) {

sb.append(obj.toString());

}

return sb.toString();

}

};

}

}

业务层代码

package com.ding.data.cache;


import java.text.SimpleDateFormat;

import java.util.Date;

import java.util.HashMap;

import java.util.Map;


import javax.annotation.PostConstruct;


import org.springframework.cache.annotation.CacheEvict;

import org.springframework.cache.annotation.CachePut;

import org.springframework.cache.annotation.Cacheable;

import org.springframework.stereotype.Component;


@Component

public class DataCache {


private Map<Long, String> dataMap = new HashMap<Long, String>();


/**

 * 初始化

 */

@PostConstruct

public void init() {

dataMap.put(1L, "张三");

dataMap.put(2L, "李四");

dataMap.put(3L, "王五");

}


/**

 * 查询

 * 如果数据没有缓存,那么从dataMap里面获取,如果缓存了,

 * 那么从redisDemo里面获取

 * 并且将缓存的数据存入到 redisDemo里面

 * 其中key 为 #id+dataMap

 */

// @Cacheable(value="redisDemo" ,key="#id + 'dataMap'")

@Cacheable(value="redisDemo")

public String query(Long id) {

SimpleDateFormat sdf = new SimpleDateFormat("yyyy-MM-dd HH:mm:ss");

System.out.println(sdf.format(new Date()) + " : query id is " + id);

return dataMap.get(id);

}


/**

 * 插入 或者更新

 * 插入或更新数据到dataMap中

 * 并且缓存到 redisDemo中

 * 如果存在了那么更新缓存中的值

 * 其中key 为 #id+dataMap

 */

// @CachePut(value="redisDemo" ,key="#id + 'dataMap'")

@CachePut(value="redisDemo")

public String put(Long id, String value) {

SimpleDateFormat sdf = new SimpleDateFormat("yyyy-MM-dd HH:mm:ss");

System.out.println(sdf.format(new Date()) + " : add data ,id is "+ id);

dataMap.put(id, value);

// data persistence

return value;

}


/**

 * 删除

 * 删除dataMap里面的数据

 * 并且删除缓存redisDemo中的数据

 * 其中key 为 #id+dataMap

 */

// @CacheEvict(value="redisDemo" , key="#id + 'dataMap'")

@CacheEvict(value="redisDemo")

public void remove(Long id) {

SimpleDateFormat sdf = new SimpleDateFormat("yyyy-MM-dd HH:mm:ss");

System.out.println(sdf.format(new Date()) + " : remove id is "+ id + " data");

dataMap.remove(id);

// data remove  

}



}

测试

依次访问:

http://localhost:8080/get?id=1

http://localhost:8080/get?id=2

http://localhost:8080/put?id=1&value=meixi

http://localhost:8080/put?id=1&value=neimaer

http://localhost:8080/put?id=1&value=cluo

查看Redis内存的内容,如下(因为Redis的database参数用的1,所以用的是Redis中的db1库)

与代码的逻辑是相符的,但是出现了新的问题,除了 @Cacheable 注解的方法仍然起到缓存的作用,其他的缓存方法实际上没起作用。这主要是因为现在缓存键生成的规则不具备重复利用性,实际项目需要根据需求对键生成规则进行修改的。

代码改造一下:使 @CachePut 注解的方法也能起作用

新增一个类MyKeyGenerator

package com.ding.data.config;


import java.lang.reflect.Method;


import org.springframework.cache.interceptor.KeyGenerator;

import org.springframework.stereotype.Component;


@Component

public class MyKeyGenerator implements KeyGenerator{


public Object generate(Object target, Method method, Object... params) {

StringBuilder sb = new StringBuilder();

sb.append(target.getClass().getName());

sb.append("::" + "query" + ":" + params[0].toString());

return sb.toString();

    }

}

DataCache类中 @CachePut 标注的方法改造如下

/**

 * 插入 或者更新

 * 插入或更新数据到dataMap中

 * 并且缓存到 redisDemo中

 * 如果存在了那么更新缓存中的值

 * 其中key 为 #id+dataMap

 */

// @CachePut(value="redisDemo" ,key="#id + 'dataMap'")

@CachePut(value="redisDemo",keyGenerator="myKeyGenerator")

public String put(Long id, String value) {

SimpleDateFormat sdf = new SimpleDateFormat("yyyy-MM-dd HH:mm:ss");

System.out.println(sdf.format(new Date()) + " : add data ,id is "+ id);

dataMap.put(id, value);

// data persistence

return value;

}

keyGenerator="myKeyGenerator"啥意思

意思就是说明这个方法的键生成规则采用myKeyGenerator这个类

再次测试(先将刚才测试的数据都清空)

依次访问:

http://localhost:8080/get?id=1

http://localhost:8080/put?id=1&value=meixi

查看Redis数据库中的数据

可见改造后@CachePut 标注的方法也起作用了。

但是现在代码仍然太“死性”,无法应用于实际项目。要想应用于实际项目,还需要根据具体需求进行设计。

© 著作权归作者所有

共有 人打赏支持
k
粉丝 8
博文 75
码字总数 61162
作品 0
丰台
Springboot 2.0 - 集成redis

最近在入门SpringBoot,然后在感慨 SpringBoot较于Spring真的方便多时,顺便记录下自己在集成redis时的一些想法。 从springboot官网查看redis的依赖包 操作redis redis的包中提供了两个可以操...

Java烂猪皮
10/04
0
0
SpringBoot下Redis相关配置是如何被初始化的

参考网页 SpringBoot集成Redis的原理 https://blog.csdn.net/hry2015/article/details/74276423 https://blog.csdn.net/hry2015/article/details/75451705 application.yml配置文件中的属性是......

karma123
07/17
0
0
恒宇少年/spring-boot-chapter

简书整套文档以及源码解析 专题 专题名称 专题描述 001 Spring Boot 核心技术 讲解SpringBoot一些企业级层面的核心组件 002 Spring Cloud 核心技术 对Spring Cloud核心技术全面讲解 003 Quer...

恒宇少年
04/19
0
0
Spring Boot 全家桶 - SpringBootBucket

Spring Boot 现在已经成为Java 开发领域的一颗璀璨明珠,它本身是包容万象的,可以跟各种技术集成。 本项目对目前Web开发中常用的各个技术,通过和SpringBoot的集成,并且对各种技术通过“一...

一刀
03/05
0
1
崛起于Springboot2.X之哨兵模式Redis(16)

介绍:springboot的哨兵模式如果只是使用redis的情况下,在单机redis 的前提下,直接在配置文件添加几行配置就可以了,因为springboot有自动配置加载的功能就可以了 1、把单机的redis中的配置...

木九天
07/15
0
0

没有更多内容

加载失败,请刷新页面

加载更多

初级开发-编程题

` public static void main(String[] args) { System.out.println(changeStrToUpperCase("user_name_abc")); System.out.println(changeStrToLowerCase(changeStrToUpperCase("user_name_abc......

小池仔
今天
4
0
现场看路演了!

HiBlock
昨天
12
0
Rabbit MQ基本概念介绍

RabbitMQ介绍 • RabbitMQ是一个消息中间件,是一个很好用的消息队列框架。 • ConnectionFactory、Connection、Channel都是RabbitMQ对外提供的API中最基本的对象。Connection是RabbitMQ的s...

寰宇01
昨天
9
0
官方精简版Windows10:微软自己都看不过去了

微软宣布,该公司正在寻求解决方案,以减轻企业客户的Windows 10规模。该公司声称,企业客户下载整个Windows 10文件以更新设备既费钱又费时。 微软宣布,该公司正在寻求解决方案,以减轻企业...

linux-tao
昨天
14
0
TypeScript基础入门之JSX(二)

转发 TypeScript基础入门之JSX(二) 属性类型检查 键入检查属性的第一步是确定元素属性类型。 内在元素和基于价值的元素之间略有不同。 对于内部元素,它是JSX.IntrinsicElements上的属性类型...

durban
昨天
9
0

没有更多内容

加载失败,请刷新页面

加载更多

返回顶部
顶部