com.dangdang.ddframe.job.exception.JobConfigurationException: Job conflict with register center.
The job 'DownloadReconcileTask' in register center's class is 'cn.appblog.mall.pay.job.alipay.task.DownloadReconcileTask', your job class is 'cn.appblog.mall.pay.job.wechatpay.task.DownloadReconcileTask'
原因:注入的
SimpleJobBean名称相同的话,路径不能冲突
@Configuration
public class MyJobConfig {
@Resource
private ZookeeperRegistryCenter regCenter;
@Bean
public SimpleJob simpleJob() {
return new DownloadReconcileTask(); //Bean名称相同,路径冲突
}
@Bean(initMethod = "init")
public JobScheduler simpleJobScheduler(final SimpleJob simpleJob, @Value("${downloadReconcileJob.cron}") final String cron,
@Value("${downloadReconcileJob.shardingTotalCount}") final int shardingTotalCount,
@Value("${downloadReconcileJob.shardingItemParameters}") final String shardingItemParameters,
@Value("${downloadReconcileJob.description}") final String description) {
return new SpringJobScheduler(simpleJob, regCenter, getLiteJobConfiguration(simpleJob.getClass(), cron, shardingTotalCount, shardingItemParameters, description));
}
private LiteJobConfiguration getLiteJobConfiguration(final Class<? extends SimpleJob> jobClass, final String cron, final int shardingTotalCount, final String shardingItemParameters, final String description) {
return LiteJobConfiguration.newBuilder(new SimpleJobConfiguration(JobCoreConfiguration.newBuilder(
jobClass.getSimpleName(), cron, shardingTotalCount).shardingItemParameters(shardingItemParameters).description(description).build(), jobClass.getCanonicalName())).overwrite(true).build();
}
}