如何解决我如何找到线程在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 \”!
版权声明:本文内容由互联网用户自发贡献,该文观点与技术仅代表作者本人。本站仅提供信息存储空间服务,不拥有所有权,不承担相关法律责任。如发现本站有涉嫌侵权/违法违规的内容, 请发送邮件至 dio@foxmail.com 举报,一经查实,本站将立刻删除。