定时器后骆驼重命名文件

Question

在 Camel 中，如果文件已经存在，有没有办法在设定的时间后使用 Timer 组件和 Spring 配置重命名文件？

是否只能通过调用将重命名文件的 Java 方法的 Timer 路由来实现？

所以，我有一个要从中提取数据的套接字。数据每天都在流动。正因为如此，我不只是想继续将数据路由到一个特定的文件中。

所以我的思考过程导致我在 X 段时间后重命名现有文件，并让 Netty 路由创建一个新文件，因为重命名后它不再存在。

我的路线类似于：

<route customId="true" id="socketToFileRoute">
    <from uri="netty4:tcp://localhost:9999?clientMode=true&amp;textline=true"  />
    <transform>
        <simple>${in.body}\n</simple>
    </transform>
    <to uri="file://data?fileName=socketData.txt&amp;charset=utf-8&amp;fileExist=Append"/>
</route>

有没有办法按照以下方式设置 Timer 路由？：

<route customId="true" id="dataFileRenamer">
    <from uri="timer://renameFile?fixedRate=true&amp;period=50"/>
    <to uri="file://data/socketData.txt?rename the file created in the previous route" />
</route>

Answer 1

你不需要计时器或任何复杂的东西，你应该使用toD (Dynamic To endpoint)：

<route customId="true" id="socketToFileRoute">
    <from uri="netty4:tcp://localhost:9999?clientMode=true&amp;textline=true"  />
    <transform>
        <simple>${in.body}\n</simple>
    </transform>
    <toD uri="file://data?fileName=socketData-${date:now:yyyyMMddHHmmss}.txt&amp;charset=utf-8&amp;fileExist=Append"/>
</route>

这将为每条消息动态解析端点，从而每秒或您要使用的任何时间段生成一个新文件。

Answer 2

您不能重命名文件，至少我不知道。您可以通过计时器节点使用.enrich() 语法读取现有文件的内容来丰富您的路线，然后使用新的时间戳创建一个新文件。一个粗略的例子：

.from("timer://renameFile?fixedRate=true&period=50")
.enrich("file://pathtofile?fileName=<filename>")
.to("file://pathtofile?fileName=${file:name.noext}-${date:now:yyyyMMdd-HHmmss}.${file:ext}");

类似的东西。当然，这意味着您为每个时期生成一个新文件。如果你真的想重命名，那么我想你必须创建一个处理器类并使用标准的 java API 来查看是否可以使用并重命名它。