当前位置:首页 > 开发 > 编程语言 > Java > 正文

AspectJ+Javasist记录日志

发表于: 2015-07-16   作者:kane_xie   来源:转载   浏览:
摘要: 在项目中碰到这样一个需求,对一个服务类的每一个方法,在方法开始和结束的时候分别记录一条日志,内容包括方法名,参数名+参数值以及方法执行的时间。   @Override public String get(String key) { // long start = System.currentTimeMillis(); // System.out.println("Be

在项目中碰到这样一个需求,对一个服务类的每一个方法,在方法开始和结束的时候分别记录一条日志,内容包括方法名,参数名+参数值以及方法执行的时间。

 

@Override
public String get(String key) {
//	long start = System.currentTimeMillis();
//	System.out.println("Begin Method = get, Args = [key=" + key + "]");
	String value = props.getProperty(key);
//	System.out.println("End Method = get, Args = [key=" + key + "], Cost=" + (System.currentTimeMillis() - start)+ "ms");
	return value;
}

 以上注释的代码能够满足要求,但是如果类中的方法比较多得时候,会有大量的冗余代码,不利于维护。这个时候可以用AspectJ实现日志代码的嵌入,但是JointPoint只能拿到参数值,无法拿到参数名。因此考虑用Javasist在初始化的时候先把参数名保存到内存中。以下是代码:

 

 

服务实现类(接口略):

 

package test;

import java.util.Properties;

public class ServiceImpl implements Service {
	private Properties props = new Properties();

	@Override
	public String get(String key) {
		return props.getProperty(key);
	}

	@Override
	public void put(String key, String value) {
		props.put(key, value);
	}

	@Override
	public void putAll(Properties props) {
		this.props.putAll(props);
	}
}

 

 

Aspect类:

 

package test;

import java.util.Map;

import javassist.ClassClassPath;
import javassist.ClassPool;
import javassist.CtClass;
import javassist.CtMethod;
import javassist.Modifier;
import javassist.NotFoundException;
import javassist.bytecode.CodeAttribute;
import javassist.bytecode.LocalVariableAttribute;
import javassist.bytecode.MethodInfo;

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 com.google.common.collect.Maps;

@Aspect
public class LogHelper {
	final static private Logger logger = Logger.getLogger(ServiceImpl.class);
	private static final String DELIMITER = " | ";

	private Map<String, String[]> paraMap = Maps.newHashMap();

	public void init() throws NotFoundException {
		reflectGetParamName(ServiceImpl.class);
	}

	@Pointcut("execution(* (test.*+).*(..))")
	public void aspectjMethod() {
	}

	@Around("aspectjMethod()")
	public Object around(ProceedingJoinPoint call) throws Throwable {
		long startTime = System.nanoTime();
		String methodName = call.getSignature().getName();
		String className = call.getTarget().getClass().getSimpleName();
		Object[] args = call.getArgs();
		StringBuilder begin = new StringBuilder("Begin ").append("Method=").append(methodName).append(", Args=[")
				.append(argsToString(className, methodName, args)).append("]");
		logger.info(begin);

		Object result = call.proceed(args);
		long costTime = (System.nanoTime() - startTime) / 1000;// μs
		StringBuilder end = new StringBuilder("End ").append("Method=").append(methodName).append(", Args=[")
				.append(argsToString(className, methodName, args)).append("], Cost=").append(costTime).append("μs");
		logger.info(end);
		return result;
	}

	private String argsToString(String className, String methodName, Object[] args) {
		String[] paraNames = paraMap.get(className + methodName);
		boolean appendParaName = true;
		if (paraNames == null || paraNames.length != args.length) {
			logger.warn("Fail to get parameter(s)' name. ClassName = " + className + ", MethodName = " + methodName
					+ ", Expected ParaNum = " + args.length);
			appendParaName = false;
		}
		StringBuilder sb = new StringBuilder();
		for (int i = 0; i < args.length; i++) {
			Object obj = args[i];
			String paraName = paraNames[i];
			if (sb.length() != 0) {
				sb.append(DELIMITER);
			}
			if (appendParaName) {
				sb.append(paraName).append("=");
			}
			sb.append(String.valueOf(obj));
		}
		return sb.toString();
	}

	private void reflectGetParamName(Class<?> clazz) throws NotFoundException {
		ClassPool pool = ClassPool.getDefault();
		pool.insertClassPath(new ClassClassPath(clazz));
		CtClass cc = pool.get(clazz.getName());
		for (CtMethod cm : cc.getDeclaredMethods()) {
			String methodName = cm.getName();
			// 使用javaassist的反射方法获取方法的参数名
			MethodInfo methodInfo = cm.getMethodInfo();
			CodeAttribute codeAttribute = methodInfo.getCodeAttribute();
			LocalVariableAttribute attr = (LocalVariableAttribute) codeAttribute
					.getAttribute(LocalVariableAttribute.tag);
			if (attr == null) {
				throw new NotFoundException("CodeAttribute Not Found. ClassName = " + clazz.getName()
						+ ", MethodName = " + methodName);
			}
			String[] paramNames = new String[cm.getParameterTypes().length];
			int pos = Modifier.isStatic(cm.getModifiers()) ? 0 : 1;
			for (int i = 0; i < paramNames.length; i++)
				paramNames[i] = attr.variableName(i + pos);
			paraMap.put(clazz.getSimpleName() + methodName, paramNames);
		}
	}
}

 

  1. 首先初始化的时候调用reflectGetParamName,运用反射获取所有方法的参数名,并保存到paraMap中。
  2. 在方法执行的前后分别打印日志并计算执行时间,方法名和参数值从JoinPoint中获取,参数名从paraMap中获取

配置文件applicationContext.xml:

<?xml version="1.0" encoding="UTF-8"?>  
  
<beans xmlns="http://www.springframework.org/schema/beans"  
         xmlns:xsi="http://www.w3.org/2001/XMLSchema-instance"  
         xmlns:aop="http://www.springframework.org/schema/aop"  
         xmlns:tx="http://www.springframework.org/schema/tx"  
         xsi:schemaLocation="http://www.springframework.org/schema/beans http://www.springframework.org/schema/beans/spring-beans-2.0.xsd  
           http://www.springframework.org/schema/aop http://www.springframework.org/schema/aop/spring-aop-2.0.xsd  
           http://www.springframework.org/schema/tx http://www.springframework.org/schema/tx/spring-tx-2.0.xsd">  
             
    <!-- 启用AspectJ对Annotation的支持 -->         
    <aop:aspectj-autoproxy/>                  
    <bean id="service" class="test.ServiceImpl"/>  
    <bean id="aspcejHandler" class="test.LogHelper" init-method="init"/>  
</beans>  

 

测试代码:

package test;

import java.util.Properties;

import org.springframework.context.ApplicationContext;
import org.springframework.context.support.ClassPathXmlApplicationContext;

public class Test {

	public static void main(String[] args) {
		ApplicationContext context = new ClassPathXmlApplicationContext("applicationContext.xml");
		Service service = (Service) context.getBean("service");
		service.put("1", "one");
		service.putAll(new Properties());
		System.out.println(service.get("1"));
	}

}

 

测试结果:

 

15/07/16 10:19:38 INFO test.ServiceImpl: Begin Method=put, Args=[key=1 | value=one]
15/07/16 10:19:38 INFO test.ServiceImpl: End Method=put, Args=[key=1 | value=one], Cost=1539μs
15/07/16 10:19:38 INFO test.ServiceImpl: Begin Method=putAll, Args=[props={}]
15/07/16 10:19:38 INFO test.ServiceImpl: End Method=putAll, Args=[props={}], Cost=148μs
15/07/16 10:19:38 INFO test.ServiceImpl: Begin Method=get, Args=[key=1]
15/07/16 10:19:38 INFO test.ServiceImpl: End Method=get, Args=[key=1], Cost=86μs

 

AspectJ+Javasist记录日志

  • 0

    开心

    开心

  • 0

    板砖

    板砖

  • 0

    感动

    感动

  • 0

    有用

    有用

  • 0

    疑问

    疑问

  • 0

    难过

    难过

  • 0

    无聊

    无聊

  • 0

    震惊

    震惊

编辑推荐
有朋友突然问我是不是改行搞SEO了。当时听了有点惊奇,原来是blogs上文章最近都是和SEO相关的 (*^__
常在服务器端处理用户请求时.特别是针对Web应用程序.当出现异常是可以根据日志操作记录还原异常出现
为了便于分析应用程序的运行情况和BUG诊断,一般都会搞个日志输出。 当初看过一点Log4net,觉得有些
1、定义log4js服务类,用于初始化log4javascript相关参数 log4jsService.js //启用javascript 日志
一、java日志组件 1、common-logging common-logging是apache提供的一个通用的日志接口。用户可以自
一、java日志组件 1、common-logging common-logging是apache提供的一个通用的日志接口。用户可以自
日志 在开发过程中,众所周知,日志记录调试的关键部分,尤其是当产品发布的时候,有用户feedback一
MS SQL的日志信息/日志记录,可能对你来说,既熟悉又陌生,熟悉是因为你可能一直都在使用,查看、关
原帖地址:http://www.cnblogs.com/kerrycode/archive/2013/05/28/3104214.html MS SQL的日志信息/日
Spring AOP 系统日志记录 AOP是Aspect Oriented Programming的缩写,意思是面向方面编程,AOP实际是
版权所有 IT知识库 CopyRight © 2009-2015 IT知识库 IT610.com , All Rights Reserved. 京ICP备09083238号