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

@Bean
@JobScope
public Step step1(
        StepBuilderFactory stepBuilderFactory,
        DatabaseClientProvider databaseClientProvider,
        @Value("#{jobParameters['input_file_path']}") String inputFilePath,
        @Value("#{jobParameters['graph_name']}") String graphName) {
    RdfTripleItemReader<Map<String, Object>> reader = new RdfTripleItemReader<Map<String, Object>>();
    reader.setFileName(inputFilePath);

    RdfTripleItemWriter writer = new RdfTripleItemWriter(databaseClientProvider.getDatabaseClient(), graphName);

    return stepBuilderFactory.get("step1")
            .<Map<String, Object>, Map<String, Object>>chunk(10)
            .reader(reader)
            .writer(writer)
            .build();
}

/**
 * @return store for scan images
 */
@Bean
@JobScope
public Map<String, BufferedImage> scanStore() {
    return Collections.synchronizedMap(
            new HashMap<String, BufferedImage>());
}

@Bean
@JobScope 
public Step step1() {
    return stepBuilderFactory
            .get("step1")
            .<Conference, Conference> chunk(5)
            .reader(itemReader())
            .writer(itemWriter())
            .build();
}

@Bean
@JobScope
public ExampleItemReader itemReader() {
    return new ExampleItemReader();
}

/**
 * @return store for IDs of processed lists
 */
@Bean
@JobScope
public ArrayList<String> listIdsStore() {
    return new ArrayList<String>();
}

@Bean
@JobScope
public Step step2(StepBuilderFactory stepBuilderFactory) {
    ItemReader<String> reader = new ItemReader<String>() {
        int i = 0;

        @Override
        public String read() throws Exception {
            i++;
            return i == 1 ? "hello" : null;
        }
    };


    ItemWriter<String> writer = new ItemWriter<String>() {
        String someString;

        @BeforeStep
        public void beforeStep(StepExecution stepExecution) {
            JobExecution jobExecution = stepExecution.getJobExecution();
            ExecutionContext jobContext = jobExecution.getExecutionContext();
            this.someString = jobContext.getString("someKey");
        }

        @Override
        public void write(List<? extends String> items) throws Exception {
            logger.info("Step 2: " + someString);
            for (String item : items) {
                logger.info("step2: " + item);
            }
        }

    };


    return stepBuilderFactory.get("step2")
            .<String, String>chunk(10)
            .reader(reader)
            .writer(writer)
            .listener(writer)
            .build();
}

@Bean(destroyMethod = "close")
@JobScope
protected BlockingSphereClient sphereClient(
        @Value("#{jobParameters['commercetools.projectKey']}") final String projectKey,
        @Value("#{jobParameters['commercetools.clientId']}") final String clientId,
        @Value("#{jobParameters['commercetools.clientSecret']}") final String clientSecret,
        @Value("#{jobParameters['commercetools.authUrl']}") final String authUrl,
        @Value("#{jobParameters['commercetools.apiUrl']}") final String apiUrl
) throws IOException {
    final SphereClientConfig config = SphereClientConfig.of(projectKey, clientId, clientSecret, authUrl, apiUrl);
    final SphereClient asyncClient = SphereClientFactory.of().createClient(config);
    return BlockingSphereClient.of(asyncClient, 20, TimeUnit.SECONDS);
}

@Bean
@JobScope
public  ConferenceItemReader itemReader() {
    return new ConferenceItemReader(dataSource);
}