FlatFileItemWriter

写出到平面文件与从文件读入存在相同的问题 必须克服。步骤必须能够在 交易方式。spring-doc.cadn.net.cn

LineAggregator

正如LineTokenizerinterface 是必需的，才能将 Item 转换为String，文件写入必须能够将多个字段聚合成一个字符串 用于写入文件。在 Spring Batch 中，这是LineAggregator，显示在 接口定义如下：spring-doc.cadn.net.cn

public interface LineAggregator<T> {

    public String aggregate(T item);

}

这LineAggregator是LineTokenizer.LineTokenizer采用String并返回一个FieldSet而LineAggregator采用item并返回一个String.spring-doc.cadn.net.cn

PassThroughLineAggregator

最基本的LineAggregatorinterface 是PassThroughLineAggregator，它假定对象已经是一个字符串，或者 它的字符串表示形式可以写入，如下面的代码所示：spring-doc.cadn.net.cn

public class PassThroughLineAggregator<T> implements LineAggregator<T> {

    public String aggregate(T item) {
        return item.toString();
    }
}

如果直接控制创建字符串 必需的，但FlatFileItemWriter，例如 transaction 和 restart 支持是必要的。spring-doc.cadn.net.cn

简化文件编写示例

现在，LineAggregatorinterface 及其最基本的实现PassThroughLineAggregator，已经定义过，基本的编写流程可以是 解释：spring-doc.cadn.net.cn

  1. 需要写入的对象被传递给LineAggregator为了获得String.spring-doc.cadn.net.cn

  2. 返回的String将写入配置文件。spring-doc.cadn.net.cn

以下摘录自FlatFileItemWriter在代码中表示：spring-doc.cadn.net.cn

public void write(T item) throws Exception {
    write(lineAggregator.aggregate(item) + LINE_SEPARATOR);
}

在 Java 中，一个简单的配置示例可能如下所示：spring-doc.cadn.net.cn

Java 配置
@Bean
public FlatFileItemWriter itemWriter() {
	return  new FlatFileItemWriterBuilder<Foo>()
           			.name("itemWriter")
           			.resource(new FileSystemResource("target/test-outputs/output.txt"))
           			.lineAggregator(new PassThroughLineAggregator<>())
           			.build();
}

在 XML 中，配置的简单示例可能如下所示：spring-doc.cadn.net.cn

XML 配置
<bean id="itemWriter" class="org.spr...FlatFileItemWriter">
    <property name="resource" value="file:target/test-outputs/output.txt" />
    <property name="lineAggregator">
        <bean class="org.spr...PassThroughLineAggregator"/>
    </property>
</bean>

FieldExtractor

前面的示例对于写入文件的最基本用途可能很有用。 但是，大多数FlatFileItemWriter有一个需要 写出，因此必须转换为一行。在文件读取中，以下内容为 必填：spring-doc.cadn.net.cn

  1. 从文件中读取一行。spring-doc.cadn.net.cn

  2. 将该行传递到LineTokenizer#tokenize()方法，为了检索FieldSet.spring-doc.cadn.net.cn

  3. 将FieldSet从分词化返回到FieldSetMapper，返回 结果ItemReader#read()方法。spring-doc.cadn.net.cn

文件写入具有类似但相反的步骤：spring-doc.cadn.net.cn

  1. 将要写入的项传递给写入器。spring-doc.cadn.net.cn

  2. 将项上的字段转换为数组。spring-doc.cadn.net.cn

  3. 将结果数组聚合为一行。spring-doc.cadn.net.cn

因为框架无法知道对象的哪些字段需要 被写出，则FieldExtractor才能完成将 item 添加到数组中，如以下接口定义所示：spring-doc.cadn.net.cn

public interface FieldExtractor<T> {

    Object[] extract(T item);

}

的FieldExtractorinterface 应从字段 中，可以在 元素或作为固定宽度线条的一部分。spring-doc.cadn.net.cn

PassThroughFieldExtractor

在许多情况下，集合（例如数组、Collection或FieldSet, 需要写出来。从这些集合类型之一中“提取”数组非常 简单。为此，请将集合转换为数组。因此，PassThroughFieldExtractor应该在此方案中使用。需要注意的是，如果 传入的对象不是一种 collection 类型，则PassThroughFieldExtractor返回仅包含要提取的项的数组。spring-doc.cadn.net.cn

BeanWrapperFieldExtractor

与BeanWrapperFieldSetMapper在文件读取部分中描述的是 通常最好配置如何将域对象转换为对象数组，而不是 而不是自己编写转换。这BeanWrapperFieldExtractor提供了这个 功能，如以下示例所示：spring-doc.cadn.net.cn

BeanWrapperFieldExtractor<Name> extractor = new BeanWrapperFieldExtractor<>();
extractor.setNames(new String[] { "first", "last", "born" });

String first = "Alan";
String last = "Turing";
int born = 1912;

Name n = new Name(first, last, born);
Object[] values = extractor.extract(n);

assertEquals(first, values[0]);
assertEquals(last, values[1]);
assertEquals(born, values[2]);

此提取器实现只有一个必需的属性：要 地图。正如BeanWrapperFieldSetMapper需要字段名称来映射FieldSet对于所提供对象上的 setter，则BeanWrapperFieldExtractor需要名字 映射到 getter 以创建对象数组。值得注意的是， names 确定数组中字段的顺序。spring-doc.cadn.net.cn

分隔文件写入示例

最基本的平面文件格式是所有字段都由分隔符分隔的格式。 这可以使用DelimitedLineAggregator.以下示例编写 输出一个简单的 domain 对象，该对象表示客户账户的信用：spring-doc.cadn.net.cn

public class CustomerCredit {

    private int id;
    private String name;
    private BigDecimal credit;

    //getters and setters removed for clarity
}

由于正在使用域对象，因此FieldExtractorinterface 以及要使用的分隔符。spring-doc.cadn.net.cn

以下示例演示如何使用FieldExtractor在 Java 中使用分隔符：spring-doc.cadn.net.cn

Java 配置
@Bean
public FlatFileItemWriter<CustomerCredit> itemWriter(Resource outputResource) throws Exception {
	BeanWrapperFieldExtractor<CustomerCredit> fieldExtractor = new BeanWrapperFieldExtractor<>();
	fieldExtractor.setNames(new String[] {"name", "credit"});
	fieldExtractor.afterPropertiesSet();

	DelimitedLineAggregator<CustomerCredit> lineAggregator = new DelimitedLineAggregator<>();
	lineAggregator.setDelimiter(",");
	lineAggregator.setFieldExtractor(fieldExtractor);

	return new FlatFileItemWriterBuilder<CustomerCredit>()
				.name("customerCreditWriter")
				.resource(outputResource)
				.lineAggregator(lineAggregator)
				.build();
}

以下示例演示如何使用FieldExtractor在 XML 中使用分隔符：spring-doc.cadn.net.cn

XML 配置
<bean id="itemWriter" class="org.springframework.batch.item.file.FlatFileItemWriter">
    <property name="resource" ref="outputResource" />
    <property name="lineAggregator">
        <bean class="org.spr...DelimitedLineAggregator">
            <property name="delimiter" value=","/>
            <property name="fieldExtractor">
                <bean class="org.spr...BeanWrapperFieldExtractor">
                    <property name="names" value="name,credit"/>
                </bean>
            </property>
        </bean>
    </property>
</bean>

在前面的示例中，BeanWrapperFieldExtractor前面已描述 chapter 用于将 name 和 credit 字段转换为CustomerCredit导入到对象中 数组，然后在每个字段之间用逗号写出。spring-doc.cadn.net.cn

也可以使用FlatFileItemWriterBuilder.DelimitedBuilder自 自动创建BeanWrapperFieldExtractor和DelimitedLineAggregator如以下示例所示：spring-doc.cadn.net.cn

Java 配置
@Bean
public FlatFileItemWriter<CustomerCredit> itemWriter(Resource outputResource) throws Exception {
	return new FlatFileItemWriterBuilder<CustomerCredit>()
				.name("customerCreditWriter")
				.resource(outputResource)
				.delimited()
				.delimiter("|")
				.names(new String[] {"name", "credit"})
				.build();
}

没有 XML 等价的 usingFlatFileItemWriterBuilder.spring-doc.cadn.net.cn

固定宽度文件写入示例

Delimited 不是平面文件格式的唯一类型。许多人喜欢使用 set width for 在字段之间划定的每一列，这通常称为“固定宽度”。 Spring Batch 在文件写入中支持此功能，使用FormatterLineAggregator.spring-doc.cadn.net.cn

使用相同的CustomerCreditdomain 对象，则可以配置为 在 Java 中遵循：spring-doc.cadn.net.cn

Java 配置
@Bean
public FlatFileItemWriter<CustomerCredit> itemWriter(Resource outputResource) throws Exception {
	BeanWrapperFieldExtractor<CustomerCredit> fieldExtractor = new BeanWrapperFieldExtractor<>();
	fieldExtractor.setNames(new String[] {"name", "credit"});
	fieldExtractor.afterPropertiesSet();

	FormatterLineAggregator<CustomerCredit> lineAggregator = new FormatterLineAggregator<>();
	lineAggregator.setFormat("%-9s%-2.0f");
	lineAggregator.setFieldExtractor(fieldExtractor);

	return new FlatFileItemWriterBuilder<CustomerCredit>()
				.name("customerCreditWriter")
				.resource(outputResource)
				.lineAggregator(lineAggregator)
				.build();
}

使用相同的CustomerCreditdomain 对象，则可以配置为 在 XML 中遵循：spring-doc.cadn.net.cn

XML 配置
<bean id="itemWriter" class="org.springframework.batch.item.file.FlatFileItemWriter">
    <property name="resource" ref="outputResource" />
    <property name="lineAggregator">
        <bean class="org.spr...FormatterLineAggregator">
            <property name="fieldExtractor">
                <bean class="org.spr...BeanWrapperFieldExtractor">
                    <property name="names" value="name,credit" />
                </bean>
            </property>
            <property name="format" value="%-9s%-2.0f" />
        </bean>
    </property>
</bean>

前面的大多数示例看起来应该很熟悉。但是，格式 property 是 new。spring-doc.cadn.net.cn

以下示例显示了 Java 中的 format 属性：spring-doc.cadn.net.cn

...
FormatterLineAggregator<CustomerCredit> lineAggregator = new FormatterLineAggregator<>();
lineAggregator.setFormat("%-9s%-2.0f");
...

以下示例显示了 XML 中的 format 属性：spring-doc.cadn.net.cn

<property name="format" value="%-9s%-2.0f" />

底层实现是使用相同的Formatter作为 Java 5 的一部分添加。Java 的Formatter基于printfC 编程的功能 语言。有关如何配置格式化程序的最详细信息，请参见 Formatter 的 Javadoc。spring-doc.cadn.net.cn

也可以使用FlatFileItemWriterBuilder.FormattedBuilder自 自动创建BeanWrapperFieldExtractor和FormatterLineAggregator如以下示例所示：spring-doc.cadn.net.cn

Java 配置
@Bean
public FlatFileItemWriter<CustomerCredit> itemWriter(Resource outputResource) throws Exception {
	return new FlatFileItemWriterBuilder<CustomerCredit>()
				.name("customerCreditWriter")
				.resource(outputResource)
				.formatted()
				.format("%-9s%-2.0f")
				.names(new String[] {"name", "credit"})
				.build();
}

处理文件创建

FlatFileItemReader与文件资源的关系非常简单。当读者 初始化后，它会打开文件（如果存在），如果不存在，则引发异常。 文件写入并不是那么简单。乍一看，它似乎很相似 应该存在 Straightforward ContractFlatFileItemWriter：如果文件已 exists，抛出一个异常，如果没有，则创建它并开始编写。然而 可能会重新启动Job可能会导致问题。在正常的重启场景中， contract is reversed：如果文件存在，则从最后一个已知 good 开始写入该文件 position 的 Position，如果没有，则引发异常。但是，如果文件名 因为这个工作总是一样的吗？在这种情况下，如果文件 存在，除非是重新启动。由于这种可能性，FlatFileItemWriter包含属性shouldDeleteIfExists.将此属性设置为 true 会导致 打开 Writer 时要删除的同名现有文件。spring-doc.cadn.net.cn