跳过spring批处理中未调用的侦听器

Question

我有一个自定义跳过管理步骤。我定义了一个跳过策略，其源代码如下：

public class CustomSkipPolicy implements SkipPolicy {

    @Override
    public boolean shouldSkip(Throwable throwable, int skipCount) throws SkipLimitExceededException {
            return true;
    }
}

我的Skip侦听器如下：

@Component
public class JoueurSkipListener implements SkipListener<Object, Object> {

    @Autowired
    private LogImportRejetRepository logImportRejetRepository;

    @Override
    public void onSkipInRead(Throwable throwable) {

        saveLogImportRejet(Optional.empty(), throwable);
    }

    @Override
    public void onSkipInWrite(Object deltaObject, Throwable throwable) {
        saveLogImportRejet(Optional.of(deltaObject), throwable);
    }

    @Override
    public void onSkipInProcess(Object deltaObject, Throwable throwable) {
        saveLogImportRejet(Optional.of(deltaObject), throwable);
    }



    private void saveLogImportRejet(Optional<Object> deltaObject, Throwable throwable){

        LogImportRejet logImportRejet = LogImportRejet.builder()
                .createTime(OffsetDateTime.now())
                .typeImport(TypeImportEnum.JOUEUR)
                .motifRejet(throwable.getLocalizedMessage())
                .ligne(deltaObject.isPresent() ? deltaObject.get().toString(): null)
                .build();
        logImportRejetRepository.save(logImportRejet);
    }

}

我的步骤定义如下：

@Bean
    public Step stepImportJoueur(@Qualifier("joueurReader") ItemReader<IJoueurFed> joueurReader, @Qualifier("joueurWriter") ItemWriter<Joueur> joueurWriter, @Qualifier("joueurProcessor") JoueurProcessor joueurProcessor,
                                 @Qualifier("joueurSkipListener")  SkipListener joueurSkipListener) {
        SimpleStepBuilder<IJoueurFed, Joueur> builder = stepBuilderFactory.get("stepImportJoueur")
                .<IJoueurFed, Joueur>chunk(chunkSize)
                .reader(joueurReader)
                .processor(joueurProcessor)
                .writer(joueurWriter)
                .faultTolerant()
                .retryLimit(retryLimit)
                .retry(ConnectTimeoutException.class)
                .retry(DeadlockLoserDataAccessException.class)
                .skipPolicy(new CustomSkipPolicy());
        return builder.listener(joueurSkipListener).build();
    }

我想跳过一个约束冲突异常。但是，不会调用侦听器或跳过策略。

Answer 1

我在数据库表中有一个唯一的约束，当试图写入数据库时会导致约束违反异常。虽然发生了异常，但步骤总是有状态完成。这就是为什么我的跳过监听器没有被调用。为了解决这个问题，我创建了一个自定义的编写器，在调用父级的写入方法后调用entityManager.flush（）。这样做后，抛出异常，并调用我的跳过监听器。我已经在这个stackoverflow线程中发布了一个代码片段：使用JPA事务进行Spring批处理错误处理