我如何找到线程在Java中运行的哪个Quartz作业？

问题描述

| 我正在使用区分符登录其他文件。基于线程名称。它通常会产生良好的结果，但石英作业除外，这些作业都记录在文件中，名称如下： org.springframework.scheduling.quartz.SchedulerFactoryBean＃0_Worker-1.log 我希望有一个文件，它是石英作业的名称（基于它的名称），以便能够快速查找哪个文件包含作业的日志。有没有办法问石英当前线程是否与工作相关联？ 谢谢     

解决方法

最后，我通过手动指示slf4j MDC来解决它 在任务开始时，我会

try {
    MDC.put(MDC_KEY,getTaskName());

最后

    }
    finally {
        MDC.remove(MDC_KEY);
    }

因此，我只需要检查MDC中的密钥即可知道我是否在任务中。     ,您的方法意味着您必须更改所有作业类的代码（或从基本作业类继承）。但是，存在另一种方法，该方法与代码不可更改的作业兼容。 您可以创建作业侦听器，该侦听器在执行期间更改线程名称（如下面的示例所示）或设置MDC（如您的示例所示），然后通过Scheduler.addJobListener（）注册它，或通过Spring进行配置。

public class RenameThreadWhenJobRunning extends JobListenerSupport {
    /**
     * Must provide two groups - for name and for number
     */
    private String parsingPattern = \"^(.+)_Worker-(\\\\d+)$\";

    /**
     * {0} - Original full name (e.q. XXX_Worker-NN)
     * {1} - XXX - original thread name
     * {2} - NN - original worker number
     * {3} - Job key (e.g. JobGroup.JobName)
     * {4} - Job group
     * {5} - Job name
     */
    private String format = \"{5}-Qz{2}\";

    public void setParsingPattern(String parsingPattern) {
        this.parsingPattern = parsingPattern;
    }

    public void setFormat(String format) {
        this.format = format;
    }

    @Override
    public String getName() {
        return RenameThreadWhenJobRunning.class.getSimpleName();
    }

    @Override
    public void jobToBeExecuted(JobExecutionContext context) {
        final String originalThreadName = currentThread().getName();
        final Matcher matcher = Pattern.compile(parsingPattern).matcher(originalThreadName);
        if (matcher.matches()) {
            final JobKey key = context.getJobDetail().getKey();
            currentThread().setName(format(format,originalThreadName,matcher.group(1),matcher.group(2),key.toString(),key.getGroup(),key.getName()
            ));
            context.put(getOriginalThreadNameContextParameter(),originalThreadName);
        }
    }

    @Override
    public void jobWasExecuted(JobExecutionContext context,JobExecutionException jobException) {
        Object originalThreadName = context.get(getOriginalThreadNameContextParameter());
        if (originalThreadName instanceof String) {
            currentThread().setName((String)originalThreadName);
        }
    }

    String getOriginalThreadNameContextParameter() {
        return getName()+\".originalThreadName\";
    }

}

    ,亚历山大·帕夫洛夫（Alexander Pavlov）的答案对我有用（尽管我对其进行了调整，以使其成为Groovy文件）。我缺少的是JobListener向调度程序的注册。 我将Alexander \的RenameThreadWhenJobRunning类的单例实例注册为Bean \'renameThreadJobListener \'。 \'quartzScheduler \'bean已经存在于我的应用程序上下文中。 由于我正在使用Grails，因此这是来自resources.groovy的代码块，可以将其移植到XML配置或基于注释的方法中：

quartzSchedulerInitializer(QuartzSchedulerInitializer) { bean ->
    bean.dependsOn = [\'quartzScheduler\',\'renameThreadJobListener\'] as String[]
    quartzScheduler = ref(\'quartzScheduler\')
    renameThreadJobListener = ref(\'renameThreadJobListener\')
}

renameThreadJobListener(RenameThreadWhenJobRunning)

然后，我创建了以下Groovy类：

import org.quartz.impl.matchers.EverythingMatcher
import org.springframework.beans.factory.InitializingBean

/**
 * At application startup,register job listeners on the QuartzScheduler bean.
 */
class QuartzSchedulerInitializer implements InitializingBean {

    def quartzScheduler
    def renameThreadJobListener

    @Override
    void afterPropertiesSet() throws Exception {
        def matcher = EverythingMatcher.allJobs()
        quartzScheduler.listenerManager.addJobListener(renameThreadJobListener,matcher)
    }
}

结果是我的工作线程名称现在看起来像\“ com.example.MyJob-Qz1 \”！