java - FileWritingMessageHandler 中的 APPEND_NO_FLUSH 如何工作？

Question

The default flush interval is 30000 。为什么FileWritingMessageHandler的start方法divide this interval by 3在安排之前？

我尝试使用 spring-cloud-dataflow 测试冲洗通过创建以下流来启动项目:'time |文件 --mode=APPEND_NO_FLUSH --directory=test'

预期结果:30 秒后看到文件中写入了 30 条消息。

实际结果:0 条消息被写入文件中。

Answer 1

我们必须安排刷新器比间隔更频繁地运行，否则如果我们在 00:00:30 检查，刷新可能需要 2 倍的间隔(假设您在 00:00:01 写入记录)，文件直到 00:01:00 才会刷新。

通过以间隔/3 运行冲洗器，实际间隔将在 3 到 4 次运行之间。

如果间隔为 30 秒，实际间隔将在 30 到 40 秒之间，平均为 35 秒。

为了获得更准确的结果，我们必须更频繁地运行冲洗器。

我们应该在java文档中阐明算法。

编辑

08:44:01.578 [main] DEBUG o.s.i.channel.DirectChannel - postSend (sent=true) on channel 'input', message: GenericMessage [payload=this is another test, headers={timestamp=1484919841573, id=ac106489-73ad-da18-791d-3d0ec515c567, dir=expression}]

08:44:41.509 [task-scheduler-3] DEBUG o.s.i.file.FileWritingMessageHandler - Flushed: /var/folders/rl/6ys7s69j2tqcjyvy8thdsd7m0000gp/T/dataflow-tests/expression/this.out