我如何找到线程在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 \”!     

要回复问题请先登录注册