Spring批处理-多线程环境

Question

我想编写一个spring boot批处理应用程序，其中我有一个充满事件的数据库表。我想做的是有一个多线程的spring boot批处理应用程序，它将以这种方式工作：

我想有5个线程运行，每个线程将保留一个偏移量来跟踪它读取的事件，以便没有其他线程再次读取相同的事件。我想怎么做：

Thread 1 will pick up the event if eventId % 5 == 1
Thread 2 will pick up the event if eventId % 5 == 2
Thread 2 will pick up the event if eventId % 5 == 3
Thread 2 will pick up the event if eventId % 5 == 4
Thread 2 will pick up the event if eventId % 5 == 0

所以我希望能够在数据库表中为每个线程保留偏移量。有没有办法让Spring Boot环境以这种方式工作？

Answer 1

您可以根据自己的描述对表进行分区(我猜您将有5个分区)，并使用一个由5个线程的< code > TaskExecutorPartitionHandler 配置的分区步骤。有了这个设置，你将实现你所寻找的。

希望这有帮助。