使用Memcached、Spring AOP构建数据库前端缓存框架

erlchina

package com.hl.usersmanager.aop.service;　　

　　
import org.apache.log4j.Logger;
　　
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.beans.factory.annotation.Autowired;
　　

　　
import com.hl.usersmanager.memcached.client.MemcachedCache;
　　
import com.hl.usersmanager.model.Users;
　　

　　
@Aspect
　　
public class UserServiceInterceptor {
　　
    public static final Logger log = Logger
　　
            .getLogger(UserServiceInterceptor.class);
　　

　　
//将缓存客户端工具类 MemcachedCache 织入进来
　　
    @Autowired
　　
    private MemcachedCache memcachedCache;
　　

　　
    /*
　　
     * 定义pointcunt
　　
     */
　　
    @Pointcut("execution(* com.hl.usersmanager.service.impl.UserServiceImpl.*(..))")
　　
    public void aPointcut() {
　　

　　
    }
　　

　　
    /**
　　
     * 环绕装备 用于拦截查询 如果缓存中有数据，直接从缓存中读取；否则从数据库读取并将结果放入缓存
　　
     *
　　
     * @param call
　　
     * @param name
　　
     * @return
　　
     */
　　
    @Around("aPointcut()&&args(name)")
　　
    public Users doFindUserByNameAround(ProceedingJoinPoint call, String name) {
　　
        Users users = null;
　　
        if (memcachedCache.getCache().containsKey("findUserByName_" + name)) {
　　
            users = (Users) memcachedCache.get("findUserByName_" + name);
　　
            log.debug("从缓存中读取！findUserByName_" + name);
　　
        } else {
　　
            try {
　　
                users = (Users) call.proceed();
　　
                if (users != null) {
　　
                    memcachedCache.put("findUserByName_" + name, users);
　　
                    log.debug("缓存装备被执行：findUserByName_" + name);
　　
                }
　　
            } catch (Throwable e) {
　　
                e.printStackTrace();
　　
            }
　　
        }
　　
        return users;
　　
    }
　　
}