Spring Integration File Outbound Channel Adapter 和文件最后修改日期

Question

我正在尝试制作一个文件出站通道适配器来写入一个将上次修改日期属性设置为自定义值而不是系统当前时间的文件。

根据文档 (http://docs.spring.io/spring-integration/docs/4.3.11.RELEASE/reference/html/files.html#file-timestamps)，我应该在出站上将preserve-timestamp 属性设置为true，并将标头file_setModified 设置为消息中所需的时间戳。

反正我试了几次都没有成功。

这是一个代码 sn-p 来显示我现在在做什么：

<int:inbound-channel-adapter
    channel="msg.channel"
    expression="'Hello'">
    <int:poller fixed-delay="1000"/>
</int:inbound-channel-adapter>

<int:header-enricher
    input-channel="msg.channel"
    output-channel="msgEnriched.channel">

    <int:header
        name="file_setModified"
        expression="new Long(1473897600)"/>
</int:header-enricher>

<int-file:outbound-channel-adapter
    id="msgEnriched.channel"
    preserve-timestamp="true"
    directory="/tmp/foo"/>

这有什么问题？

（使用 Spring Integration 4.3.11）

Answer 1

如果您的payload 是File，则timestamp 值将被覆盖：

Object timestamp = requestMessage.getHeaders().get(FileHeaders.SET_MODIFIED);
...
if (payload instanceof File) {
    resultFile = handleFileMessage((File) payload, tempFile, resultFile);
    timestamp = ((File) payload).lastModified();
}
...
if (this.preserveTimestamp) {
    if (timestamp instanceof Number) {
        resultFile.setLastModified(((Number) timestamp).longValue());
    }
}

为避免这种覆盖并真正从 file_setModified 中获得收益，您应该将 File 从 <int:inbound-channel-adapter> 转换为其 InputStream：

<transformer expression="new java.io.FileInputStream(payload)"/>

在<int-file:outbound-channel-adapter>之前。

文档对此提出警告：

对于文件负载，这会将时间戳从入站文件传输到出站文件（无论是否需要副本）

更新

我刚刚测试了你的用例，我的/tmp/out 目录看起来像：

如您所见，我的所有文件都有正确的自定义上次修改。

我错过了什么？

也许1473897600（1970 年）对您的操作系统有误？

更新

好的！解析XML时preserve-timestamp未配置到目标组件的问题：https://jira.spring.io/browse/INT-4324

您的用例的解决方法如下：

<int:outbound-channel-adapter id="msgEnriched.channel">
    <bean class="org.springframework.integration.file.FileWritingMessageHandler">
        <constructor-arg value="/tmp/foo"/>
        <property name="preserveTimestamp" value="true"/>
        <property name="expectReply" value="false"/>
    </bean>
</int:outbound-channel-adapter>

而不是 <int-file:outbound-channel-adapter> 定义。