面向切面编程（注解式）---实现请求，返回日志的自动打印

 

 

面向切面编程（注解式）---实现请求，返回日志的自动打印

 

 

Pointcut  切点  用方法作为一系列要准备植入地的别名  （所有的方法路径就是切面）

 

Around  Before  AfterReturning  通知织入到某些切点--此时的切点就用这个方法别名了

 

 

 

 

示例：

 

 

配置文件：

 

 

 

<!-- 启动对@AspectJ注解的支持  -->

    <aop:aspectj-autoproxy proxy-target-class="true"/>

 

 

@Component

@Aspect

public class LogAopAspect {

 

 //execution  切面的路径表达方式，@within  切面的注解表达方式

  @Pointcut("execution(* com.houbank.incoming.web.controller..*(..)) and  @within(org.springframework.web.bind.annotation.Controller)")

    private void anyAcesssAndResponseMethdod() {

    }

 

    @Autowired

    private HttpServletRequest request;

 

    @Around("anyAcesssAndResponseMethdod()")

    public Object notifyLog(ProceedingJoinPoint joinPoint) throws Throwable {

 

}

 

 

 

 

}

 

 

 又如：

 

@Component

@Aspect

public class MonitorAdvise {

 

@Pointcut("@within(org.springframework.web.bind.annotation.RestController)")

public void apiMethod() {

}

 

@Pointcut("execution(* com.houbank.bank.*.service.*.*(..)))")

public void serviceMethod() {

}

 

@Around("apiMethod() || serviceMethod()")

@Monitor

public Object aroundExecuteApiMethod(ProceedingJoinPoint pJoinPoint) throws Throwable {

return MethodInvocationAspect.aspectMonitorAnnotation(pJoinPoint);

}

 

}

 

 

================切面也可传参数============

 

 

package com.houbank.xloan.core.db;

 

import org.apache.commons.lang3.StringUtils;

import org.apache.commons.logging.Log;

import org.apache.commons.logging.LogFactory;

import org.aspectj.lang.ProceedingJoinPoint;

import org.aspectj.lang.annotation.Around;

import org.aspectj.lang.annotation.Aspect;

import org.springframework.core.annotation.Order;

import org.springframework.stereotype.Component;

 

@Component

@Aspect

@Order(1)

// order设置为1.保证在配置@Transactional时，优于事务进行切面

public class MultipleDataSourceAspectAdvice {

 

private Log logger = LogFactory.getLog(MultipleDataSourceAspectAdvice.class);

 

// 所有service接口的

@Around("@annotation(dbRoute) &amp;&amp;execution(* com.houbank.xloan.api.service.*.*(..))")

public Object doAround(ProceedingJoinPoint point, DbRoute dbRoute)

throws Throwable {

Object retVal = null;

try {

 

Object target = point.getTarget();

String method = point.getSignature().getName();

Class<?> classz = target.getClass();

// 打印log

if (logger.isDebugEnabled()) {

logger.debug(String

.format("class %s,method %s", classz, method));

}

// 设置路由数据源

if (dbRoute != null && StringUtils.isNotEmpty(dbRoute.value().getValue())) {

DbContextHolder.setDataSourceType(dbRoute.value().getValue());

}

 

retVal = point.proceed();

 

} catch (Exception e) {

// e.printStackTrace();

throw e;// 确保抛出异常

} finally {

// 环绕通知后,恢复数据源为默认

DbContextHolder.setDataSourceType(DbEnum.DEFAULT_DATA_SOURCE);

}

return retVal;

}

}