是否可以查询 运行 Spring 批处理申请以检查工作状态?
Is it possible to query a running Spring Batch application in order to check Jobs status?
我正在开发 Spring 批处理应用程序。我将此应用程序作为 ajar 文件部署在生产 Linux 服务器上,并作为普通 jar 应用程序运行。我的 Spring 批处理应用程序已启动并且 运行,实际上我的 UpdateInfoBatch-0.0.1-SNAPSHOT.jar 似乎已启动并且 运行作为过程:
webadmin@webadmin.myserver.it [~]# ps aux | grep java
webadmin 4677 0.1 3.2 10255180 809528 ? Sl Nov17 12:10 java -jar UpdateInfoBatch-0.0.1-SNAPSHOT.jar
webadmin 5152 0.0 0.0 112812 980 pts/1 S+ 09:58 0:00 grep --color=auto java
我的应用程序包含两个使用 CRON 表达式安排在特定时间的作业定义:
/**
* This bean schedules and runs our Spring Batch job.
*/
@Component
@Profile("!test")
public class SpringBatchExampleJobLauncher {
private static final Logger LOGGER = LoggerFactory.getLogger(SpringBatchExampleJobLauncher.class);
@Autowired
@Qualifier("launcher")
private JobLauncher jobLauncher;
@Autowired
@Qualifier("updateNotaryDistrictsJob")
private Job updateNotaryDistrictsJob;
@Autowired
@Qualifier("updateNotaryListInfoJob")
private Job updateNotaryListInfoJob;
@Scheduled(cron = "${cron.expresion.runUpdateNotaryListInfoJob}")
public void runUpdateNotaryListInfoJob() {
LOGGER.info("SCHEDULED run of updateNotaryListInfoJob STARTED");
Map<String, JobParameter> confMap = new HashMap<>();
confMap.put("time", new JobParameter(System.currentTimeMillis()));
JobParameters jobParameters = new JobParameters(confMap);
try {
jobLauncher.run(updateNotaryListInfoJob, jobParameters);
}catch (Exception ex){
LOGGER.error(ex.getMessage());
}
}
@Scheduled(cron = "${cron.expresion.runUpdateNotaryDistrictJob}")
public void runUpdateNotaryDistrictsJob() {
LOGGER.info("SCHEDULED run of updateNotaryDistrictsJob STARTED");
Map<String, JobParameter> confMap = new HashMap<>();
confMap.put("time", new JobParameter(System.currentTimeMillis()));
JobParameters jobParameters = new JobParameters(confMap);
try {
jobLauncher.run(updateNotaryDistrictsJob, jobParameters);
}catch (Exception ex){
LOGGER.error(ex.getMessage());
}
}
private JobParameters newExecution() {
Map<String, JobParameter> parameters = new HashMap<>();
JobParameter parameter = new JobParameter(new Date());
parameters.put("currentTime", parameter);
return new JobParameters(parameters);
}
}
现在我想问是否有一些方法可以与这个 运行 应用程序交互,以检查在这个应用程序中定义的作业的最后执行过程中是否发生了一些错误。是否可以查询我的 运行 应用程序以询问工作状态或类似信息?
是的,您可以为此使用 Spring 批处理数据库表,请在此处查看文档:https://docs.spring.io/spring-batch/docs/current/reference/html/schema-appendix.html
我正在开发 Spring 批处理应用程序。我将此应用程序作为 ajar 文件部署在生产 Linux 服务器上,并作为普通 jar 应用程序运行。我的 Spring 批处理应用程序已启动并且 运行,实际上我的 UpdateInfoBatch-0.0.1-SNAPSHOT.jar 似乎已启动并且 运行作为过程:
webadmin@webadmin.myserver.it [~]# ps aux | grep java
webadmin 4677 0.1 3.2 10255180 809528 ? Sl Nov17 12:10 java -jar UpdateInfoBatch-0.0.1-SNAPSHOT.jar
webadmin 5152 0.0 0.0 112812 980 pts/1 S+ 09:58 0:00 grep --color=auto java
我的应用程序包含两个使用 CRON 表达式安排在特定时间的作业定义:
/**
* This bean schedules and runs our Spring Batch job.
*/
@Component
@Profile("!test")
public class SpringBatchExampleJobLauncher {
private static final Logger LOGGER = LoggerFactory.getLogger(SpringBatchExampleJobLauncher.class);
@Autowired
@Qualifier("launcher")
private JobLauncher jobLauncher;
@Autowired
@Qualifier("updateNotaryDistrictsJob")
private Job updateNotaryDistrictsJob;
@Autowired
@Qualifier("updateNotaryListInfoJob")
private Job updateNotaryListInfoJob;
@Scheduled(cron = "${cron.expresion.runUpdateNotaryListInfoJob}")
public void runUpdateNotaryListInfoJob() {
LOGGER.info("SCHEDULED run of updateNotaryListInfoJob STARTED");
Map<String, JobParameter> confMap = new HashMap<>();
confMap.put("time", new JobParameter(System.currentTimeMillis()));
JobParameters jobParameters = new JobParameters(confMap);
try {
jobLauncher.run(updateNotaryListInfoJob, jobParameters);
}catch (Exception ex){
LOGGER.error(ex.getMessage());
}
}
@Scheduled(cron = "${cron.expresion.runUpdateNotaryDistrictJob}")
public void runUpdateNotaryDistrictsJob() {
LOGGER.info("SCHEDULED run of updateNotaryDistrictsJob STARTED");
Map<String, JobParameter> confMap = new HashMap<>();
confMap.put("time", new JobParameter(System.currentTimeMillis()));
JobParameters jobParameters = new JobParameters(confMap);
try {
jobLauncher.run(updateNotaryDistrictsJob, jobParameters);
}catch (Exception ex){
LOGGER.error(ex.getMessage());
}
}
private JobParameters newExecution() {
Map<String, JobParameter> parameters = new HashMap<>();
JobParameter parameter = new JobParameter(new Date());
parameters.put("currentTime", parameter);
return new JobParameters(parameters);
}
}
现在我想问是否有一些方法可以与这个 运行 应用程序交互,以检查在这个应用程序中定义的作业的最后执行过程中是否发生了一些错误。是否可以查询我的 运行 应用程序以询问工作状态或类似信息?
是的,您可以为此使用 Spring 批处理数据库表,请在此处查看文档:https://docs.spring.io/spring-batch/docs/current/reference/html/schema-appendix.html