Spring批处理 - 使用块和多线程使用taskexecutor读取和写入数据库答案

【问题标题】：Spring batch - read and write to database using chunks and multi thread using taskexecutorSpring批处理 - 使用块和多线程使用taskexecutor读取和写入数据库
【发布时间】：2021-03-16 21:37:58
【问题描述】：

我的代码能够读取和写入数据库，但在此过程停止之后只有一个块。无法执行其他块。

这是错误的样子 org.springframework.dao.InvalidDataAccessResourceUsageException：意外的光标位置变化。

步骤实施

@Bean
    public Step step(StepBuilderFactory stepBuilderFactory) throws Exception {
       ThreadPoolTaskExceutor taskExcutorInstance = new ThreadPoolTaskExceutor();
       taskExcutorInstance.setCorePoolSize(10);
       taskExcutorInstance.setMaxPoolSize(10);

       return stepBuilderFactory
                .get("read from DB and Write to DB")
                .<Object, Object>chunk(1000)
                .reader(reader(null))
                .writer(writer())
                .taskExecutor(taskExcutorInstance)
                .build();
    }

对于使用 JdbcCursorItemReader 的阅读器和使用 JdbcbatchItemWriter 的编写器。我正在尝试同时读取和写入多个块

如果我需要禁用 verifyCursorPosition 我们究竟需要如何禁用它？

【问题讨论】：

标签： java multithreading jdbc spring-batch batch-processing

【解决方案1】：

JdbcCursorItemReader 扩展了 AbstractItemCountingItemStreamItemReader，即 NOT thread-safe。您可以尝试同步其read 操作（通过用SynchronizedItemStreamReader 装饰它），否则您需要使用像JdbcPagingItemReader 这样的线程安全阅读器。

【讨论】：