如何用Java从应用内获取其所在Kubernetes集群的命名空间？

不管你的Java应用部署在dev还是prod集群，以下几种方法都能在不预先知晓集群环境的前提下获取当前Pod的命名空间：

方法1：读取K8s自动挂载的服务账户文件 #

Kubernetes会自动给每个运行中的Pod挂载服务账户相关文件，其中就包含了当前Pod的命名空间信息，路径固定为/var/run/secrets/kubernetes.io/serviceaccount/namespace。

Java代码示例：

import java.nio.file.Files;
import java.nio.file.Paths;

public class NamespaceUtil {
    public static String getCurrentNamespace() throws Exception {
        String nsFilePath = "/var/run/secrets/kubernetes.io/serviceaccount/namespace";
        return new String(Files.readAllBytes(Paths.get(nsFilePath))).trim();
    }

    public static void main(String[] args) {
        try {
            String namespace = getCurrentNamespace();
            System.out.println("当前应用所在命名空间: " + namespace);
        } catch (Exception e) {
            // 非K8s环境下可以返回默认值或做异常处理
            System.err.println("获取命名空间失败: " + e.getMessage());
        }
    }
}

优势：无需任何额外配置，K8s默认支持，不管集群是dev还是prod都能直接用。

方法2：通过Deployment注入环境变量 #

你可以在应用的Deployment配置中，将Pod的命名空间注入为环境变量，Java应用直接读取该环境变量即可。

Deployment配置片段：

spec:
  containers:
  - name: your-java-app
    image: your-app-image:latest
    env:
    - name: POD_NAMESPACE
      valueFrom:
        fieldRef:
          fieldPath: metadata.namespace

Java读取环境变量的代码：

public class NamespaceUtil {
    public static String getCurrentNamespace() {
        String namespace = System.getenv("POD_NAMESPACE");
        // 环境变量不存在时返回默认命名空间
        return namespace != null ? namespace : "default";
    }

    public static void main(String[] args) {
        String namespace = getCurrentNamespace();
        System.out.println("当前应用所在命名空间: " + namespace);
    }
}

优势：代码更简洁，非K8s环境下可以设置默认值，兼容性更强。

方法3：使用Kubernetes Java客户端（适合需要更多K8s资源操作的场景） #

如果你的应用需要和K8s API交互，可以使用Fabric8 Kubernetes Client来获取命名空间，客户端会自动从服务账户文件中读取集群信息和命名空间。

Java代码示例：

import io.fabric8.kubernetes.client.DefaultKubernetesClient;
import io.fabric8.kubernetes.client.KubernetesClient;

public class NamespaceUtil {
    public static String getCurrentNamespace() {
        try (KubernetesClient client = new DefaultKubernetesClient()) {
            return client.getNamespace();
        } catch (Exception e) {
            System.err.println("获取命名空间失败: " + e.getMessage());
            return "default";
        }
    }

    public static void main(String[] args) {
        String namespace = getCurrentNamespace();
        System.out.println("当前应用所在命名空间: " + namespace);
    }
}

注意：需要在项目中引入Fabric8的依赖（比如Maven依赖），同时Pod的服务账户需要有访问K8s API的权限。如果只是单纯获取命名空间，前两种方法更轻量。

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