Spring批处理事务管理-多线程步骤
我在批处理作业中使用多线程步骤来处理来自源数据库的记录并写入目标数据库。该步骤基于块，由JdbcpagingItemReader、Processor和JDBCBathItemWriter组成。我明白，如果在步骤处理期间发生任何异常，数据库事务将回滚整个块。我想了解一下Spring batch在内部是如何管理的？由于这是多线程步骤，因此不能保证处理器和写入器在块的同一线程中执行。块可能由不同的线程处理。那么，Spring batch如何确保数据库事务正确回滚，即使不同的线程在同一个块上执行呢？
共有1个答案
您的语句不正确:“块可能由不同的线程处理。”
参考Spring批处理文档，关于多线程步骤，该步骤通过在单独的执行线程中读取、处理和写入每个项块来执行。因此，多线程是在步骤级别而不是在块级别启用的，它在自己的线程中执行每个块；因此，每个线程将“运行”一个读-进程-写组合。
上述配置的结果是，该步骤通过在单独的执行线程中读取、处理和写入每个项块（每个提交间隔）来执行。请注意，这意味着要处理的项没有固定的顺序，与单线程的情况相比，块可能包含不连续的项。除了任务执行器设置的任何限制（例如它是否由线程池支持）之外，在tasklet配置中还有一个节流限制，默认设置为4。您可能需要增加这一点，以确保线程池得到充分利用。
-
我目前正在处理一批数据，这些数据来自一个拥有数百万行的大型SQL数据库。 它在处理器中执行一些处理，包括通过带有连接的大型sql查询对从Reader检索到的行进行分组。 编写器将结果写入另一个表。 问题是此Batch存在性能问题，因为Sql选择查询需要大量时间并且步骤不会在多线程中执行。 因此，我希望在多标题中运行它们，但问题是，这些步骤通过计算具有相同类型的所有行的总数来对行进行分组。 因此，如
-
null 我更新了我的步骤并添加了一个ThreadPoolTaskExecutor，如下所示 在此之后，我的处理器将被多个线程调用，但使用相同的源数据。我还有什么需要做的吗？
-
我正在尝试使用多个处理器类在处理器步骤中处理记录。这些类可以并行工作。目前我已经编写了一个多线程步骤，其中我 设置处理器类的输入和输出行 提交给遗嘱执行人服务 获取所有未来对象并收集最终输出
-
问题内容： 我正在使用Callable接口在serviceImpl中编写多线程程序。我正在使用spring事务管理器。在DB中执行更新操作时，它会成功执行。但是更新后的数据不会反映在DB中。但是，当我运行不带多线程的程序时，它将在DB中更新。 这是我的配置 我可以转向事务管理器的另一种方法。只是我想确认这种方法是否支持多线程。所以我的问题是 spring事务管理器是否支持多线程（我的意思是仅通过声
-
Spring Transaction不支持多线程，所以我尝试在thread的run()方法中手动管理事务。但是，没用！ 我想在下面的示例中回滚每个线程的run（）方法，当其中有异常抛出时。（在以下情况下，插入到UNKNOWN_TABLE） 我的预期结果是“开始，1，3，5，结束”。 而实际结果是‘开始，1,2,3,4,5，结束’。 欢迎任何回复！谢谢！ 主要类别： 服务等级：
-
我想编写一个spring boot批处理应用程序，其中我有一个充满事件的数据库表。我想做的是有一个多线程的spring boot批处理应用程序，它将以这种方式工作： 我想有5个线程运行，每个线程将保留一个偏移量来跟踪它读取的事件，以便没有其他线程再次读取相同的事件。我想怎么做： 所以我希望能够在数据库表中为每个线程保留偏移量。有没有办法让Spring Boot环境以这种方式工作？