监测mysql查询时间

@Autowired
    private Tracer tracer; //用于访问Spring Cloud Sleuth跟踪信息
public Organization getOrg
            (String organizationId) {
        Span newSpan = tracer.createSpan("getOrgDBCall");//创建一个新的自定义跨度，名为getOrgDBCall
        logger.debug("In the organizationService.getOrg() call");
        try {
            return orgRepository.findById(organizationId);
        }
        finally{
          newSpan.tag("peer.service", "mysql");//将标签信息添加到跨度中，提供了将要被Zipkin捕获的服务名称
          newSpan.logEvent(org.springframework.cloud.sleuth.Span.CLIENT_RECV);//记录事件，告诉Spring Cloud Sleuth捕获调用完成的时间
          tracer.close(newSpan);//关闭跟踪，否则报错
        }
    }
1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
监测redis查询时间

private Organization checkRedisCache(String organizationId) {
       Span newSpan = tracer.createSpan("readLicensingDataFromRedis");
        try {
            return orgRedisRepo.findOrganization(organizationId);
        }
        catch (Exception ex){
            return null;
        }
        finally {
          newSpan.tag("peer.service", "redis");
          newSpan.logEvent(org.springframework.cloud.sleuth.Span.CLIENT_RECV);
          tracer.close(newSpan);
        }
    }

@Aspect
@Component
@ConditionalOnProperty(value = "spring.sleuth.enabled", matchIfMissing = false)
public class TracerServiceAspect {@Pointcut("execution(public * com.xxx.cloud.*.service.impl.*.*(..))")public void tracerLog() {}// 全局的trace对象@AutowiredTracer tracer;// 针对所有Controller层的方法的切面@Around("tracerLog()")public Object doSurround(ProceedingJoinPoint proceedingJoinPoint) throws Throwable {Span currentSpan = tracer.getCurrentSpan();String className = proceedingJoinPoint.getSignature().getDeclaringTypeName();String methodName = proceedingJoinPoint.getSignature().getName();Span newSpan = null;if (currentSpan != null) {newSpan = tracer.createSpan(methodName, currentSpan);} else {newSpan = tracer.createSpan(methodName);}newSpan.tag("className", className);newSpan.tag("methodName", methodName);Object result = null;try {// 方法的执行结果result = proceedingJoinPoint.proceed();} catch (Exception e) {newSpan.tag("error", e.getMessage());} finally {newSpan.logEvent(org.springframework.cloud.sleuth.Span.CLIENT_RECV);// 记录事件，告诉Spring Cloud Sleuth捕获调用完成的时间tracer.close(newSpan);// 关闭跟踪，否则报错}return result;}}