ItemReader和ItemWriter列表

Item Reader

表 1. 可用的 Item Reader
Item Reader	说明	线程安全
`AbstractItemStreamItemReader`	组合了`ItemStream`和`ItemReader`接口的抽象基类。	是
`AbstractItemCountingItemStreamItemReader`	通过计算从 `ItemReader` 返回的项目数，提供基本重启功能的抽象基类。	否
`AbstractPagingItemReader`	提供基本分页功能的抽象基类	否
`AbstractPaginatedDataItemReader`	基于 Spring Data 的分页功能提供基本分页功能的抽象基类	否
`AggregateItemReader`	将列表作为其项目提供的 `ItemReader`，存储来自注入的 `ItemReader` 的对象，直到它们准备好打包为集合。此类必须用作自定义 `ItemReader` 的包装器，该包装器可以识别记录边界。自定义读取器应通过返回对查询方法（`isHeader()` 和 `isFooter()`）响应 `true` 的 `AggregateItem` 来标记记录的开始和结束。请注意，此读取器不属于 Spring Batch 提供的读取器库，而是作为 `spring-batch-samples` 中的示例提供。	是
`AmqpItemReader`	给定 Spring `AmqpTemplate`，它提供同步接收方法。`receiveAndConvert()` 方法允许您接收 POJO 对象。	是
`KafkaItemReader`	从 Apache Kafka 主题读取消息的 `ItemReader`。可以将其配置为从同一主题的多个分区读取消息。此读取器将消息偏移量存储在执行上下文中，以支持重启功能。	否
`FlatFileItemReader`	从平面文件中读取。包括 `ItemStream` 和 `Skippable` 功能。请参阅 “FlatFileItemReader”。	否
`HibernateCursorItemReader`	从基于 HQL 查询的游标中读取。请参阅 `基于游标的 ItemReaders`。	否
`HibernatePagingItemReader`	从分页的 HQL 查询中读取。	是
`ItemReaderAdapter`	将任何类适配到 `ItemReader` 接口。	是
`JdbcCursorItemReader`	从 JDBC 上的数据库游标中读取。请参阅 “基于游标的 ItemReaders”。	否
`JdbcPagingItemReader`	给定一个 SQL 语句，对行进行分页，以便在不耗尽内存的情况下读取大型数据集。	是
`JmsItemReader`	给定一个 Spring `JmsOperations` 对象和一个 JMS 目标或目标名称以发送错误，提供通过注入的 `JmsOperations#receive()` 方法接收的项目。	是
`JpaCursorItemReader`	执行 JPQL 查询并迭代返回的结果集	否
`JpaPagingItemReader`	给定一个 JPQL 查询，对行进行分页，以便在内存不足的情况下读取大型数据集。	是
`ListItemReader`	一次提供一个列表中的项。	否
`MongoItemReader`	给定一个 `MongoOperations` 对象和一个基于 JSON 的 MongoDB 查询，提供从 `MongoOperations#find()` 方法接收的项。	是
`Neo4jItemReader`	给定一个 `Neo4jOperations` 对象和 Cyhper 查询的组件，项作为 Neo4jOperations.query 方法的结果返回。	是
`RepositoryItemReader`	给定一个 Spring Data `PagingAndSortingRepository` 对象、一个 `Sort` 和要执行的方法的名称，返回 Spring Data 存储库实现提供的项。	是
`StoredProcedureItemReader`	从数据库存储过程执行产生的数据库游标中读取。请参阅 `StoredProcedureItemReader`	否
`StaxEventItemReader`	读取 StAX。请参阅 `StaxEventItemReader`。	否
`JsonItemReader`	从 Json 文档读取项。请参阅 `JsonItemReader`。	否
`AvroItemReader`	从包含序列化 Avro 对象的资源中读取项。	否
`LdifReader`	从 LDIF 资源中读取项，并将其作为 `LdapAttributes` 返回	否
`MappingLdifReader`	从 LDIF 资源中读取项，并使用 `RecordMapper` 将其映射到域对象	否

项写入器

表 2. 可用的项写入器
项写入器	说明	线程安全
`AbstractItemStreamItemWriter`	组合`ItemStream`和`ItemWriter`接口的抽象基类。	是
`AmqpItemWriter`	给定一个 Spring `AmqpTemplate`，提供一个同步 `send` 方法。`convertAndSend(Object)` 方法允许您发送 POJO 对象。	是
`CompositeItemWriter`	将项传递给注入的 `ItemWriter` 对象 `List` 中每个项的 `write` 方法。	是
`FlatFileItemWriter`	写入平面文件。包括 `ItemStream` 和可跳过功能。请参阅 “FlatFileItemWriter”。	否
`HibernateItemWriter`	此项写入器支持 Hibernate 会话，并处理一些事务相关的工作，而非“支持 hibernate”项写入器不需要了解这些工作，然后委托给另一个项写入器来执行实际写入操作。	是
`ItemWriterAdapter`	将任何类适配到 `ItemWriter` 接口。	是
`JdbcBatchItemWriter`	如果可用，使用来自`PreparedStatement`的批处理功能，并且可以在`flush`期间采取基本步骤来找到故障。	是
`JmsItemWriter`	使用`JmsOperations`对象，通过`JmsOperations#convertAndSend()`方法将项目写入默认队列。	是
`JpaItemWriter`	此项目编写器是 JPA `EntityManager` 感知的，并且处理一些事务相关的工作，而非“JPA 感知”`ItemWriter`不需要了解，然后委托给另一个编写器执行实际写入。	是
`KafkaItemWriter`	使用`KafkaTemplate`对象，通过使用`Converter`从项目映射键，通过`KafkaTemplate#sendDefault(Object, Object)`方法将项目写入默认主题。还可以配置删除标志以将删除事件发送到主题。	否
`MimeMessageItemWriter`	使用 Spring 的`JavaMailSender`，类型为`MimeMessage`的项目作为邮件消息发送。	是
`MongoItemWriter`	给定`MongoOperations`对象，通过`MongoOperations.save(Object)`方法写入项目。实际写入会延迟到事务提交前的最后可能时刻。	是
`Neo4jItemWriter`	给定`Neo4jOperations`对象，通过`save(Object)`方法保留项目或通过`delete(Object)`删除项目，如`ItemWriter`的配置所指示。	是
`PropertyExtractingDelegatingItemWriter`	扩展`AbstractMethodInvokingDelegator`，动态创建参数。基于注入的字段名数组，通过从待处理项目中的字段中检索值（通过`SpringBeanWrapper`）来创建参数。	是
`RepositoryItemWriter`	给定 Spring Data `CrudRepository`实现，通过配置中指定的方法保存项目。	是
`StaxEventItemWriter`	使用`Marshaller`实现将每个项目转换为 XML，然后使用 StAX 将其写入 XML 文件。	否
`JsonFileItemWriter`	使用`JsonObjectMarshaller`实现将每个项目转换为 Json，然后将其写入 Json 文件。	否
`AvroItemWriter`	使用 Avro 将数据序列化到`WritableResource`	否
`ListItemWriter`	将项目写入`List`的项目编写器。	否