Apache camel 中 Seda 的并发消费者

Question

我有一条如下所述的路线。该路由定期轮询一个目录并读取一个大尺寸的 .csv 文件。然后它将文件分成 1000 行的块并将其发送到 seda queue(firstQueue)。我在这个 seda 队列上有 15 个并发消费者。

route.split().tokenize("\n", 1000).streaming().to("seda:firstQueue?concurrentConsumers=15").process(myProcessor).to("seda:secondQueue?concurrentConsumers=15").process(anotherMyProcessor);

1) 15 个并发消费者是什么意思 - 是否意味着 15 个线程从 seda 读取数据并将其传递给 myProcessor 的一个实例？还是创建了 15 个单独的 myProcessor 实例，每个实例都作用于同一数据副本？注意myProcessor是一个单例，如果我把它改成原型会发生什么。

2) 是否有可能任何两个或多个线程选择相同的数据并将其传递给myProcessor？还是保证不会有两个线程拥有相同的数据？

感谢您的快速响应。谢谢！

Answer 1

我的骆驼有点生锈了，但我很确定

1. 有 15 个线程正在运行。每个将从队列中读取一条消息并调用 myProcessor。我的处理器只有一个实例，因此您需要确保它是线程安全的。我从未尝试过它，但我不相信将范围更改为原型会产生任何影响。

2. 两个线程不应从队列中获取相同的消息。在正常运行中，每条消息应该只处理一次。但是，在某些错误情况下，我会导致同一条消息被处理两次，最明显的情况是您在处理文件的过程中重新启动了应用程序。