使用 logId 作为 traceId 扩展名的 XXL-JOB

一、背景

目前XXL-JOB使用自定义XxlJobHelper来做日志埋点，但是实际上很多内部框架的日志都未接入，此时定时任务出现错误，需要上执行器上查看日志信息，这时候无法查询到本次调度相关日志。

二、环境

<dependency>
	<groupId>com.xuxueli</groupId>
	<artifactId>xxl-job-core</artifactId>
	<version>2.3.0</version>
</dependency>

三、实现

为了后续方便接入链路，使用MDC传递logId

日志埋点工具类

/**
 *  扩展XXL-JOB帮助类
 *  将调度执行日志也打印到本地log文件中
 *
 *  @see com.xxl.job.core.context.XxlJobHelper
 *  @author Yu
 *  @date 2021/4/3 23:24
 */

public class XxlJobExHelper {

    public static String getLogId() {
        String path = XxlJobContext.getXxlJobContext().getJobLogFileName();

        if (Objects.isNull(path)) {
            return "";
        }

        int startIdx = path.lastIndexOf(File.separator) + 1;
        int endIdx = path.lastIndexOf(".");

        if (startIdx == 0 || endIdx == -1) {
            return "";
        }

        return path.substring(startIdx, endIdx);
    }

    /**
     * append log
     *
     * @param callInfo
     * @param appendLog
     */
    private static boolean logDetail(StackTraceElement callInfo, String appendLog) {
        XxlJobContext xxlJobContext = XxlJobContext.getXxlJobContext();
        if (xxlJobContext == null) {
            return false;
        }
        StringBuilder stringBuffer = new StringBuilder();

        stringBuffer.append(DateUtil.formatDateTime(new Date()))
                .append(" ")
                .append("["+ callInfo.getClassName() + "#" + callInfo.getMethodName() +"]")
                .append("-")
                .append("["+ callInfo.getLineNumber() +"]")
                .append("-")
                .append("["+ Thread.currentThread().getName() +"]")
                .append(" ")
                .append(appendLog != null ? appendLog : "");

        String formatAppendLog = stringBuffer.toString();

        // appendlog
        String logFileName = xxlJobContext.getJobLogFileName();

        logger.info(">>>>>>>>>>> {}", formatAppendLog);

        if (logFileName != null && logFileName.trim().length() > 0) {
            XxlJobFileAppender.appendLog(logFileName, formatAppendLog);
            return true;
        } else {
            return false;
        }
    }



}

拦截器

@Aspect
@Order(-1)
public class XxlJobInterceptor {

    @Around("@annotation(xxlJob)")
    public Object handle(ProceedingJoinPoint point, XxlJob xxlJob) throws Throwable{
        try{
            MDC.put(TraceConstant.TRACE_ID_NAME, XxlJobExHelper.getLogId());
            return point.proceed();
        } finally{
            MDC.remove(TraceConstant.TRACE_ID_NAME);
        }
    }

}

配置属性类

@Getter
@Setter
@ConfigurationProperties(prefix = "teddy.boot.xxl-job")
public class XxlJobProperties {

    private String adminAddresses;

    private String accessToken;

    private Executor executor;

    @Getter
    @Setter
    public static class Executor {
        private String appname;

        private String address;

        private String ip;

        private int port;

        private String logPath;

        private int logRetentionDays;
    }

}

自动配置类

@Configuration
@EnableConfigurationProperties(XxlJobProperties.class)
public class XxlJobAutoConfiguration {

    private static Logger log = LoggerFactory.getLogger(XxlJobAutoConfiguration.class);

    @Bean
    @ConditionalOnMissingBean
    public XxlJobSpringExecutor xxlJobExecutor(XxlJobProperties properties) {
        log.info(">>>>>>>>>>> xxl-job executor init...");
        XxlJobSpringExecutor xxlJobSpringExecutor = new XxlJobSpringExecutor();
        xxlJobSpringExecutor.setAdminAddresses(properties.getAdminAddresses());
        xxlJobSpringExecutor.setAppname(properties.getExecutor().getAppname());
        xxlJobSpringExecutor.setAddress(properties.getExecutor().getAddress());
        xxlJobSpringExecutor.setIp(properties.getExecutor().getIp());
        xxlJobSpringExecutor.setPort(properties.getExecutor().getPort());
        xxlJobSpringExecutor.setAccessToken(properties.getAccessToken());
        xxlJobSpringExecutor.setLogPath(properties.getExecutor().getLogPath());
        xxlJobSpringExecutor.setLogRetentionDays(properties.getExecutor().getLogRetentionDays());
        return xxlJobSpringExecutor;
    }

    @Bean
    @ConditionalOnMissingBean
    public XxlJobInterceptor xxlJobInterceptor() {
        return new XxlJobInterceptor();
    }

}