路由阅读器在并行处理中多次读取记录

Question

我的 apache 骆驼路线如下：-

get("fileReaderSvc", fileReaderSvc")
.rocess(e->fileReaderSvc.init(e, ctx)
.split(body().convertToString.tokenize("/n"))
.streming()
.parallelProcessing(true)
.thread(10)
.to("direct:nextRoute")
.end();

get("nextRoute", "nextRoute")
.choice()
.when(body().startWith("HDR"))
.bean("process","processHdr")
.when(body().startsWith("REC"))
.bean("process","processRecord")
.end()

我的问题是我有一个包含 1000 多条记录的文件，其中只有一条以“HDR”开头。但是 processHdr 被多次调用。看起来同步问题。在我看来，多个线程读取相同的记录。此代码主要显示 Linux 上的问题。 请提出建议。

这里 fileReaderSvc 扩展自 FileReaderService 并且 init 和 readFile 调用 super.methods。

Answer 1

问题不是这个代码。文件移动失败触发多次读取。