|
|
@ -1,6 +1,6 @@
|
|
|
|
package com.example.serive.impl;
|
|
|
|
package com.example.serive.impl;
|
|
|
|
|
|
|
|
|
|
|
|
import com.dangdang.ddframe.job.api.simple.SimpleJob;
|
|
|
|
import com.dangdang.ddframe.job.api.ElasticJob;
|
|
|
|
import com.dangdang.ddframe.job.config.JobCoreConfiguration;
|
|
|
|
import com.dangdang.ddframe.job.config.JobCoreConfiguration;
|
|
|
|
import com.dangdang.ddframe.job.config.simple.SimpleJobConfiguration;
|
|
|
|
import com.dangdang.ddframe.job.config.simple.SimpleJobConfiguration;
|
|
|
|
import com.dangdang.ddframe.job.lite.api.strategy.impl.AverageAllocationJobShardingStrategy;
|
|
|
|
import com.dangdang.ddframe.job.lite.api.strategy.impl.AverageAllocationJobShardingStrategy;
|
|
|
@ -65,7 +65,7 @@ public class JobServiceImpl implements JobService {
|
|
|
|
.build();
|
|
|
|
.build();
|
|
|
|
try {
|
|
|
|
try {
|
|
|
|
Class<?> aClass = Class.forName(job.getJobClass());
|
|
|
|
Class<?> aClass = Class.forName(job.getJobClass());
|
|
|
|
SimpleJob simpleJob = (SimpleJob) ctx.getBean(aClass);
|
|
|
|
ElasticJob elasticJob = (ElasticJob) ctx.getBean(aClass);
|
|
|
|
// 配置数据源
|
|
|
|
// 配置数据源
|
|
|
|
// if (job.isJobEvent()) {
|
|
|
|
// if (job.isJobEvent()) {
|
|
|
|
// JobEventConfiguration jec = new JobEventRdbConfiguration(dataSource);
|
|
|
|
// JobEventConfiguration jec = new JobEventRdbConfiguration(dataSource);
|
|
|
@ -73,7 +73,8 @@ public class JobServiceImpl implements JobService {
|
|
|
|
// } else {
|
|
|
|
// } else {
|
|
|
|
// new SpringJobScheduler(elasticJob, center, ljc).init();
|
|
|
|
// new SpringJobScheduler(elasticJob, center, ljc).init();
|
|
|
|
// }
|
|
|
|
// }
|
|
|
|
new SpringJobScheduler(simpleJob, center, ljc).init();
|
|
|
|
new SpringJobScheduler(elasticJob, center, ljc).init();
|
|
|
|
|
|
|
|
|
|
|
|
} catch (Exception e) {
|
|
|
|
} catch (Exception e) {
|
|
|
|
e.printStackTrace();
|
|
|
|
e.printStackTrace();
|
|
|
|
log.error("加载任务失败,任务为 {}", job.getJobName());
|
|
|
|
log.error("加载任务失败,任务为 {}", job.getJobName());
|
|
|
@ -109,6 +110,14 @@ public class JobServiceImpl implements JobService {
|
|
|
|
}
|
|
|
|
}
|
|
|
|
}
|
|
|
|
}
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
@Override
|
|
|
|
|
|
|
|
public void resumeJob(String jobName) {
|
|
|
|
|
|
|
|
JobScheduleController jobScheduleController = JobRegistry.getInstance().getJobScheduleController(jobName);
|
|
|
|
|
|
|
|
if (jobScheduleController != null) {
|
|
|
|
|
|
|
|
jobScheduleController.resumeJob();
|
|
|
|
|
|
|
|
}
|
|
|
|
|
|
|
|
}
|
|
|
|
|
|
|
|
|
|
|
|
/**
|
|
|
|
/**
|
|
|
|
* 立刻启动作业
|
|
|
|
* 立刻启动作业
|
|
|
|
*/
|
|
|
|
*/
|
|
|
|