代碼
@Aspect
@Component
public class OnsListenerConsumeAspect {
private static final Logger logger = LoggerFactory.getLogger(OnsListenerConsumeAspect.class);
@Pointcut("execution(public * com.aliyun.openservices.ons.api.MessageListener.consume(..))")
public void consumeCut(){
}
@Before(value = "consumeCut()")
public void beforeConsume(JoinPoint joinPoint){
try {
Object[] args = joinPoint.getArgs();
Message message = (Message) args[0];
String traceId = message.getUserProperties(TraceIdentity.HEADER_TRACE_ID);
TraceIdentity identity = new TraceIdentity();
identity.setTraceId(traceId);
identity.setFrom("goods-center");
identity.setFromType("mq-consume");
MDC.put(TraceIdentity.HEADER_TRACE_ID, identity.getTraceId());
MDC.put(TraceIdentity.HEADER_TRACE_SPAN_ID, String.valueOf(identity.getTraceSpanId()));
MDC.put(TraceIdentity.HEADER_TRACE_STORE_ID, String.valueOf(identity.getTraceStoreId()));
MDC.put(TraceIdentity.HEADER_FROM, identity.getFrom());
MDC.put(TraceIdentity.HEADER_FROM_TYPE, identity.getFromType());
ThreadContext.setTraceIdentity(identity);
} catch (Throwable e) {
logger.error("OnsListenerConsumeAspect[before_failed], cause by:{}", e);
}
}
@After(value = "consumeCut()")
public void afterConsume(){
ThreadContext.removeContext();
}
問題記錄
確認(rèn)自己的依賴配置,創(chuàng)建的切面類,切入點和方法都沒問題,但是切面類就是不生效,代碼不執(zhí)行,最后重新創(chuàng)建切面類文件解決。
springBoot 使用 @Aspect 不能用 idea創(chuàng)建Aspect類,創(chuàng)建完之后改為class 也不行,要刪除文件重新創(chuàng)建class文件