跳过情况下禁用Spring批处理单件处理

Question

我有一个工作，处理项目的大块（1000个）。这些项目被封送到一个JSON有效负载中，并作为一个批处理发布到远程服务（在一个HTTP POST中所有1000个）。有时远程服务陷入困境,连接超时。我为此设置了跳过

    return steps.get("sendData")
            .<DataRecord, DataRecord> chunk(1000)
            .reader(reader())
            .processor(processor())
            .writer(writer())
            .faultTolerant()
            .skipLimit(10)
            .skip(IOException.class)
            .build();

如果一个块失败了，批处理重试这个块，但一次一个项目（为了找出是哪个项目导致了失败）但在我的情况下，没有一个项目导致了失败，这是整个块作为块成功或失败的情况，应该作为块重试（事实上，下降到单项目模式导致远程服务非常生气，它拒绝接受数据。我们不控制远程服务）。

Answer 1

让我分两个部分来讨论这个问题。首先，我将解释它的工作方式，然后我将提出一个选项来解决您的问题。

为什么要逐项重试

在您的配置中，您已经指定它是容错的。这样，当在itemwriter中抛出异常时，我们不知道是哪个项导致了异常，因此我们无法跳过/重试它。这就是为什么当我们开始跳过/重试逻辑时，我们逐项执行。

这确实消除了在列表中真正跳过单个项目的能力，但听起来这对您的用例来说是可以的。