设为首页 收藏本站
查看: 1517|回复: 0

[经验分享] 基于 自定义注解 和 aop 实现使用memcache 对数据库的缓存 示例

[复制链接]

尚未签到

发表于 2015-11-18 10:39:46 | 显示全部楼层 |阅读模式
  好久没更新blog了,在新公司打拼了两个月,每天都从早忙到晚,学到了很多东西,但是没有时间来更新blog了。。。。
  下面开始讲解这次的主题
  


  公司老大让我研究 ocs 就是阿里云的 开放缓存服务 点击打开链接
  其实就是一个memcache的服务
  memchech 就是用内存来存放 key -value  在一些情况下就不必频繁的访问 数据库了(其实就是个map)
  如何在常用的Dao中方便的使用这个map呢,我首先想到了 aop,然后又想到了自定义注解,那么就开始干吧。。。。
  


  aop动态代理要使用的jar包如下
  aspectjrt-1.6.12.jar(jdk7.0 需要这么高的版本,否则报错)

aspectjweaver-1.6.12.jar

cglib-nodep-2.2.jar
  com.springsource.org.aopalliance-1.0.0.jar
  和其他的spring包请自行搜索
  spring加上这一行 开启自动代理:
  

<aop:aspectj-autoproxy/>  
  
  



我的spring配置  

<?xml version=&quot;1.0&quot; encoding=&quot;UTF-8&quot;?>
<beans xmlns=&quot;http://www.springframework.org/schema/beans&quot;
xmlns:xsi=&quot;http://www.w3.org/2001/XMLSchema-instance&quot; xmlns:context=&quot;http://www.springframework.org/schema/context&quot;
xmlns:aop=&quot;http://www.springframework.org/schema/aop&quot; xmlns:tx=&quot;http://www.springframework.org/schema/tx&quot;
xmlns:mvc=&quot;http://www.springframework.org/schema/mvc&quot;
xsi:schemaLocation=&quot;
http://www.springframework.org/schema/beans
http://www.springframework.org/schema/beans/spring-beans-3.0.xsd
http://www.springframework.org/schema/context
http://www.springframework.org/schema/context/spring-context-3.0.xsd
http://www.springframework.org/schema/aop
http://www.springframework.org/schema/aop/spring-aop-3.0.xsd
http://www.springframework.org/schema/tx
http://www.springframework.org/schema/tx/spring-tx-3.0.xsd
http://www.springframework.org/schema/mvc
http://www.springframework.org/schema/mvc/spring-mvc-3.0.xsd
&quot;>
<!-- 默认扫描的包路径 -->
<context:component-scan base-package=&quot;com.test&quot; />
<!-- 添加注解驱动 -->
<mvc:annotation-driven />
<aop:aspectj-autoproxy/>  
</beans>



首先模拟一个 memCache 我写了一个工具类  
  

package com.test.action;
import java.io.IOException;
import java.util.HashMap;
import java.util.Map;
import java.util.concurrent.ExecutionException;

public class OcsUtil {
private static Map<String, Object> memMap=new HashMap<String, Object>();
//模拟
public static void add(String key,Object val) throws IOException, InterruptedException, ExecutionException{
memMap.put(key, val);
}
//模拟
public static Object get(String key) throws IOException{
return memMap.get(key);
}
}


这个就暂时代替memCached吧。  
  


  dao层:
  

package com.test.dao;
import org.springframework.stereotype.Repository;
import com.test.aop.MemCache;

@Repository
public class TestDao {
@MemCache
public Object selectKeyValue(String arg1,Integer arg2){
return &quot;12345&quot;;
}
}

两个参数随便写的,这样用来模拟真实情况下的多个查询参数  
  方法名上的@MemCache 注解 就是我自己定义的注解,当拥有这个注解的方法在调用时首先会在memCache中去找,这样就提高了性能
  自定义注解如下:
  

package com.test.aop;
import java.lang.annotation.*;
import static java.lang.annotation.ElementType.*;
@Target({METHOD})
@Retention(RetentionPolicy.CLASS)
public @interface MemCache {
}
  我们要做的就是用aop拦截 拥有@MemCache注解的方法,然后处理它。下面是aop拦截器
  package com.test.aop;
import org.aspectj.lang.ProceedingJoinPoint;
import org.aspectj.lang.annotation.Around;
import org.aspectj.lang.annotation.Aspect;
import org.aspectj.lang.annotation.Pointcut;
import org.springframework.stereotype.Component;
import com.google.gson.Gson;
import com.test.action.OcsUtil;
@Component
@Aspect
public class MemCacheInterceptor {
private Gson gson=new Gson();
@Pointcut(&quot;execution(* com.test.dao.TestDao.select*(..))&& @annotation(com.test.aop.MemCache)&quot;)
private void theMethod(){}//定义一个切入点

@Around(&quot;theMethod()&quot;)
public Object doBasicProfiling(ProceedingJoinPoint pjp) throws Throwable{
String  key=pjp.getSignature().toString();
key+=gson.toJson(pjp.getArgs());
Object memValue=OcsUtil.get(key);
if(memValue!=null){
System.out.println(&quot;memcache获取到&quot;);
return memValue;
}
Object object = pjp.proceed();//执行该方法
OcsUtil.add(key, object+&quot; cache&quot;);
System.out.println(&quot;db获取&quot;);
return object;
}
}





  



*1为了测试我在memCache中放的时候追加了一个字符串 “ cache”  
  这个拦截器 使用 “方法的签名” 和 “参数转换成的json字符串” 作为 memCache的key
  就像这个样子 Object com.test.dao.TestDao.selectKeyValue(String,Integer)[&quot;1&quot;,2]
  这样就可以保证memCache的存取与dao的操作对应了
  这样就大功告成了。
  


  


  


  



版权声明:本文为博主原创文章,未经博主允许不得转载。

运维网声明 1、欢迎大家加入本站运维交流群:群②:261659950 群⑤:202807635 群⑦870801961 群⑧679858003
2、本站所有主题由该帖子作者发表,该帖子作者与运维网享有帖子相关版权
3、所有作品的著作权均归原作者享有,请您和我们一样尊重他人的著作权等合法权益。如果您对作品感到满意,请购买正版
4、禁止制作、复制、发布和传播具有反动、淫秽、色情、暴力、凶杀等内容的信息,一经发现立即删除。若您因此触犯法律,一切后果自负,我们对此不承担任何责任
5、所有资源均系网友上传或者通过网络收集,我们仅提供一个展示、介绍、观摩学习的平台,我们不对其内容的准确性、可靠性、正当性、安全性、合法性等负责,亦不承担任何法律责任
6、所有作品仅供您个人学习、研究或欣赏,不得用于商业或者其他用途,否则,一切后果均由您自己承担,我们对此不承担任何法律责任
7、如涉及侵犯版权等问题,请您及时通知我们,我们将立即采取措施予以解决
8、联系人Email:admin@iyunv.com 网址:www.yunweiku.com

所有资源均系网友上传或者通过网络收集,我们仅提供一个展示、介绍、观摩学习的平台,我们不对其承担任何法律责任,如涉及侵犯版权等问题,请您及时通知我们,我们将立即处理,联系人Email:kefu@iyunv.com,QQ:1061981298 本贴地址:https://www.yunweiku.com/thread-140630-1-1.html 上篇帖子: memcache 多线程 并发模型 下篇帖子: 【ci框架】ci框架中中有关memcache文件缓存相关的文件
您需要登录后才可以回帖 登录 | 立即注册

本版积分规则

扫码加入运维网微信交流群X

扫码加入运维网微信交流群

扫描二维码加入运维网微信交流群,最新一手资源尽在官方微信交流群!快快加入我们吧...

扫描微信二维码查看详情

客服E-mail:kefu@iyunv.com 客服QQ:1061981298


QQ群⑦:运维网交流群⑦ QQ群⑧:运维网交流群⑧ k8s群:运维网kubernetes交流群


提醒:禁止发布任何违反国家法律、法规的言论与图片等内容;本站内容均来自个人观点与网络等信息,非本站认同之观点.


本站大部分资源是网友从网上搜集分享而来,其版权均归原作者及其网站所有,我们尊重他人的合法权益,如有内容侵犯您的合法权益,请及时与我们联系进行核实删除!



合作伙伴: 青云cloud

快速回复 返回顶部 返回列表