如何使用K8s Java客户端实现集群列举及上下文查询、切换操作

所有实现基于官方维护的 io.kubernetes:client-java 内置的 kubeconfig 解析能力，无需手动编写 YAML 解析逻辑即可对齐 kubectl config 子命令的全部行为。

列举所有已配置集群 #

K8s Java 客户端加载 kubeconfig 后，会将配置文件中定义的所有集群条目存储在 Config 对象的 clusters 属性中，直接遍历该属性即可获取全量集群信息，和 kubectl 视角下的集群定义完全一致。
示例代码：

// 加载默认路径（~/.kube/config）下的kubeconfig配置
Config k8sConfig = ClientConfig.kubeconfig();

// 遍历输出所有集群的基础信息
k8sConfig.getClusters().forEach(clusterEntry -> {
    String clusterName = clusterEntry.getName();
    String apiServerAddr = clusterEntry.getCluster().getServer();
    System.out.printf("集群名称：%s，API服务地址：%s%n", clusterName, apiServerAddr);
});

对齐 kubectl config 命令的功能实现 #

列举所有上下文（对应 kubectl config get-contexts） #

kubeconfig 中的上下文（context）会绑定集群、用户、默认命名空间信息，这些内容存储在 Config 对象的 contexts 属性中，同时 Config 对象中的 currentContext 字段记录了当前生效的上下文，输出逻辑可完全对齐 kubectl 的多列表格输出格式。
示例代码：

Config k8sConfig = ClientConfig.kubeconfig();
String currentContext = k8sConfig.getCurrentContext();

// 遍历输出所有上下文信息
k8sConfig.getContexts().forEach(contextEntry -> {
    Context contextMeta = contextEntry.getContext();
    String contextName = contextEntry.getName();
    String boundCluster = contextMeta.getCluster();
    String boundUser = contextMeta.getUser();
    String defaultNs = contextMeta.getNamespace() != null ? contextMeta.getNamespace() : "default";
    String currentMark = contextName.equals(currentContext) ? "*" : " ";
    
    System.out.printf(
        "%s 上下文名称：%s，绑定集群：%s，绑定用户：%s，默认命名空间：%s%n",
        currentMark, contextName, boundCluster, boundUser, defaultNs
    );
});

切换当前上下文（对应 kubectl config use-context foo） #

kubectl 的 use-context 命令本质是修改 kubeconfig 文件中的 current-context 字段值，Java 侧实现时只需完成三步：加载现有配置、设置目标上下文名称、将修改后的配置回写到原 kubeconfig 文件即可。
示例代码：

Config k8sConfig = ClientConfig.kubeconfig();
String targetContext = "foo";

// 前置校验：确认目标上下文存在，避免写入无效配置
boolean contextExists = k8sConfig.getContexts().stream()
        .anyMatch(entry -> entry.getName().equals(targetContext));
if (!contextExists) {
    throw new IllegalArgumentException("目标上下文 " + targetContext + " 不存在，请检查配置后重试");
}

// 设置新的当前上下文
k8sConfig.setCurrentContext(targetContext);

// 回写配置到本地kubeconfig文件
File kubeconfigPath = new File(System.getProperty("user.home"), ".kube/config");
try (FileWriter fileWriter = new FileWriter(kubeconfigPath)) {
    KubeConfig.save(k8sConfig, fileWriter);
}

实现注意事项 #

• 若 kubeconfig 文件不在默认路径下，可在调用 ClientConfig.kubeconfig() 时传入自定义文件路径参数，适配多套配置并存的场景。
• 列举集群、上下文的操作均为本地文件解析过程，不会向 K8s 集群发起任何网络请求，执行效率与 kubectl 原生命令一致。
• 执行上下文切换操作前需确认当前账号对 kubeconfig 文件有读写权限，避免出现权限类报错。

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