注解方式---spring的AOP拦截用户操作
1、主要实现用户在进行某项操作时，多数据库的更新、插入和删除详细信息。记录操作时的请求信息。
2、在进入Controller时，生成一个事物ID，在这个Controller中进行的所有DAO操作都绑定该事物ID。并进行记录日志信息。
?
package com.centralsoft.filter;import java.lang.reflect.Field;import java.lang.reflect.Method;import java.util.Date;import java.util.HashMap;import java.util.regex.Pattern;import net.sf.json.JSONObject;import org.aspectj.lang.ProceedingJoinPoint;import org.aspectj.lang.annotation.Around;import org.aspectj.lang.annotation.Aspect;import org.springframework.beans.factory.annotation.Autowired;import org.springframework.beans.factory.annotation.Qualifier;import org.springframework.stereotype.Component;import com.centralsoft.cache.CacheService;import com.centralsoft.cache.annotations.Cache;import com.centralsoft.cache.entity.MemCacheKey;import com.centralsoft.entity.SysLogDetail;import com.centralsoft.manager.pub.ThreadBean;import com.centralsoft.manager.pub.ThreadId;import com.centralsoft.pub.dao.SysLogDAO;import com.centralsoft.webservice.pub.DateSHA;/** * DAO层AOP拦截器，实现记录用户操作过的所有方法和参数，并实现DAO层缓存 * * @author Administrator * */@Aspect@Componentpublic class AspectAutoDAOBean { @Autowired @Qualifier("CacheService") private CacheService memcache; @Autowired @Qualifier("SysLogDAO") private SysLogDAO SysLogDAO; @Around("execution(* com.centralsoft.*.dao.Zr*DAO.*(..))") public Object before(ProceedingJoinPoint joinPoint) throws Throwable { // 获取请求事务ID信息 ThreadId threadId = new ThreadBean().getThreadId(); // 调用方法名称 String methodName = joinPoint.getSignature().getName(); // 调用参数 Object[] args = joinPoint.getArgs(); Object object = null; // 数据库更新操作日志 if (Pattern.matches("(save|insert|add|delete|remove|del|update)[\\S]*", methodName)) { if (threadId != null && threadId.getTransactionalId() != null) { // 获取执行请求事务ID String transactionalId = threadId.getTransactionalId(); // 获取执行请求用户ID String userId = threadId.getUserId(); SysLogDetail sysLogDetail = new SysLogDetail(); sysLogDetail.setXh(transactionalId); sysLogDetail.setUserId(userId); sysLogDetail.setMethod(methodName); JSONObject msg = new JSONObject(); // 处理参数 for (Object temp : args) { // 获取参数类型,不同参数类型数据处理不一样 Class<? extends Object> paramClazz = temp.getClass(); String classType = paramClazz.getName(); if (classType.equals("java.lang.String")) { msg.put("key", temp); } else if (classType.equals("java.util.HashMap")) { msg.putAll((HashMap<?, ?>) temp); } else if (classType.startsWith("com.")) { try { Field[] f = paramClazz.getDeclaredFields(); for (Field field : f) { String fieldName = field.getName(); field.setAccessible(true); msg.put(fieldName, field.get(temp)); } } catch (SecurityException e) { e.printStackTrace(); } catch (IllegalArgumentException e) { e.printStackTrace(); } } } sysLogDetail.setMsg(msg.toString()); // 记录DAO数据库操作日志 SysLogDAO.insertSysLogDetail(sysLogDetail); } // 执行数据库操作 object = joinPoint.proceed(); // 数据库查询缓存 } else if (Pattern.matches("(query|load|get|select|read)[\\S]*", methodName)) { // DAO层缓存注解 MemCacheKey cacheKey = new MemCacheKey(); // 获取cache注解属性 Cache cache = null; // 获取请求方法 Class<?> cls = joinPoint.getTarget().getClass(); // 获取class中的所有方法 Method[] methods = cls.getMethods(); for (Method m : methods) { // 获取执行方法前的注解信息。 if (m.getName().equals(methodName)) { cache = m.getAnnotation(Cache.class); break; } } if (cache != null) { // 获取memcacheKey,并进行MD5加密 cacheKey = memcacheKey(cache, args); // 判断缓存服务器是否存在该可以值 if (memcache.exist(cacheKey.getMemcacheKey())) { object = memcache.get(cacheKey.getMemcacheKey()); } else { // 执行数据库操作 object = joinPoint.proceed(); // 将数据存放进缓存 if (cacheKey.getMemcacheKey() != null) { memcache.put(cacheKey.getMemcacheKey(), object == null ? "" : object, new Date(cacheKey .getTime())); } } } else { // 执行数据库操作 object = joinPoint.proceed(); } } else { // 执行数据库操作 object = joinPoint.proceed(); } return object; } /** * 获取根据注解中的key获取memcache的含参数key值 * * @param cache * @param parameterObject * @return * @author fei.zhao 2011-10-10 */ @SuppressWarnings("unchecked") private static MemCacheKey memcacheKey(Cache cache, Object[] args) { MemCacheKey tempKey = new MemCacheKey(); String key = ""; boolean flag = true; StringBuilder keyBuilder = new StringBuilder(32); // 获取注解中的key值 String cacheKey = cache.key(); Object[] cacheArgs = cacheKey.split("\\."); // 设置请求参数在args[]中的序号 // key参数进行循环遍历 for (Object s : cacheArgs) { // 判断是否是格式$,$... if (s.toString().startsWith("$")) { // 获取参数名称 String type = s.toString().substring(1); // 获取参数值 Object temp = args[0]; // 获取参数类型,不同参数类型数据处理不一样 Class<? extends Object> paramClazz = temp.getClass(); String classType = paramClazz.getName(); if (classType.equals("java.lang.String")) { keyBuilder.append(temp); } else if (classType.equals("java.util.HashMap")) { keyBuilder.append(((HashMap) temp).get(type)); } else if (classType.startsWith("com.")) { try { Field f = paramClazz.getDeclaredField(type);// 实体中字段 f.setAccessible(true);// 允许访问私有字段 keyBuilder.append(f.get(temp)); } catch (SecurityException e) { flag = false; e.printStackTrace(); } catch (NoSuchFieldException e) { flag = false; e.printStackTrace(); } catch (IllegalArgumentException e) { flag = false; e.printStackTrace(); } catch (IllegalAccessException e) { flag = false; e.printStackTrace(); } } } else { keyBuilder.append(s); } // 每个参数后面添加 “.”号分隔 keyBuilder.append("."); } if (args.length == 3) { keyBuilder.append(args[1] + ".").append(args[2]); } if (flag == true) { key = keyBuilder.toString(); tempKey.setMemcacheKey(DateSHA.shaEncrypt(key)); tempKey.setTime(cache.time()); } return tempKey; }}?