使用Kubernetes Client更新ConfigMap时偶发异常求助

核心问题点 #

你的代码存在两个关键问题：

1. 逻辑不符合需求：当前代码直接新建ConfigMapBuilder，仅添加新条目就执行createOrReplace，会覆盖原有ConfigMap的所有数据，完全达不到「保留原有条目新增」的目的。
2. 偶发IO异常触发场景：底层的java.io.IOException: closed是OkHttp的HTTP/2连接被意外关闭导致的，常见触发条件：
   • K8s API Server与客户端之间的网络波动（如负载均衡超时、临时网络中断）
   • OkHttp连接池配置不合理，连接被提前回收后仍被复用
   • 并发更新冲突时，API端提前关闭连接
   • fabric8客户端与OkHttp版本组合存在已知兼容性问题（你使用的5.12.2版本较旧）

具体解决步骤 #

1. 修正ConfigMap更新逻辑（必做） #

要保留原有条目新增数据，必须先获取现有ConfigMap，再基于它修改，而不是新建空的Builder：

KubernetesClient client = new DefaultKubernetesClient(new ConfigBuilder().build());
String deployConfigName = deploy_config; // 变量名规范调整

// 获取现有ConfigMap，不存在则初始化空对象
ConfigMap existingConfigMap = client.configMaps().withName(deployConfigName).get();
ConfigMapBuilder configMapBuilder;
if (existingConfigMap != null) {
    // 基于现有ConfigMap构建，保留所有原有数据
    configMapBuilder = new ConfigMapBuilder(existingConfigMap);
} else {
    // 不存在则创建新的ConfigMap
    configMapBuilder = new ConfigMapBuilder()
            .withNewMetadata()
                .withName(deployConfigName)
            .endMetadata();
}

// 添加新条目
configMapBuilder.addToData(status, status.name());

// 执行创建或替换
client.configMaps().withName(deployConfigName).createOrReplace(configMapBuilder.build());

2. 解决HTTP/2连接关闭异常 #

• 调整OkHttp连接配置：优化连接超时、连接池参数，避免连接被提前回收

// 自定义OkHttp客户端配置
OkHttpClient okHttpClient = new OkHttpClient.Builder()
        .connectTimeout(30, TimeUnit.SECONDS)
        .readTimeout(30, TimeUnit.SECONDS)
        .writeTimeout(30, TimeUnit.SECONDS)
        .connectionPool(new ConnectionPool(10, 5, TimeUnit.MINUTES)) // 调整连接池大小和存活时间
        .build();

// 传入自定义OkHttp客户端创建KubernetesClient
KubernetesClient client = new DefaultKubernetesClient(
        new ConfigBuilder().build(),
        new OkHttpClientImpl(okHttpClient)
);

• 升级fabric8客户端版本：5.12.2版本存在一些OkHttp相关的bug，升级到5.13.0及以上版本（建议使用最新稳定版），可修复部分连接异常问题。

• 使用Patch操作替代全量替换：Patch仅传输需要修改的部分，减少数据传输量，降低网络异常概率，同时避免全量替换的并发冲突：

// JSON Merge Patch方式新增数据
client.configMaps().withName(deploy_config)
        .patch(PatchContext.of(PatchType.JSON_MERGE_PATCH), 
               "{\"data\": {\"" + status + "\": \"" + status.name() + "\"}}");

• 添加重试策略：针对偶发的网络异常，自定义重试逻辑：

client.configMaps().withName(deploy_config)
        .withRetryPolicy(new RetryPolicy() {
            @Override
            public boolean shouldRetry(int attempt, Throwable t) {
                // 最多重试3次，仅针对IO异常和客户端异常
                return attempt < 3 && (t instanceof IOException || t instanceof KubernetesClientException);
            }
        })
        .createOrReplace(configMapBuilder.build());

内容的提问来源于stack exchange，提问作者santosh jk