当前位置：首页 > Java

java如何访问kubernetes

2026-03-20 23:28:31Java

访问 Kubernetes 的 Java 客户端库

Java 开发者可以通过官方提供的 kubernetes-client 库与 Kubernetes API 交互。该库封装了 Kubernetes API 的 REST 调用，简化了操作流程。

添加 Maven 依赖

在项目的 pom.xml 文件中添加以下依赖：

<dependency>
    <groupId>io.kubernetes</groupId>
    <artifactId>client-java</artifactId>
    <version>18.0.0</version>
</dependency>

配置客户端

使用默认的 kubeconfig 文件（通常位于 ~/.kube/config）创建客户端：

java如何访问kubernetes

import io.kubernetes.client.openapi.ApiClient;
import io.kubernetes.client.util.ClientBuilder;
import io.kubernetes.client.util.KubeConfig;

ApiClient client = ClientBuilder.kubeconfig(KubeConfig.loadKubeConfig()).build();

示例：列出 Pod

以下代码展示如何列出默认命名空间中的所有 Pod：

import io.kubernetes.client.openapi.ApiException;
import io.kubernetes.client.openapi.apis.CoreV1Api;
import io.kubernetes.client.openapi.models.V1PodList;

CoreV1Api api = new CoreV1Api(client);
V1PodList podList = api.listNamespacedPod("default", null, null, null, null, null, null, null, null, null, null);
podList.getItems().forEach(pod -> System.out.println(pod.getMetadata().getName()));

处理异常

Kubernetes API 调用可能抛出 ApiException，需妥善处理：

java如何访问kubernetes

try {
    V1PodList podList = api.listNamespacedPod("default", null, null, null, null, null, null, null, null, null, null);
} catch (ApiException e) {
    System.err.println("API exception: " + e.getResponseBody());
}

自定义配置

如需自定义集群配置（如访问内网集群），可显式设置参数：

ApiClient client = new ClientBuilder()
    .setBasePath("https://your-cluster-ip:6443")
    .setVerifyingSsl(false) // 仅测试环境禁用 SSL 验证
    .setAuthentication(new AccessTokenAuthentication("your-token"))
    .build();

高级操作示例

创建 Deployment 的代码片段：

import io.kubernetes.client.openapi.apis.AppsV1Api;
import io.kubernetes.client.openapi.models.V1Deployment;

AppsV1Api appsApi = new AppsV1Api(client);
V1Deployment deployment = new V1Deployment();
// 设置 deployment 配置...
appsApi.createNamespacedDeployment("default", deployment, null, null, null);