对于最新的稳定版本，请使用 Spring Integration 6.4.0！spring-doc.cn

写入文件

要将消息写入文件系统，可以使用 FileWritingMessageHandler。 此类可以处理以下有效负载类型：spring-doc.cn

对于 String 负载，您可以配置编码和 charset。spring-doc.cn

为了简化操作，您可以使用 XML 名称空间将 作为出站通道适配器或出站网关的一部分进行配置。FileWritingMessageHandlerspring-doc.cn

从版本 4.3 开始，您可以指定写入文件时要使用的缓冲区大小。spring-doc.cn

从版本 5.1 开始，您可以提供一个 如果使用 or 并且必须创建新文件，则会触发该 URL。 此回调接收新创建的文件以及触发该文件的消息。 例如，此回调可用于编写消息标头中定义的 CSV 标头。BiConsumer<File, Message<?>>newFileCallbackFileExistsMode.APPENDFileExistsMode.APPEND_NO_FLUSHspring-doc.cn

生成文件名

在最简单的形式中，只需要一个用于写入文件的目标目录。 要写入的文件的名称由处理程序的 FileNameGenerator 确定。 默认实现查找其键与定义为 FileHeaders.FILENAME 的常量匹配的消息标头。FileWritingMessageHandlerspring-doc.cn

或者，您可以指定要根据消息计算的表达式以生成文件名 — 例如 . 表达式的计算结果必须为 . 为方便起见，还提供了该方法，允许您显式指定其值将用作文件名的消息头。headers['myCustomHeader'] + '.something'StringDefaultFileNameGeneratorsetHeaderNamespring-doc.cn

设置完成后，将采用以下解析步骤来确定给定消息有效负载的文件名：DefaultFileNameGeneratorspring-doc.cn

  1. 根据消息评估表达式，如果结果是 非空 ，则将其用作文件名。Stringspring-doc.cn

  2. 否则，如果有效负载是 a ，请使用对象的文件名。java.io.FileFilespring-doc.cn

  3. 否则，请使用附加了 .作为文件名。msgspring-doc.cn

当您使用 XML 名称空间支持时，文件出站通道适配器和文件出站网关都支持以下互斥的配置属性：spring-doc.cn

  • filename-generator（对 implementation 的引用）FileNameGeneratorspring-doc.cn

  • filename-generator-expression（计算结果为String)spring-doc.cn

写入文件时，将使用临时文件后缀（其默认值为 ）。 在写入文件时，它会附加到文件名中。 要自定义后缀，您可以在文件出站通道适配器和文件出站网关上设置该属性。.writingtemporary-file-suffixspring-doc.cn

使用 file 时，将忽略该属性，因为数据会直接附加到文件中。APPENDmodetemporary-file-suffix

从版本 4.2.5 开始，生成的文件名（作为 result of 或 evaluation）可以与目标文件名一起表示子路径。 它像以前一样用作第二个构造函数参数。 但是，在过去，我们没有为子路径创建 （） 目录，只假设文件名。 当我们需要恢复文件系统树以匹配源目录时，这种方法非常有用，例如，解压缩存档并按原始顺序保存目标目录中的所有文件时。filename-generatorfilename-generator-expressionFile(File parent, String child)mkdirs()spring-doc.cn

指定输出目录

文件出站通道适配器和文件出站网关都提供了两个互斥的配置属性，用于指定输出目录：spring-doc.cn

Spring Integration 2.2 引入了该属性。directory-expression

使用属性directory

使用该属性时，输出目录将设置为固定值，该值在初始化时设置。 如果未指定此属性，则必须使用该属性。directoryFileWritingMessageHandlerdirectory-expressionspring-doc.cn

使用属性directory-expression

如果你想获得完整的 SPEL 支持，你可以使用该属性。 此属性接受一个 SPEL 表达式，该表达式针对正在处理的每条消息进行评估。 因此，当您动态指定输出文件目录时，您对消息的有效负载及其标头具有完全访问权限。directory-expressionspring-doc.cn

SPEL 表达式必须解析为 a 、 或 。 （后者无论如何都会被评估为 a。 此外，生成的 or 必须指向目录。 如果未指定 attribute，则必须设置 attribute。Stringjava.io.Fileorg.springframework.core.io.ResourceFileStringFiledirectory-expressiondirectoryspring-doc.cn

使用属性auto-create-directory

默认情况下，如果目标目录不存在，则会自动创建相应的目标目录和任何不存在的父目录。 要防止这种行为，可以将该属性设置为 。 此属性适用于 和 属性。auto-create-directoryfalsedirectorydirectory-expressionspring-doc.cn

使用属性 and is 时，从 Spring Integration 2.2 开始进行了以下更改：directoryauto-create-directoryfalsespring-doc.cn

现在，对正在处理的每条消息执行此检查，而不是在初始化适配器时检查目标目录是否存在。spring-doc.cn

此外，如果 is 且在消息处理之间删除了目录，则会为正在处理的每条消息重新创建目录。auto-create-directorytruespring-doc.cn

处理现有目标文件

当您写入文件并且目标文件已存在时，默认行为是覆盖该目标文件。 您可以通过在相关文件出站组件上设置属性来更改此行为。 存在以下选项：modespring-doc.cn

Spring Integration 2.2 引入了属性以及 、 和 选项。modeAPPENDFAILIGNORE
REPLACE

如果目标文件已存在，则将其覆盖。 如果未指定该属性，则这是写入文件时的默认行为。modespring-doc.cn

REPLACE_IF_MODIFIED

如果目标文件已存在，则仅当上次修改的时间戳与源文件的时间戳不同时，才会覆盖该目标文件。 对于有效负载，将有效负载时间与现有文件进行比较。 对于其他有效负载，将 （） 标头与现有文件进行比较。 如果标头缺失或具有非 a 值，则始终会替换该文件。FilelastModifiedFileHeaders.SET_MODIFIEDfile_setModifiedNumberspring-doc.cn

APPEND

此模式允许您将消息内容附加到现有文件，而不是每次都创建新文件。 请注意，此属性与该属性是互斥的，因为当它将内容附加到现有文件时，适配器不再使用临时文件。 文件在每条消息后关闭。temporary-file-suffixspring-doc.cn

APPEND_NO_FLUSH

此选项的语义与 相同，但不会刷新数据，也不会在每条消息后关闭文件。 这可以提供显著的性能，但在发生故障时有丢失数据的风险。 有关更多信息，请参阅使用 APPEND_NO_FLUSH 时刷新文件。APPENDspring-doc.cn

FAIL

如果目标文件存在，则引发 MessageHandlingException。spring-doc.cn

IGNORE

如果目标文件存在，则消息负载将被静默忽略。spring-doc.cn

使用临时文件后缀（默认值为 ）时，如果最终文件名或临时文件名存在，则此选项适用。.writingIGNORE

使用 时刷新文件APPEND_NO_FLUSH

该模式是在版本 4.3 中添加的。 使用它可以提高性能，因为文件不会在每条消息后关闭。 但是，如果发生故障，这可能会导致数据丢失。APPEND_NO_FLUSHspring-doc.cn

Spring 集成提供了几种刷新策略来减轻这种数据丢失：spring-doc.cn

  • 用。 如果文件在这段时间内未写入，则会自动刷新该文件。 这是近似值，可能到这个时间为止（平均值为 ）。flushInterval1.33x1.167xspring-doc.cn

  • 将包含正则表达式的消息发送到消息处理程序的方法。 具有与模式匹配的绝对路径名的文件将被刷新。triggerspring-doc.cn

  • 为处理程序提供自定义实现，以修改将消息发送到该方法时执行的操作。MessageFlushPredicatetriggerspring-doc.cn

  • 通过传入 custom 或 implementation 来调用处理程序的方法之一。flushIfNeededFileWritingMessageHandler.FlushPredicateFileWritingMessageHandler.MessageFlushPredicatespring-doc.cn

将为每个打开的文件调用谓词。 有关更多信息，请参阅这些接口的 Javadoc。 请注意，从版本 5.0 开始，谓词方法提供了另一个参数：当前文件的首次写入时间（如果是新的或以前的关闭）。spring-doc.cn

使用 时，间隔从最后一次写入开始。 仅当文件在时间间隔内处于空闲状态时，才会刷新该文件。 从版本 4.3.7 开始，可以将附加属性 （） 设置为 ，这意味着间隔从第一次写入以前刷新（或新）文件开始。flushIntervalflushWhenIdlefalsespring-doc.cn

文件时间戳

默认情况下，目标文件的时间戳是创建文件的时间（就地重命名保留当前时间戳除外）。 从版本 4.3 开始，您现在可以配置 （或使用 Java 配置时）。 对于有效负载，这会将时间戳从入站文件传输到出站文件（无论是否需要副本）。 对于其他负载，如果存在标头 （），则只要标头是 .lastModifiedpreserve-timestampsetPreserveTimestamp(true)FileFileHeaders.SET_MODIFIEDfile_setModifiedlastModifiedNumberspring-doc.cn

文件权限

从版本 5.0 开始，在将文件写入支持 Posix 权限的文件系统时，您可以在出站通道适配器或网关上指定这些权限。 该属性是一个整数，通常以熟悉的八进制格式提供，例如，表示所有者具有读/写权限，组具有只读权限，而其他人没有访问权限。0640spring-doc.cn

文件出站通道适配器

下面的示例配置文件出站通道适配器：spring-doc.cn

<int-file:outbound-channel-adapter id="filesOut" directory="${input.directory.property}"/>

基于命名空间的配置还支持属性。 如果设置为 ，则会在写入目标后触发删除原始源文件。 该标志的默认值为 . 以下示例显示如何将其设置为 ：delete-source-filestruefalsetruespring-doc.cn

<int-file:outbound-channel-adapter id="filesOut"
    directory="${output.directory}"
    delete-source-files="true"/>
仅当入站消息具有有效负载，或者标头值包含源实例或表示原始文件路径时，该属性才有效。delete-source-filesFileFileHeaders.ORIGINAL_FILEFileString

从版本 4.2 开始，支持 an 选项。 如果设置为 ，则在写入消息后，会向文件附加一个新行。 默认属性值为 . 以下示例演示如何使用该选项：FileWritingMessageHandlerappend-new-linetruefalseappend-new-linespring-doc.cn

<int-file:outbound-channel-adapter id="newlineAdapter"
	append-new-line="true"
    directory="${output.directory}"/>

出站网关

如果要继续根据写入的文件处理消息，可以改用 。 它的作用类似于 . 但是，在写入文件后，它还会将其作为消息的有效负载发送到回复通道。outbound-gatewayoutbound-channel-adapterspring-doc.cn

以下示例配置出站网关：spring-doc.cn

<int-file:outbound-gateway id="mover" request-channel="moveInput"
    reply-channel="output"
    directory="${output.directory}"
    mode="REPLACE" delete-source-files="true"/>

如前所述，您还可以指定 attribute，该属性定义如何处理目标文件已存在的情况的行为。 有关更多详细信息，请参阅 Dealing with Existing Destination Files。 通常，在使用文件出站网关时，结果文件将作为回复通道上的消息负载返回。modespring-doc.cn

这在指定模式时也适用。 在这种情况下，将返回预先存在的目标文件。 如果请求消息的负载是一个文件，您仍然可以通过消息标头访问该原始文件。 请参阅 FileHeaders.ORIGINAL_FILE。IGNOREspring-doc.cn

“outbound-gateway” 在您希望首先移动文件，然后通过处理管道发送文件的情况下效果很好。 在这种情况下，您可以将文件命名空间的元素连接到 ，然后将该网关的元素连接到管道的开头。inbound-channel-adapteroutbound-gatewayreply-channel

如果您有更详细的要求或需要支持其他有效负载类型作为要转换为文件内容的输入，则可以扩展 ，但更好的选择是依赖 Transformer。FileWritingMessageHandlerspring-doc.cn

使用 Java 配置进行配置

Spring 下面的 Boot 应用程序显示了如何使用 Java 配置配置入站适配器的示例：spring-doc.cn

@SpringBootApplication
@IntegrationComponentScan
public class FileWritingJavaApplication {

    public static void main(String[] args) {
        ConfigurableApplicationContext context =
                      new SpringApplicationBuilder(FileWritingJavaApplication.class)
                              .web(false)
                              .run(args);
             MyGateway gateway = context.getBean(MyGateway.class);
             gateway.writeToFile("foo.txt", new File(tmpDir.getRoot(), "fileWritingFlow"), "foo");
    }

    @Bean
    @ServiceActivator(inputChannel = "writeToFileChannel")
    public MessageHandler fileWritingMessageHandler() {
         Expression directoryExpression = new SpelExpressionParser().parseExpression("headers.directory");
         FileWritingMessageHandler handler = new FileWritingMessageHandler(directoryExpression);
         handler.setFileExistsMode(FileExistsMode.APPEND);
         return handler;
    }

    @MessagingGateway(defaultRequestChannel = "writeToFileChannel")
    public interface MyGateway {

        void writeToFile(@Header(FileHeaders.FILENAME) String fileName,
                       @Header(FileHeaders.FILENAME) File directory, String data);

    }
}

使用 Java DSL 进行配置

Spring 下面的 Boot 应用程序显示了如何使用 Java DSL 配置入站适配器的示例：spring-doc.cn

@SpringBootApplication
public class FileWritingJavaApplication {

    public static void main(String[] args) {
        ConfigurableApplicationContext context =
                 new SpringApplicationBuilder(FileWritingJavaApplication.class)
                         .web(false)
                         .run(args);
        MessageChannel fileWritingInput = context.getBean("fileWritingInput", MessageChannel.class);
        fileWritingInput.send(new GenericMessage<>("foo"));
    }

    @Bean
   	public IntegrationFlow fileWritingFlow() {
   	    return IntegrationFlow.from("fileWritingInput")
   		        .enrichHeaders(h -> h.header(FileHeaders.FILENAME, "foo.txt")
   		                  .header("directory", new File(tmpDir.getRoot(), "fileWritingFlow")))
   	            .handle(Files.outboundGateway(m -> m.getHeaders().get("directory")))
   	            .channel(MessageChannels.queue("fileWritingResultChannel"))
   	            .get();
    }

}