import org.springframework.batch.item.ItemStreamReader; //导入依赖的package包/类
public ItemStreamReader<Ticket> createReader(final Resource source) {

        final FlatFileItemReader<Ticket> reader = new FlatFileItemReader<>();
        reader.setResource(source);
        final DefaultLineMapper<Ticket> lineMapper = new DefaultLineMapper<>();
        final DelimitedLineTokenizer lineTokenizer = new DelimitedLineTokenizer();
        lineTokenizer.setNames(TICKET_FILE_CSV_FIELDS);
        lineMapper.setLineTokenizer(lineTokenizer);
        final BeanWrapperFieldSetMapper<Ticket> fieldMapper = new BeanWrapperFieldSetMapper<>();
        fieldMapper.setTargetType(Ticket.class);
        final DateFormat df = new SimpleDateFormat(DATE_FORMAT);
        final Map<Class, PropertyEditor> customEditors = Stream.of(
                new AbstractMap.SimpleEntry<>(Date.class, new CustomDateEditor(df, false)))
                .collect(Collectors.toMap(Map.Entry::getKey, Map.Entry::getValue));
        fieldMapper.setCustomEditors(customEditors);
        lineMapper.setFieldSetMapper(fieldMapper);
        reader.setLineMapper(lineMapper);
        return reader;
    }
 

import org.springframework.batch.item.ItemStreamReader; //导入依赖的package包/类
@Test(expected = FlatFileParseException.class)
public void testCreateReaderAndFailToRead() throws Exception {
    // given
    final ExecutionContext executionContext = mock(ExecutionContext.class);

    // when
    final ItemStreamReader<Ticket> reader = factory.createReader(new ClassPathResource("tickets-fail.csv"));

    try {
        reader.open(executionContext);
        System.out.println(reader.read());
    } finally {
        reader.close();
    }

    // then
}
 

import org.springframework.batch.item.ItemStreamReader; //导入依赖的package包/类
@Test
public void testCreateReaderAndReadCorrectData() throws Exception {
    // given
    final ExecutionContext executionContext = mock(ExecutionContext.class);
    final LocalDate date = LocalDate.of(2015, 12, 20);

    // when
    final ItemStreamReader<Ticket> reader = factory.createReader(new ClassPathResource("tickets.csv"));
    final Ticket ticket;

    try {
        reader.open(executionContext);
        ticket = reader.read();
    } finally {
        reader.close();
    }

    // then
    assertThat(ticket, notNullValue());
    assertThat(ticket.getTag(), equalTo("Ticket_0"));
    assertThat(ticket.getDate(), equalTo(Date.valueOf(date)));
    assertThat(ticket.getContent(), equalTo("Test ticket"));
}
 

import org.springframework.batch.item.ItemStreamReader; //导入依赖的package包/类
@Bean
@StepScope
public ItemStreamReader<Ticket> ticketReader(final TicketReaderFactory ticketReaderFactory,
                                             final @Value("file:#{jobParameters['input.file.name']}") Resource resource) {
    return new FilterItemReaderAdapter<>(ticketReaderFactory.createReader(resource), TicketPredicate.hasTodayDate());
}
 

import org.springframework.batch.item.ItemStreamReader; //导入依赖的package包/类
/**
 * @param reader          the {@link ItemStreamReader} implementation to delegate to
 * @param filterCondition Condition predicate.
 */
public FilterItemReaderAdapter(final ItemStreamReader<T> reader, final Predicate<T> filterCondition) {
    this.reader = reader;
    this.filterCondition = filterCondition;
}
 

import org.springframework.batch.item.ItemStreamReader; //导入依赖的package包/类
private SynchronizedItemStreamReader<Product> productsReader(final BlockingSphereClient sphereClient) {
    final ItemStreamReader<Product> productItemStreamReader = ItemReaderFactory.sortedByIdQueryReader(sphereClient, ProductQuery.of());
    final SynchronizedItemStreamReader<Product> objectSynchronizedItemStreamReader = new SynchronizedItemStreamReader<>();
    objectSynchronizedItemStreamReader.setDelegate(productItemStreamReader);
    return objectSynchronizedItemStreamReader;
}
 

import org.springframework.batch.item.ItemStreamReader; //导入依赖的package包/类
public MetricsTestItemReader(ItemStreamReader<Item> delegate,
		BatchMetrics businessMetrics, boolean readerTransactional) {
	this.delegate = delegate;
	this.businessMetrics = businessMetrics;
	this.readerTransactional = readerTransactional;
}
 

import org.springframework.batch.item.ItemStreamReader; //导入依赖的package包/类
/**
 * 설정파일에서 ItemReaderList에 등록한 값을  Setting
 * 
 * @param itemReaderList
 */
public void setItemReaderList(List<ItemStreamReader<?>> itemReaderList) {
	this.itemReaderList = itemReaderList;
}