http://blog.csdn.net/xrt95050/article/details/7325225
上回说到Memcahed的安装及java客户端的使用(http://my249645546.iteye.com/blog/1420061),现在我们使用memcached、Spring AOP技术来构建一个数据库的缓存框架。
数据库访问可能是很多网站的瓶颈。动不动就连接池耗尽、内存溢出等。前面已经讲到如果我们的网站是一个分布式的大型站点,那么使用memcached实现数据库的前端缓存是个很不错的选择;但如果网站本身足够小只有一个服务器,甚至是vps的那种,不推荐使用memcached,使用Hibernate或者Mybatis框架自带的缓存系统就行了。
一、开启memcached服务器端服务
如果已经安装了memcached服务器端程序,请确认服务器端服务已开启。
二、引入jar
1. alisoft-xplatform-asf-cache-2.5.1.jar
2. commons-logging-1.0.4.jar
3. hessian-3.0.1.jar
4. log4j-1.2.9.jar
5. stax-api-1.0.1.jar
6. wstx-asl-2.0.2.jar
三、创建memcached客户端配置文件
02 |
<!-- name 属性是程序中使用Cache的唯一标识;socketpool 属性将会关联到后面的socketpool配置; -->
|
03 |
< client name = "mclient_0" compressEnable = "true" defaultEncoding = "UTF-8"
|
06 |
< errorHandler >com.alisoft.xplatform.asf.cache.memcached.MemcachedErrorHandler
|
11 |
name 属性和client 配置中的socketpool 属性相关联。
|
12 |
maintSleep属性是后台线程管理SocketIO池的检查间隔时间,如果设置为0,则表明不需要后台线程维护SocketIO线程池,默认需要管理。
|
13 |
socketTO 属性是Socket操作超时配置,单位ms。 aliveCheck
|
14 |
属性表示在使用Socket以前是否先检查Socket状态。
|
16 |
< socketpool name = "pool_0" maintSleep = "5000" socketTO = "3000"
|
17 |
failover = "true" aliveCheck = "true" initConn = "5" minConn = "5" maxConn = "250"
|
19 |
<!-- 设置memcache服务端实例地址.多个地址用","隔开 -->
|
20 |
< servers >127.0.0.1:11211</ servers >
|
22 |
可选配置。表明了上面设置的服务器实例的Load权重. 例如 <weights>3,7</weights> 表示30% load 在
|
23 |
10.2.224.36:33001, 70% load 在 10.2.224.46:33001
|
25 |
<weights>3,7</weights>
|
四、创建memcached客户端程序
客户端工具类:
01 |
package com.hl.usersmanager.memcached.client;
|
03 |
import com.alisoft.xplatform.asf.cache.ICacheManager;
|
04 |
import com.alisoft.xplatform.asf.cache.IMemcachedCache;
|
05 |
import com.alisoft.xplatform.asf.cache.memcached.CacheUtil;
|
06 |
import com.alisoft.xplatform.asf.cache.memcached.MemcachedCacheManager;
|
08 |
public class MemcachedCache {
|
09 |
private ICacheManager<IMemcachedCache> manager;
|
10 |
private IMemcachedCache cache;
|
12 |
public MemcachedCache(){
|
13 |
manager = CacheUtil.getCacheManager(IMemcachedCache. class ,
|
14 |
MemcachedCacheManager. class .getName());
|
15 |
manager.setConfigFile( "memcached.xml" );
|
16 |
manager.setResponseStatInterval( 5 * 1000 );
|
18 |
cache = manager.getCache( "mclient_0" );
|
25 |
public IMemcachedCache getCache(){
|
34 |
public void put(String key,Object object){
|
35 |
cache.put(key, object);
|
43 |
public Object get(String key){
|
44 |
return cache.get(key);
|
五、使用Spring AOP在数据查询的Service层实现数据缓存及读取
实现数据缓存的过程很简单,就是在Service层查询数据库操作前判断要查询的数据在缓存中是否存在,如果不存在就到数据库中查询,查询完成后将数据放入缓存系统;如果要查询的数据在缓存中已经存在,则直接从缓存中读取,不需要操作数据库。这就大大降低了数据库的连接次数。原理就是这么简单。
但是,如果直接对Service层代码进行修改,就违背了“开放-封闭”原则,也会导致缓存系统的操作代码散落到Service层的各处,不方便代码的管理和维护。所以,Spring AOP华丽登场了。它使用非入侵式的来创建、管理这些缓存操作代码。
关于Spring AOP本身的一些知识,我们这里不做讲述。参考资料:
由于首先要判断查询数据是否存在于缓存系统,如果存在直接从缓存中读取,也就是说Service层的查询代码根本不会执行;另一方面,如果数据在缓存系统中不存在,从数据库查询出的结果,我们需要将其放入缓存系统中。
我们来看Spring AOP的几个装备中哪个适用呢?那就是最强大的环绕通知装备@Around!
下面以UserService为例,其源代码如下:
01 |
package com.hl.usersmanager.service.impl;
|
03 |
import java.util.List;
|
05 |
import org.springframework.beans.factory.annotation.Autowired;
|
06 |
import org.springframework.stereotype.Service;
|
07 |
import org.springframework.transaction.annotation.Transactional;
|
09 |
import com.hl.usersmanager.dao.IUserMapper;
|
10 |
import com.hl.usersmanager.model.Users;
|
11 |
import com.hl.usersmanager.service.IUserService;
|
13 |
//使用Service注解 不需要再在配置文件中配置bean |
15 |
public class UserServiceImpl implements IUserService{
|
17 |
private IUserMapper userMapper;
|
21 |
public Users findUserByName(String name) {
|
22 |
return userMapper.findUserByName(name);
|
findUserByName主要实现按照用户名查询用户的功能,现在我们使用Spring AOP来实现缓存:
01 |
package com.hl.usersmanager.aop.service;
|
03 |
import org.apache.log4j.Logger;
|
04 |
import org.aspectj.lang.ProceedingJoinPoint;
|
05 |
import org.aspectj.lang.annotation.Around;
|
06 |
import org.aspectj.lang.annotation.Aspect;
|
07 |
import org.aspectj.lang.annotation.Pointcut;
|
08 |
import org.springframework.beans.factory.annotation.Autowired;
|
10 |
import com.hl.usersmanager.memcached.client.MemcachedCache;
|
11 |
import com.hl.usersmanager.model.Users;
|
14 |
public class UserServiceInterceptor {
|
15 |
public static final Logger log = Logger
|
16 |
.getLogger(UserServiceInterceptor. class );
|
18 |
//将缓存客户端工具类 MemcachedCache 织入进来 |
20 |
private MemcachedCache memcachedCache;
|
25 |
@Pointcut("execution(* com.hl.usersmanager.service.impl.UserServiceImpl.*(..))")
|
26 |
public void aPointcut() {
|
31 |
* 环绕装备 用于拦截查询 如果缓存中有数据,直接从缓存中读取;否则从数据库读取并将结果放入缓存
|
37 |
@Around ( "aPointcut()&&args(name)" )
|
38 |
public Users doFindUserByNameAround(ProceedingJoinPoint call, String name) {
|
40 |
if (memcachedCache.getCache().containsKey( "findUserByName_" + name)) {
|
41 |
users = (Users) memcachedCache.get( "findUserByName_" + name);
|
42 |
log.debug( "从缓存中读取!findUserByName_" + name);
|
45 |
users = (Users) call.proceed();
|
47 |
memcachedCache.put( "findUserByName_" + name, users);
|
48 |
log.debug( "缓存装备被执行:findUserByName_" + name);
|
50 |
} catch (Throwable e) {
|
环绕通知装备需要一个ProceedingJoinPoint 类型的参数,它的强大之处在于可以代理一个我们的切入点,指定切入点方法是否执行,或者获取执行后的返回结果!!
memcachedCache.getCache().containsKey("findUserByName_" + name)
可以判断缓存中是否有指定的数据。如果有则直接从缓存中读取:
users = (Users) memcachedCache.get("findUserByName_" + name);
否则调用切入点UserServiceImpl的findUserByName方法:
users = (Users) call.proceed();
call.proceed()表示执行切入点的方法。
使用Spring AOP以后,整个缓存系统代码看起来 就是这么优雅!UserServiceImpl根本不知道外界发了什么,更不知道外界调用它的findUserByName的时候已经被拦截了!
那天不用缓存系统,只需要将Aop这块的代码去掉即可。
当然,我们还需要在Spring 配置文件中注册一个memcached客户端工具类的bean:
1 |
<!-- MemcachedCache缓存 --> |
2 |
< bean id = "MemcachedCache" class = "com.hl.usersmanager.memcached.client.MemcachedCache" ></ bean >
|
相关推荐
NULL 博文链接:https://leiwuluan.iteye.com/blog/1176120
memcached是高性能的分布式缓存服务器,用来集中缓存数据库查询结果,减少数据库访问次数来提高动态web应用的响应速度,官方网站:http://memcached.org/。
hibernate-memcached, 在Hibernate中,使用Memcached作为第二级分布式缓存的库 休眠 memcachedHibernate中使用Memcached作为第二级分布式缓存的库。基于优秀的spymemcached客户端包含对 Whalin ( danga ) memcached...
java Memcached客户端代码,整合到Spring,提供Util工具类 代码片段: public class MemcachedUtils { private static boolean setExp(String key, Object value, Date expire) { boolean flag = false; try { ...
C#使用memCached实现缓存 Memcached 是一个高性能的分布式内存对象缓存系统,用于动态Web应用以减轻数据库负载。它通过在内存中缓存数据和对象来减少读取数据库的次数,从而提供动态、数据库驱动网站的速度。...
使用Spring,SpringMVC,mybatis框架 将memcached和Spring集成,基于Spring原Cache注解
本系统非常简洁易用,主程序BaseManager.java不到1000行代码,用“精悍”来形容绝对不为过,1000行代码却包含了数据库对象的缓存、列表和长度的缓存、按字段散列缓存、update延时更新、自动清除列表缓存等功能,用它...
memcached缓存使用演示小项目,缓存服务器的搭建,增删改查缓存
该项在java-memcached客户端的基础上使用java5的注解和Sping/AspectJ的AOP,使能够在Sping中管理bean缓存。使用Simple-Spring-Memcached只需要简单的配置和在要缓存的方法的返回值或参数上标注上相应的注解就可以。
memcached缓存数据库,有需要的亲们及时下载把
想要学习Memcached与spring集成的
memcached缓存安装使用说明,包含windows和linux的安装和使用 集群
memcached和spring集成、内附测试例子
memcached 缓存 jar包,tomcat共享缓存可用,java开发数据库缓存也可用。
简单的Spring Memcached 一个通过注释在Spring bean中启用... 该项目通过在 , 或客户端之上使用Java 5注释和Spring / AspectJ AOP来启用Spring管理的bean中的缓存。 使用Simple Spring Memcached仅需要一点点配置
Memcached——内存数据库讲义及安装步骤
顾名思义是基于spring和memcached的一个插件,该插件目前实现了memcached的查询缓存,利用java的annotation方式和spring的AOP切面编程使得我们在业务层获得缓存数据非常的方便 ##开始使用 首先你必须实现CacheSupport...
memcached_1.2.3.zip服务器缓存调节工具,能够进行服务器上缓存管理,加快服务器访问效率
memcached缓存在spring中的配置
本资源都是自创的,对安装MemCached Server和调用MemCached做了详细的说明和源码提供,在其中整合了本地缓存HttpContext.Current.Cache,都是key-value模式