PowerJob的DatabaseMonitorAspect源码流程

 更新时间:2024年01月09日 08:34:23   作者:codecraft  
这篇文章主要为大家介绍了PowerJob的DatabaseMonitorAspect源码流程解析,有需要的朋友可以借鉴参考下,希望能够有所帮助,祝大家多多进步,早日升职加薪

本文主要研究一下PowerJob的DatabaseMonitorAspect

DatabaseMonitorAspect

tech/powerjob/server/persistence/monitor/DatabaseMonitorAspect.java

@Slf4j
@Aspect
@Component
@RequiredArgsConstructor
public class DatabaseMonitorAspect {
    private final MonitorService monitorService;
    @Around("execution(* tech.powerjob.server.persistence.remote.repository..*.*(..))")
    public Object monitorCoreDB(ProceedingJoinPoint joinPoint) throws Throwable {
        return wrapperMonitor(joinPoint, DatabaseType.CORE);
    }
    @Around("execution(* tech.powerjob.server.persistence.local..*.*(..))")
    public Object monitorLocalDB(ProceedingJoinPoint joinPoint) throws Throwable {
        return wrapperMonitor(joinPoint, DatabaseType.LOCAL);
    }
    //......
}
DatabaseMonitorAspect拦截了remote和local的repository,然后执行wrapperMonitor

wrapperMonitor

private Object wrapperMonitor(ProceedingJoinPoint point, DatabaseType type) throws Throwable {
        String classNameMini = AOPUtils.parseRealClassName(point);
        final String methodName = point.getSignature().getName();
        DatabaseEvent event = new DatabaseEvent().setType(type)
                .setServiceName(classNameMini)
                .setMethodName(methodName)
                .setStatus(DatabaseEvent.Status.SUCCESS);
        long startTs = System.currentTimeMillis();
        try {
            final Object ret = point.proceed();
            event.setRows(parseEffectRows(ret));
            return ret;
        } catch (Throwable t) {
            event.setErrorMsg(t.getClass().getSimpleName()).setStatus(DatabaseEvent.Status.FAILED);
            throw t;
        } finally {
            long cost = System.currentTimeMillis() - startTs;
            monitorService.monitor(event.setCost(cost));
        }
    }
wrapperMonitor主要是构建DatabaseEvent,成功时获取effectRows,异常时获取erroMsg,最后计算耗时,执行monitorService.monitor

MonitorService

tech/powerjob/server/monitor/MonitorService.java

public interface MonitorService {
    void monitor(Event event);
}
MonitorService定义了monitor方法

PowerJobMonitorService

tech/powerjob/server/monitor/PowerJobMonitorService.java

@Slf4j
@Component
public class PowerJobMonitorService implements MonitorService {

    private final List<Monitor> monitors = Lists.newLinkedList();

    public PowerJobMonitorService(List<Monitor> monitors) {
        monitors.forEach(m -> {
            log.info("[MonitorService] register monitor: {}", m.getClass().getName());
            this.monitors.add(m);
        });
    }

    @Override
    public void monitor(Event event) {
        monitors.forEach(m -> m.record(event));
    }
}
PowerJobMonitorService是实现了MonitorService接口,其monitor方法遍历monitors,挨个执行record方法

Monitor

tech/powerjob/server/monitor/Monitor.java

public interface Monitor {

    /**
     * 全局上下文绑定 & 初始化
     */
    void init();
    /**
     * 记录监控事件
     * 请注意该方法务必异步不阻塞!!!
     * @param event 事件
     */
    void record(Event event);
}
Monitor接口定义了record方法

LogMonitor

tech/powerjob/server/monitor/monitors/LogMonitor.java

@Component
public class LogMonitor implements Monitor, ServerInfoAware {
    /**
     * server 启动依赖 DB,DB会被 monitor,因此最初的几条 log serverInfo 一定为空,在此处简单防空
     */
    private ServerInfo serverInfo = new ServerInfo();
    private static final String MDC_KEY_SERVER_ID = "serverId";
    @Override
    public void init() {
    }
    @Override
    public void record(Event event) {
        MDC.put(MDC_KEY_SERVER_ID, String.valueOf(serverInfo.getId()));
        LoggerFactory.getLogger(event.type()).info(event.message());
    }
    @Override
    public void setServerInfo(ServerInfo serverInfo) {
        this.serverInfo = serverInfo;
    }
}
LogMonitor实现了Monitor, ServerInfoAware接口,其record方法通过logger打印event的message

小结

DatabaseMonitorAspect拦截了remote和local的repository,然后执行wrapperMonitor;wrapperMonitor主要是构建DatabaseEvent,成功时获取effectRows,异常时获取erroMsg,最后计算耗时,执行monitorService.monitor;LogMonitor的record方法通过logger打印event的message。

以上就是PowerJob DatabaseMonitorAspect源码流程的详细内容,更多关于PowerJob DatabaseMonitorAspect的资料请关注脚本之家其它相关文章!

相关文章

  • SpringCloud OpenFeign 服务调用传递 token的场景分析

    SpringCloud OpenFeign 服务调用传递 token的场景分析

    这篇文章主要介绍了SpringCloud OpenFeign 服务调用传递 token的场景分析,本篇文章简单介绍 OpenFeign 调用传递 header ,以及多线程环境下可能会出现的问题,其中涉及到 ThreadLocal 的相关知识,需要的朋友可以参考下
    2022-07-07
  • SpringBoot使用SOFA-Lookout监控的方法

    SpringBoot使用SOFA-Lookout监控的方法

    本文介绍SpringBoot使用蚂蚁金服SOFA-Lookout配合Prometheus进行监控,小编觉得挺不错的,现在分享给大家,也给大家做个参考。一起跟随小编过来看看吧
    2019-03-03
  • java调用chatgpt接口来实现专属于自己的人工智能助手

    java调用chatgpt接口来实现专属于自己的人工智能助手

    这篇文章主要介绍了用java来调用chatget的接口,实现自己的聊天机器人,对人工智能感兴趣的小伙伴可以参考阅读
    2023-03-03
  • spring强行注入和引用实例解析

    spring强行注入和引用实例解析

    这篇文章主要介绍了spring强行注入和引用实例解析,文中通过示例代码介绍的非常详细,对大家的学习或者工作具有一定的参考学习价值,需要的朋友可以参考下
    2019-09-09
  • Java8新特性之Lambda表达式浅析

    Java8新特性之Lambda表达式浅析

    这篇文章主要介绍了Java8新特性之Lambda表达式,本文着重讲解了Lambda表达式的语法部份,需要的朋友可以参考下
    2014-06-06
  • Java8 stream流的map()方法你会使用了吗

    Java8 stream流的map()方法你会使用了吗

    在日常的开发工作中经常碰到要处理list中数据的问题。本文主要带大家了解下Java8 stream流中map()方法的使用,感兴趣的小伙伴可以跟随小编一起学习一下
    2022-12-12
  • Java数据脱敏实现的方法总结

    Java数据脱敏实现的方法总结

    数据脱敏,指的是对某些敏感信息通过脱敏规则进行数据的变形,实现敏感隐私数据的可靠保护,本文主要是对后端数据脱敏实现的简单总结,希望对大家有所帮助
    2023-07-07
  • java Random.nextInt()方法的具体使用

    java Random.nextInt()方法的具体使用

    这篇文章主要介绍了java Random.nextInt()方法的具体使用,文中通过示例代码介绍的非常详细,对大家的学习或者工作具有一定的参考学习价值,需要的朋友们下面随着小编来一起学习学习吧
    2020-07-07
  • Java分页工具类及其使用(示例分享)

    Java分页工具类及其使用(示例分享)

    本篇文章主要分享了Java分页工具类及其使用的示例代码,具有一定的参考价值,下面跟着小编一起来看下吧
    2017-01-01
  • Java在创建文件时指定编码的实现方法

    Java在创建文件时指定编码的实现方法

    本文主要介绍了Java在创建文件时指定编码的实现方法,文中通过示例代码介绍的非常详细,对大家的学习或者工作具有一定的参考学习价值,需要的朋友们下面随着小编来一起学习学习吧
    2022-07-07

最新评论