在 OkHttp 拦截器中，绝不能手动调用 response.body().close()，否则会导致后续调用方无法读取响应体，引发 IOException 或空响应等不可预知错误。拦截器的职责是观察、修改或重试请求/响应，而非释放资源。
在 okhttp 拦截器中，**绝不能手动调用 `response.body().close()`**，否则会导致后续调用方无法读取响应体，引发 `ioexception` 或空响应等不可预知错误。拦截器的职责是观察、修改或重试请求/响应，而非释放资源。
OkHttp 的响应资源管理遵循明确的责任分离原则：Response 及其 ResponseBody 的关闭责任完全归属于最终消费响应的业务代码（例如调用 response.body().string()、response.body().byteStream() 或 response.close() 的地方），而非中间拦截器。
你的重试拦截器逻辑本身是合理的——检测 429 Too Many Requests 后休眠并重新发起请求。但以下写法是危险且错误的：
// ❌ 错误示例：在拦截器中提前关闭响应体
if (!response.isSuccessful() && response.code() == 429) {
LOG.error("Rate limit exceeded. Waiting 20 seconds.");
Thread.sleep(20000);
response = chain.proceed(chain.request());
}
response.body().close(); // ⚠️ 绝对禁止！此行将使返回的 response 不可读
return response;一旦执行 response.body().close()，该 ResponseBody 的底层输入流即被关闭，后续任何对 response.body() 的访问（如 string()、bytes()、source()）都会抛出 IllegalStateException("closed") 或 IOException，导致上游 Flink 作业解析失败。
✅ 正确做法是：让拦截器只负责逻辑控制，不干预资源生命周期。你的原始代码（无 .close() 调用）已是合规实现：
public Response intercept(Chain chain) throws IOException {
Response response = chain.proceed(chain.request());
if (!response.isSuccessful() && response.code() == 429) {
LOG.error("Rate limit exceeded. Waiting 20 seconds.");
try {
Thread.sleep(20000);
} catch (InterruptedException e) {
Thread.currentThread().interrupt(); // ✅ 更佳实践：恢复中断状态
throw new IOException("Interrupted during rate-limit wait", e);
}
// 重试：注意——此处应使用新 request，避免复用已发送过的 request（尤其含 body）
Request retryRequest = chain.request(); // 若 request 为幂等（如无 body 或已缓存），可复用；否则建议重建
response = chain.proceed(retryRequest);
}
return response; // ✅ 正确：不关闭，交由调用方处置
}⚠️ 额外注意事项：
- 重试时的 Request 安全性：若原始请求含 RequestBody（如 JSON POST），默认 chain.request() 在首次 proceed() 后可能已被消费（OkHttp 会缓冲或标记为不可重放）。生产环境建议使用 request.newBuilder().build() 显式重建，或启用 RequestBody 的 isOneShot() 兼容机制。
- 超时与中断处理：Thread.sleep() 中捕获 InterruptedException 后，应调用 Thread.currentThread().interrupt() 恢复中断标志，确保上层能感知中断信号。
- 日志与监控：建议记录重试次数（避免无限循环），并考虑指数退避（如 2^retry * baseDelay）替代固定 20 秒，提升系统鲁棒性。
-
资源清理兜底：虽然拦截器不关闭，但业务侧必须确保响应终被消费或显式关闭。推荐使用 try-with-resources 模式：
try (Response response = client.newCall(request).execute()) { if (response.isSuccessful()) { String body = response.body().string(); // 自动关闭 body } }
总结：OkHttp 拦截器是“透明管道”，不是“资源管家”。关闭 ResponseBody 是下游义务，强行越权关闭将破坏链式调用契约。保持拦截器轻量、无副作用，把资源管理权完整交给最终消费者，才是符合 OkHttp 设计哲学的健壮实践。
