JSON 项读取器和写入器
Spring Batch 提供对以下格式的 JSON 资源读取和写入的支持:
[
{
"isin": "123",
"quantity": 1,
"price": 1.2,
"customer": "foo"
},
{
"isin": "456",
"quantity": 2,
"price": 1.4,
"customer": "bar"
}
]
假设 JSON 资源是一个对应于各个条目的 JSON 对象数组。Spring Batch 不绑定于任何特定的 JSON 库。
JsonItemReader
JsonItemReader 将 JSON 解析和绑定委托给 org.springframework.batch.infrastructure.item.json.JsonObjectReader 接口的实现。该接口旨在通过使用流式 API 分块读取 JSON 对象来实现。目前提供了两种实现:
要能够处理 JSON 记录,需要以下内容:
-
Resource: 一个 Spring 资源,代表要读取的 JSON 文件。 -
JsonObjectReader:一个用于解析并将 JSON 对象绑定到条目的 JSON 对象读取器
以下示例展示了如何定义一个与之前的 JSON 资源 org/springframework/batch/infrastructure/item/json/trades.json 配合使用的 JsonItemReader,以及一个基于 Jackson 的 JsonObjectReader:
@Bean
public JsonItemReader<Trade> jsonItemReader() {
return new JsonItemReaderBuilder<Trade>()
.jsonObjectReader(new JacksonJsonObjectReader<>(Trade.class))
.resource(new ClassPathResource("trades.json"))
.name("tradeJsonItemReader")
.build();
}
JsonFileItemWriter
JsonFileItemWriter 将项的编组委托给 org.springframework.batch.infrastructure.item.json.JsonObjectMarshaller 接口。该接口的契约是接收一个对象并将其编组为 JSON String。
目前提供了两种实现:
要能够写入 JSON 记录,需要以下内容:
-
Resource: 一个 SpringResource,代表要写入的 JSON 文件 -
JsonObjectMarshaller: 一个将对象序列化为 JSON 格式的 JSON 对象编组器
以下示例展示了如何定义一个 JsonFileItemWriter:
@Bean
public JsonFileItemWriter<Trade> jsonFileItemWriter() {
return new JsonFileItemWriterBuilder<Trade>()
.jsonObjectMarshaller(new JacksonJsonObjectMarshaller<>())
.resource(new ClassPathResource("trades.json"))
.name("tradeJsonFileItemWriter")
.build();
}