Apache HttpClient4.5.2配置ServiceUnavailableRetryStrategy重试时POST数据丢失问题

是的，你遇到的重试无请求体问题确实是InputStreamEntity的特性导致的：

• InputStreamEntity基于单次可读的InputStream实现，其isRepeatable()方法默认返回false，标识该实体内容不可重复读取
• 首次请求发送时，底层会读取InputStream的全部内容传输到服务端，流的读取指针会移动到末尾，无剩余数据可读取
• 重试机制触发后再次发送请求时，读取InputStreamEntity只能拿到空数据，最终表现为重试请求无请求体，触发服务端400错误。

可以根据业务场景选择以下适配方案：

方案1：替换为可重复读的实体类（推荐，适配绝大多数场景） #

如果JSON payload体积不大，内存可承载，直接将InputStreamEntity替换为StringEntity或ByteArrayEntity即可：

• 两类实体的isRepeatable()方法默认返回true，内容会缓存在内存中，每次读取都会自动重置指针，重试时可正常重复读取请求体
• 用法示例：

// 构造JSON请求实体
String jsonPayload = "{\"key\":\"value\"}";
HttpEntity entity = new StringEntity(jsonPayload, ContentType.APPLICATION_JSON);

方案2：自定义可重复读InputStreamEntity #

如果必须使用InputStream作为数据来源，可以自定义InputStreamEntity子类，提前缓存流内容实现可重复读取：

public class RepeatableInputStreamEntity extends InputStreamEntity {
    private final byte[] contentCache;

    public RepeatableInputStreamEntity(InputStream inputStream, long length) throws IOException {
        super(inputStream, length);
        // 提前读取全量流内容缓存到字节数组
        this.contentCache = inputStream.readAllBytes();
    }

    @Override
    public boolean isRepeatable() {
        return true;
    }

    @Override
    public InputStream getContent() {
        // 每次读取都返回全新的流实例，重置读取指针
        return new ByteArrayInputStream(contentCache);
    }

    @Override
    public void writeTo(OutputStream outStream) throws IOException {
        outStream.write(contentCache);
    }
}

方案3：重试前重新构造请求实体 #

如果请求体体积过大，不适合全量缓存到内存，可以修改重试逻辑，在重试触发前重新生成原始的InputStream，构造新的InputStreamEntity替换原有请求的实体即可。

内容的提问来源于stack exchange，提问作者Dyutiman Chaudhuri