HttpAdvice.java 1.7 KB

1234567891011121314151617181920212223242526272829303132333435363738394041424344454647484950
  1. package com.yihu.jw.advice;
  2. import com.fasterxml.jackson.databind.ObjectMapper;
  3. import org.aspectj.lang.ProceedingJoinPoint;
  4. import org.aspectj.lang.annotation.Around;
  5. import org.aspectj.lang.annotation.Aspect;
  6. import org.slf4j.Logger;
  7. import org.slf4j.LoggerFactory;
  8. import org.springframework.beans.factory.annotation.Autowired;
  9. import org.springframework.cloud.sleuth.Tracer;
  10. import org.springframework.stereotype.Component;
  11. import org.springframework.web.context.request.RequestContextHolder;
  12. import org.springframework.web.context.request.ServletRequestAttributes;
  13. import javax.servlet.http.HttpServletRequest;
  14. /**
  15. * Created by yeshijie on 2018/9/14
  16. */
  17. @Aspect
  18. @Component
  19. public class HttpAdvice {
  20. @Autowired
  21. private Tracer tracer;
  22. @Autowired
  23. private ObjectMapper objectMapper;
  24. private Logger logger = LoggerFactory.getLogger(HttpAdvice.class);
  25. @Around("within(@org.springframework.web.bind.annotation.RestController *)")
  26. public Object process(ProceedingJoinPoint point) throws Throwable {
  27. //保存入参
  28. HttpServletRequest request = ((ServletRequestAttributes) RequestContextHolder.getRequestAttributes()).getRequest();
  29. tracer.getCurrentSpan().logEvent(objectMapper.writeValueAsString(request.getParameterMap()));
  30. //访问目标方法的参数:
  31. Object[] args = point.getArgs();
  32. Long strartTime = System.currentTimeMillis();
  33. Object returnValue = point.proceed(args);
  34. Long endTime = System.currentTimeMillis();
  35. //保存响应
  36. tracer.getCurrentSpan().logEvent(objectMapper.writeValueAsString(returnValue));
  37. //保存响应时间
  38. tracer.getCurrentSpan().logEvent("executeTime:"+(endTime - strartTime));
  39. return returnValue;
  40. }
  41. }