多次运行的Spring批处理作业

Question

@Path("/launcher")
public class LaunchController {
static String[] springConfig = { "spring/batch/jobs/job-update*.xml" };

@GET
@Path("/semjobs/{jobname}")
@Produces("application/xml")
public Response getScmJobs(@PathParam("jobname") String jobname) {
    {
        JobDetails jobdetails = new JobDetails();
        ApplicationContext context = new ClassPathXmlApplicationContext(springConfig);
    JobLauncher jobLauncher = (JobLauncher) context.getBean("jobLauncher");
    String category = EMPTY_STRING; 
    jobdetails.setJobname(jobname);
    Job job = (Job) context.getBean(jobname);
    JobExecution executionall = null;
    String inputpath = EMPTY_STRING;
                try {
                    inputpath = loadPropertiesFile(jobname);
                } catch (Exception e) {
                    LOGGER.error("Error occured while loading the properties file -> " + e);
                }
                executionall = jobLauncher.run(job, new JobParametersBuilder().addString("inputFile", inputpath).addDate("date", new Date()).toJobParameters());                
                if (executionall != null) {
        jobdetails.setJobstatus(executionall.getExitStatus().getExitCode());
                    jobdetails.setJobid(executionall.getJobId());
                }   
        } catch (Exception e) {
            LOGGER.error("Error occured while launching the job -> " + e);
        }

        return Response.status(200).entity(jobdetails).build();
    }

Spring批处理作业与flatfileitemreader（从csv读取）、processor（更新adwords api提要详细信息，对于csv文件中的每个记录（大约有40条记录），这一步大约需要40秒）和正在更新DB中记录的定制writer一起使用。

web.xml

<web-app>
    <display-name>Archetype Created Web Application</display-name>
    <!-- Auto scan REST service -->
    <context-param>
        <param-name>resteasy.scan</param-name>
        <param-value>true</param-value>
    </context-param>

    <servlet>
        <servlet-name>resteasy-servlet</servlet-name>
        <servlet-class>
            org.jboss.resteasy.plugins.server.servlet.HttpServletDispatcher
        </servlet-class>
    </servlet>

    <servlet-mapping>
        <servlet-name>resteasy-servlet</servlet-name>
        <url-pattern>/*</url-pattern>
    </servlet-mapping>
</web-app>

Answer 1

好吧，我可能有一个解决办法--但这不是一个合适的办法。

你可以在你的主要工作中添加一个工作列表，以结束你的申请

您可以在该Listner的after-job方法中调用system.exit(0)-。