Java 类org.springframework.batch.core.configuration.JobRegistry 实例源码

public static void main(String[] args) throws Exception
{
  ServerConfigHelper.initLog4j("log4j-shell.xml");
  ClassPathXmlApplicationContext ctx = Util.initContext("batch/new-context.xml","batch-file-ac01.xml");
  JobLauncher launch = ctx.getBean(JobLauncher.class);
  JobExplorer epl=ctx.getBean(JobExplorer.class);
  JobRegistry reg =ctx.getBean(JobRegistry.class);
  JobOperator jop=ctx.getBean(JobOperator.class);
  System.out.println(epl.getJobNames()+" "+reg.getJobNames()+" "+jop.toString());



  for(String bn: ctx.getBeanFactory().getBeanDefinitionNames())
  {
    System.out.println(bn);
  }

  ctx.close();
}

public static void main(String[] args) throws JobExecutionAlreadyRunningException, JobRestartException,
        JobInstanceAlreadyCompleteException, JobParametersInvalidException, DuplicateJobException {
    ConfigurableApplicationContext ctx = SpringApplication.run(Application.class, args);

    Job simpleJob = ctx.getBean("simpleJob", Job.class);
    JobRegistry jobRegistry = ctx.getBean("jobRegistry", JobRegistry.class);
    jobRegistry.register(new ReferenceJobFactory(simpleJob));

    //JobRepository jobRepository = ctx.getBean("jobRepository", JobRepository.class);
    //JobInstance jobInstance = jobRepository.createJobInstance("simpleJob", new JobParameters());
    // JobParameters jobParameters = ctx.getBean("basicParameters", JobParameters.class);
    //
    //JobRegistry jobRegistry = ctx.getBean("mapJobRegistry", JobRegistry.class);
    // jobRegistry.register();
    // jobLauncher.run(job, jobParameters);
}

public JobServiceImpl(JobExplorer jobExplorer, JobOperator jobOperator, JobLauncher jobLauncher, JobRegistry jobRegistry,
                      JobRepository jobRepository) {
    this.jobExplorer = jobExplorer;
    this.jobOperator = jobOperator;
    this.jobLauncher = jobLauncher;
    this.jobRegistry = jobRegistry;
    this.jobRepository = jobRepository;
}

@Bean
public JobService jobService(JobOperator batchJobOperator,
                             JobRegistry batchJobRegistry,
                             JobExplorer jobExplorer,
                             JobLauncher jobLauncher,
                             JobRepository jobRepository) throws Exception {
    return new JobServiceImpl(jobExplorer, batchJobOperator, jobLauncher, batchJobRegistry, jobRepository);
}

@Bean
@ConditionalOnMissingBean(JobService.class)
public JobService jobService(JobOperator batchJobOperator,
                             JobRegistry batchJobRegistry,
                             JobExplorer jobExplorer,
                             JobLauncher jobLauncher,
                             JobRepository jobRepository) throws Exception {
    return new JobServiceImpl(jobExplorer, batchJobOperator, jobLauncher, batchJobRegistry, jobRepository);
}

@Bean
public AutomaticJobRegistrar jobRegistrar(JobRegistry jobRegistry) throws Exception {
    AutomaticJobRegistrar registrar = new AutomaticJobRegistrar();
    registrar.setJobLoader(new DefaultJobLoader(jobRegistry));
    for (ApplicationContextFactory factory : applicationContext.getBeansOfType(ApplicationContextFactory.class).values()) {
        registrar.addApplicationContextFactory(factory);
    }
    return registrar;
}

@Test
public void testServletConfiguration() throws Exception {
    ClassPathXmlApplicationContext parent = new ClassPathXmlApplicationContext(
            "classpath:/org/springframework/batch/admin/web/resources/webapp-config.xml");
    ClassPathXmlApplicationContext context = new ClassPathXmlApplicationContext(
            new String[] { "classpath:/org/springframework/batch/admin/web/resources/servlet-config.xml" }, parent);

    assertTrue(context.containsBean("jobRepository"));
    String[] beanNames = BeanFactoryUtils.beanNamesForTypeIncludingAncestors(context.getBeanFactory(),
            JobController.class);
    assertEquals(1, beanNames.length);

    Job job = context.getBean(JobRegistry.class).getJob("job1");
    final JobExecution jobExecution = parent.getBean(JobLauncher.class).run(job,
            new JobParametersBuilder().addString("fail", "false").toJobParameters());

    new DirectPoller<BatchStatus>(100).poll(new Callable<BatchStatus>() {
        public BatchStatus call() throws Exception {
            BatchStatus status = jobExecution.getStatus();
            if (status.isLessThan(BatchStatus.STOPPED) && status!=BatchStatus.COMPLETED) {
                return null;
            }
            return status;
        }
    }).get(2000, TimeUnit.MILLISECONDS);

    context.close();
    parent.close();

    assertEquals(BatchStatus.COMPLETED, jobExecution.getStatus());

}

public static void main(String[] args) 
{
  try
  {
    ServerConfigHelper.initConfig();
    ServerConfigHelper.initLog4j("log4j-debug.xml");
    ClassPathXmlApplicationContext ctx = Util.initContext("batch/new-context.xml");
    JobLauncher launch = ctx.getBean(JobLauncher.class);
    JobExplorer epl=ctx.getBean(JobExplorer.class);
    JobRegistry reg =ctx.getBean(JobRegistry.class);
    JobOperator jop=ctx.getBean(JobOperator.class);
    ClassPathXmlApplicationContext ctx2 = Util.initContext(false,"batch/job-context.xml","batch-file-prod.xml");
    ctx2.setParent(ctx);
    ctx2.refresh();
    Job job = ctx2.getBean(Job.class);
    JobParametersBuilder build = new JobParametersBuilder();
    build.addLong("Id", System.currentTimeMillis());



    JobExecution exec= launch.run(job,build.toJobParameters());
    System.out.println(reg.getJobNames());
    Thread.sleep(Long.MAX_VALUE);
  }
  catch (Exception e)
  {
    e.printStackTrace();
  }

}

public BatchController(final JobRegistry jobRegistry, final JobExplorer jobExplorer, final BatchOperator batchOperator,
        final JobParameterInfoRegistry parameterInfos) {
    this.jobRegistry = jobRegistry;
    this.jobExplorer = jobExplorer;
    this.batchOperator = batchOperator;
    this.parameterInfos = parameterInfos;
}

@Bean
public JobRegistry jobRegistry() {
    return new MapJobRegistry() {
        @Override
        public Set<String> getJobNames() {
            return new TreeSet<>(super.getJobNames());
        }
    };

}

public JobOperationsController(JobOperator jobOperator,
        JobExplorer jobExplorer, JobRegistry jobRegistry,
        JobRepository jobRepository, JobLauncher jobLauncher,
        JsrJobOperator jsrJobOperator) {
    super();
    this.jobOperator = jobOperator;
    this.jobExplorer = jobExplorer;
    this.jobRegistry = jobRegistry;
    this.jobRepository = jobRepository;
    this.jobLauncher = jobLauncher;
    this.jsrJobOperator = jsrJobOperator;
}

public MyOwnJobService(JobExplorer jobExplorer, JobOperator jobOperator, JobLauncher jobLauncher, JobRegistry jobRegistry, JobRepository jobRepository) {
    super(jobExplorer, jobOperator, jobLauncher, jobRegistry, jobRepository);
}

@Bean
public JobService jobService(JobOperator batchJobOperator, JobRegistry batchJobRegistry, JobExplorer jobExplorer, JobLauncher jobLauncher, JobRepository jobRepository) throws Exception {
    return new MyOwnJobService(jobExplorer, batchJobOperator, jobLauncher, batchJobRegistry, jobRepository);
}

@Bean
public JobRegistry jobRegistry() {
    return new MapJobRegistry();
}

public JobRegistry getJobRegistry() {
    return jobRegistry;
}

public void setJobRegistry(JobRegistry jobRegistry) {
    this.jobRegistry = jobRegistry;
}

@Bean
public JobRegistry jobRegistry() {
    return new MapJobRegistry();
}

@Autowired(required = false)
public void setJobRegistry(JobRegistry jobRegistry) {
    this.jobRegistry = jobRegistry;
}

@Autowired(required = false)
public void setJobRegistry(JobRegistry jobRegistry) {
    this.jobRegistry = jobRegistry;
}

@Autowired(required = false)
public void setJobRegistry(JobRegistry jobRegistry) {
    this.jobRegistry = jobRegistry;
}

public JobRegistry jobRegistry() {
    return jobRegistry;
}

@Bean
public JobRegistry jobRegistry() {
    return new MapJobRegistry();
}

@Bean
public JobRegistry jobRegistry() {
    return new MapJobRegistry();
}

public JobLauncherController(JobLauncher jobLauncher, JobRegistry jobRegistry) {
    this.jobLauncher = jobLauncher;
    this.jobRegistry = jobRegistry;
}

@Bean
public JobRegistry jobRegistry() {
    return new MapJobRegistry();
}

@Bean
public JobRegistry jobRegistry() {
    return new MapJobRegistry();
}