java方法 获取k8s有状态项目实际正常运行的pod数

在Kubernetes (k8s) 中，获取有状态应用（如StatefulSets或Deployments）中实际正常运行的Pod数量通常涉及到Kubernetes API的查询。你可以通过编写一个Java程序，并利用Kubernetes客户端库（如`kubectl-java`或`java-client` for Kubernetes）来实现这个功能。

以下是一个简单的步骤概述：

1. **添加依赖**：首先，你需要将Kubernetes Java客户端库添加到你的项目中。如果你使用Maven，可以在pom.xml文件中添加以下依赖：

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

2. **创建Kubernetes client**：初始化并配置Kubernetes客户端，通常需要提供一个Kubernetes的API服务器地址（例如`https://your-k8s-cluster/api/v1`）和认证凭据。

3. **查询资源**：针对StatefulSet或Deployment，使用`CoreV1Api`或者相应的API实例，发送GET请求到对应的资源列表（如`/namespaces/{namespace}/statefulsets` 或 `/namespaces/{namespace}/deployments`）。然后遍历返回的`PodList`，筛选出`Ready`状态为`true`的Pods。

4. **计数处理**：计算返回的Pod列表中`readyStatus`为`True`的Pod数量作为实际运行的数量。

以下是伪代码示例：

import io.kubernetes.client.openapi.ApiClient;
import io.kubernetes.client.openapi.Configuration;
import io.kubernetes.client.openapi.apis.AppsV1Api;
import io.kubernetes.client.util.Config;

...

ApiClient client = Config.defaultClient();
AppsV1Api appsApi = new AppsV1Api(client);

String namespace = "your-namespace";
String kind = "statefulset"; // 或者"deployment"

if (kind.equals("statefulset")) {
    V1beta1StatefulSetList statefulSets = appsApi.listNamespacedStatefulSet(namespace, null);
} else if (kind.equals("deployment")) {
    V1DeploymentList deployments = appsApi.listNamespacedDeployment(namespace, null);
}

int runningPodsCount = 0;
for (V1Pod pod : statefulSets.getItems() || deployments.getItems()) {
    if (pod.getStatus().getPhase().equals("Running") && pod.getStatus().getConditions().stream()
            .anyMatch(condition -> condition.getType().equals("Ready") && condition.getStatus())) {
        runningPodsCount++;
    }
}

System.out.println("实际正常运行的Pod数: " + runningPodsCount);