spring与redis集成之aop整合方案

柔光的暖阳◎ 2022-08-21 12:44 140阅读 0赞

java使用redis缓存可以使用jedis框架,jedis操作简单,没有什么复杂的东西需要学习,网上资料很多,随便看看就会了.

将spring与redis缓存集成,其实也是使用jedis框架,只不过spring对它进行了一层封装,并将这层封装库命名为spring-data-redis.

下面将要使用spring-data-redis与jedis的jar包,并通过spring的aop功能,将redis缓存无缝无侵入的整合进来.

1.先下载好依赖包

**\[html\]**  [view plain][]   [copy][view plain]

[![在CODE上查看代码片][CODE]][CODE_CODE] [![派生到我的代码片][ico_fork.svg]][ico_fork.svg 1]

1.  **<****dependency****>**  
2.      **<****groupId****>**org.springframework**</****groupId****>**  
3.      **<****artifactId****>**spring-core**</****artifactId****>**  
4.      **<****version****>**4.1.1.RELEASE**</****version****>**  
5.  **</****dependency****>**  
6.

**\[html\]**  [view plain][]   [copy][view plain]

[![在CODE上查看代码片][CODE]][CODE_CODE] [![派生到我的代码片][ico_fork.svg]][ico_fork.svg 1]

1.  **<****dependency****>**    
2.      **<****groupId****>**org.springframework.data**</****groupId****>**    
3.      **<****artifactId****>**spring-data-redis**</****artifactId****>**    
4.      **<****version****>**1.4.1.RELEASE**</****version****>**    
5.  **</****dependency****>**   
6.  **<****dependency****>**   
7.      **<****groupId****>**redis.clients**</****groupId****>**   
8.      **<****artifactId****>**jedis**</****artifactId****>**   
9.      **<****version****>**2.6.0**</****version****>**   
10. **</****dependency****>**

2.再配置spring文件

**\[html\]**  [view plain][]   [copy][view plain]

[![在CODE上查看代码片][CODE]][CODE_CODE] [![派生到我的代码片][ico_fork.svg]][ico_fork.svg 1]

1.     **<****bean** id="poolConfig" class="redis.clients.jedis.JedisPoolConfig"**>**  
2.      **<****property** name="minIdle" value="$\{redis.minIdle\}" **/>**  
3.         **<****property** name="maxIdle" value="$\{redis.maxIdle\}" **/>**    
4.         **<****property** name="maxTotal" value="$\{redis.maxActive\}" **/>**    
5.         **<****property** name="maxWaitMillis" value="$\{redis.maxWait\}" **/>**    
6.         **<****property** name="testOnBorrow" value="$\{redis.testOnBorrow\}" **/>**    
7.     **</****bean****>**    
8.       
9.     **<****bean** id="jedisConnFactory" class="org.springframework.data.redis.connection.jedis.JedisConnectionFactory"**>**  
10.        **<****property** name="hostName" value="$\{redis.host\}" **/>**  
11.        **<****property** name="port" value="$\{redis.port\}" **/>**  
12.        **<****property** name="password" value="$\{redis.password\}" **/>**  
13.        **<****property** name="usePool" value="true" **/>**  
14.        **<****property** name="poolConfig" ref="poolConfig" **/>**  
15.    **</****bean****>**   
16.      
17.   
18. **<****bean** id="redisTemplate" class="org.springframework.data.redis.core.RedisTemplate"**>**  
19.     **<****property** name="connectionFactory" ref="jedisConnFactory" **/>**  
20.     **<****property** name="keySerializer"**>**  
21.         **<****bean** class="org.springframework.data.redis.serializer.StringRedisSerializer" **/>**  
22.     **</****property****>**     
23.     **<****property** name="valueSerializer"**>**  
24.         **<****bean** class="org.springframework.data.redis.serializer.JdkSerializationRedisSerializer" **/>**  
25.     **</****property****>**  
26.     **<****property** name="hashKeySerializer"**>**    
27.        **<****bean** class="org.springframework.data.redis.serializer.StringRedisSerializer"**/>**    
28.     **</****property****>**  
29.     **<****property** name="hashValueSerializer"**>**  
30.        **<****bean** class="org.springframework.data.redis.serializer.JdkSerializationRedisSerializer"**/>**    
31.     **</****property****>**  
32. **</****bean****>**

3.开始编写aop代码

3.1 声明两个注解类,用于定义哪些方法将使用缓存

**\[java\]**  [view plain][]   [copy][view plain]

[![在CODE上查看代码片][CODE]][CODE_CODE] [![派生到我的代码片][ico_fork.svg]][ico_fork.svg 1]

1.  @Retention(RetentionPolicy.RUNTIME)  
2.  @Target(\{ElementType.METHOD\})  
3.  **public** **@interface** Cacheable \{  
4.        
5.      **public** **enum** KeyMode\{  
6.          DEFAULT,    //只有加了@CacheKey的参数,才加入key后缀中  
7.          BASIC,      //只有基本类型参数,才加入key后缀中,如:String,Integer,Long,Short,Boolean  
8.          ALL;        //所有参数都加入key后缀  
9.      \}  
10.       
11.     **public** String key() **default** "";     //缓存key  
12.     **public** KeyMode keyMode() **default** KeyMode.DEFAULT;       //key的后缀模式  
13.     **public** **int** expire() **default** 0;      //缓存多少秒,默认无限期  
14. \}

**\[java\]**  [view plain][]   [copy][view plain]

[![在CODE上查看代码片][CODE]][CODE_CODE] [![派生到我的代码片][ico_fork.svg]][ico_fork.svg 1]

1.  @Retention(RetentionPolicy.RUNTIME)  
2.  @Target(\{ElementType.PARAMETER\})  
3.  **public** **@interface** CacheKey \{\}

3.2 创建一个Aop拦截器的处理类,用于拦截加了@Cacheable的方法

**\[java\]**  [view plain][]   [copy][view plain]

[![在CODE上查看代码片][CODE]][CODE_CODE] [![派生到我的代码片][ico_fork.svg]][ico_fork.svg 1]

1.  @Aspect  
2.  @Component  
3.  **public** **class** CacheableAop \{  
4.        
5.      @Autowired **private** RedisTemplate redisTemplate;  
6.        
7.      @Around("@annotation(cache)")  
8.      **public** Object cached(**final** ProceedingJoinPoint pjp,Cacheable cache) **throws** Throwable \{  
9.            
10.         String key=getCacheKey(pjp, cache);  
11.         ValueOperations<String, Object> valueOper=redisTemplate.opsForValue();  
12.         Object value=valueOper.get(key);    //从缓存获取数据  
13.         **if**(value!=**null**) **return** value;       //如果有数据,则直接返回  
14.           
15.         value = pjp.proceed();      //跳过缓存,到后端查询数据  
16.         **if**(cache.expire()<=0) \{      //如果没有设置过期时间,则无限期缓存  
17.             valueOper.set(key, value);  
18.         \} **else** \{                    //否则设置缓存时间  
19.             valueOper.set(key, value,cache.expire(),TimeUnit.SECONDS);  
20.         \}  
21.         **return** value;  
22.     \}  
23.       
24.     /\*\* 
25.      \* 获取缓存的key值 
26.      \* @param pjp 
27.      \* @param cache 
28.      \* @return 
29.      \*/  
30.     **private** String getCacheKey(ProceedingJoinPoint pjp,Cacheable cache) \{  
31.           
32.         StringBuilder buf=**new** StringBuilder();  
33.         buf.append(pjp.getSignature().getDeclaringTypeName()).append(".").append(pjp.getSignature().getName());  
34.         **if**(cache.key().length()>0) \{  
35.             buf.append(".").append(cache.key());  
36.         \}  
37.           
38.         Object\[\] args=pjp.getArgs();  
39.         **if**(cache.keyMode()==KeyMode.DEFAULT) \{  
40.             Annotation\[\]\[\] pas=((MethodSignature)pjp.getSignature()).getMethod().getParameterAnnotations();  
41.             **for**(**int** i=0;i<pas.length;i++) \{  
42.                 **for**(Annotation an:pas\[i\]) \{  
43.                     **if**(an **instanceof** CacheKey) \{  
44.                         buf.append(".").append(args\[i\].toString());  
45.                         **break**;  
46.                     \}  
47.                 \}  
48.             \}  
49.         \} **else** **if**(cache.keyMode()==KeyMode.BASIC) \{  
50.             **for**(Object arg:args) \{  
51.                 **if**(arg **instanceof** String) \{  
52.                     buf.append(".").append(arg);  
53.                 \} **else** **if**(arg **instanceof** Integer || arg **instanceof** Long || arg **instanceof** Short) \{  
54.                     buf.append(".").append(arg.toString());  
55.                 \} **else** **if**(arg **instanceof** Boolean) \{  
56.                     buf.append(".").append(arg.toString());  
57.                 \}  
58.             \}  
59.         \} **else** **if**(cache.keyMode()==KeyMode.ALL) \{  
60.             **for**(Object arg:args) \{  
61.                 buf.append(".").append(arg.toString());  
62.             \}  
63.         \}  
64.           
65.         **return** buf.toString();  
66.     \}  
67. \}

4.使用缓存示例

**\[java\]**  [view plain][]   [copy][view plain]

[![在CODE上查看代码片][CODE]][CODE_CODE] [![派生到我的代码片][ico_fork.svg]][ico_fork.svg 1]

1.  @Service  
2.  @Transactional  
3.  **public** **class** DemoServiceImpl **implements** DemoService \{  
4.    
5.      @Autowired **private** DemoDao demoDao;  
6.    
7.      **public** List<Demo> findAll() \{  
8.          **return** demoDao.findAll();  
9.      \}  
10.       
11.     /\* 
12.         对get()方法配置使用缓存,缓存有效期为3600秒,缓存的key格式为:\{package\_name\}.DemoServiceImpl.get 
13.         同时为参数配置了@CacheKey后,表示此参数的值将做为key的后缀,此例的key,最终是:\{package\_name\}.DemoServiceImpl.get.\{id\} 
14.         可以为多个参数配置@CacheKey,拦截器会调用参数的toString()做为key的后缀 
15.         若配置多个@CacheKey参数,那么最终的key格式为:\{package\_name\}.\{class\_name\}.\{method\}.\{arg1\}.\{arg2\}.\{...\} 
16.      \*/  
17.     @Cacheable(expire=3600)  
18.     **public** Demo get(@CacheKey String id) \{  
19.         **return** demoDao.get(id);  
20.     \}  
21.   
22.     **public** Demo getByName(String name) \{  
23.         **return** demoDao.getByName(name);  
24.     \}  
25. \}

*  若为名称相同的方法配置缓存,可以在@Cacheable中加入key属性,追加额外的key后缀
 *  @Cacheable还有一个KeyMode属性,用于配置哪些参数可以追加到key后缀中,  
    默认取值 DEFAULT:表示只有加了@CacheKey的参数才能追加到key后缀  
    BASIC:自动将基本类型追加到key后缀,而无需再配置@CacheKey  
    ALL:自动将所有参数追加到lkey后缀,而无需再配置@CacheKey

这只是一个初步整合方案,测试可行,还未在生产中使用,实际效果待验正.

[view plain]: http://blog.csdn.net/zhanngle/article/details/41077423#
[CODE]: https://code.csdn.net/assets/CODE_ico.png
[CODE_CODE]: https://code.csdn.net/snippets/517538
[ico_fork.svg]: https://code.csdn.net/assets/ico_fork.svg
[ico_fork.svg 1]: https://code.csdn.net/snippets/517538/fork

发表评论取消回复

表情：

评论列表（有 0 条评论，140人围观）

还没有评论，来说两句吧...

相关阅读

相关 Spring与MyBatis集成 AOP整合PageHelper插件

目录 1.什么是集成？ 2.Spring与MyBatis集成 3.Spring与MyBatis集成的基本配置 4.AOP整合PageHelper插件 --------

悠悠/ 2023年10月15日 10:24/ 0 赞/ 113 阅读

相关 spring与redis集成之aop整合方案

java使用redis缓存可以使用jedis框架,jedis操作简单,没有什么复杂的东西需要学习,网上资料很多,随便看看就会了. 将spring与redis缓存集成,其实也是

柔光的暖阳◎/ 2022年08月21日 12:44/ 0 赞/ 141 阅读

相关 Spring整合Redis之哨兵与故障转移

前言上篇[博客][Link 1]谈到了Spring整合redis集群以及故障转移演示，会发现redis集群模式存在一个很明显的问题：当某个主节点及其所有从节点挂掉，整个

港控/mmm°/ 2022年06月10日 04:28/ 0 赞/ 340 阅读

相关 Redis 讲解系列之与Spring集成(二)

Redis 讲解系列之与Spring集成(二) 上章中我们讲解了如何使用spring与spring-data-redis如何整合在一起同时总结出了一些优缺点，正对于缺点

灰太狼/ 2022年06月07日 10:25/ 0 赞/ 179 阅读

相关 Redis 讲解系列之与Spring集成(一)

Redis 讲解系列之与Spring集成(一) 本章我们将实例讲解Redis如何与Spring整合。由于Redis与Spring的整合手段比较多，本章将着重讲解Spri

水深无声/ 2022年06月07日 10:23/ 0 赞/ 140 阅读

相关 redis整合spring mybatis -- 缓存方案

上一篇总结了redis sentinel（哨兵方案）的配置流程，本篇就redis整合ssm框架进行说明。目前，大多数公司用redis主要做缓存用，对于那些不常变动的数据来说，我

秒速五厘米/ 2022年06月05日 06:49/ 0 赞/ 226 阅读

相关 Spring Boot 集成AOP

在这里多谈一些关于AOP 方面的知识，如果你对AOP 方面的知识比较熟悉，可以直接略过这个段落，往下看。一、AOP概述 AOP(面向切面编程) 概念：这种在运行时，动

曾经终败给现在/ 2022年05月31日 08:56/ 0 赞/ 163 阅读

相关 spring和redis整合集成步骤

spring和redis整合集成步骤一、准备工作 1、已经安装好redis服务（windows 版，linux 版都可以） 2、依赖jar： jedis

Bertha 。/ 2022年05月30日 02:49/ 0 赞/ 156 阅读

相关 Redis（五）之整合Jedis与Spring

思路：创建一个redis操作的接口。分别创建两个实现类对应redis 的单机版和集群版。当使用单机版redis时，配置单机版的实现类，当使用集群版本的时候，配置集群版的实现类。

女爷i/ 2022年05月21日 05:52/ 0 赞/ 187 阅读

相关 SpringBoot集成Spring AOP

在开始之前，我们先把需要的jar包添加到工程里。新增Maven依赖如下： \[html\] [view plain][] [copy][view plain] 1.

ゝ一世哀愁。/ 2021年09月15日 03:18/ 0 赞/ 339 阅读