如何通过Java（fabric8 kubeclient）同步删除Kubernetes Ingress规则及命名空间

问题背景 #

我通过Fabric8 KubeClient操作Kubernetes和Ingress，每个存储用户内容的命名空间下都配置了一条Ingress规则。现在需要根据请求删除这些用户命名空间，但删除命名空间的操作耗时较长，因此希望先同步删除Ingress规则以禁止用户访问，再异步删除命名空间本身。目前使用的删除代码均为异步执行：

client.extensions().ingresses().inNamespace(namespaceName).delete();

// 或者指定Ingress名称删除
// client.extensions().ingresses().inNamespace(namespaceName).withName(ingressName).delete();

client.namespaces().withName(namespaceName).delete();

对应的Ingress配置如下：

apiVersion: networking.k8s.io/v1
kind: Ingress
metadata:
  labels:
    my-cluster: dev-cluster
  name: name_1
spec:
  ingressClassName: nginx
  rules:
    - host: {{host}}
      http:
        paths:
          - backend:
              service:
                name: service_1
                port:
                  number: 80
            path: /
            pathType: ImplementationSpecific

同步删除Ingress的实现方式 #

Fabric8 KubeClient默认的delete()方法仅异步发起删除请求，可通过以下方式实现同步等待删除完成的效果：

1. 使用waitUntilDeleted()方法阻塞等待 #

Fabric8提供了资源操作的等待API，发起删除请求后可阻塞当前线程，直到资源被Kubernetes彻底删除：

// 删除指定命名空间下的单个Ingress并等待删除完成
client.extensions().ingresses().inNamespace(namespaceName).withName(ingressName)
    .delete()
    .waitUntilDeleted(60, TimeUnit.SECONDS); // 设置超时时间，例如60秒

// 或者删除命名空间下所有Ingress后等待
client.extensions().ingresses().inNamespace(namespaceName)
    .delete()
    .waitUntilDeleted(60, TimeUnit.SECONDS);

这段代码会在发起删除请求后，持续检查资源状态，直到Ingress被彻底删除或等待超时。

2. 手动轮询检查Ingress状态 #

如果需要自定义重试逻辑，可手动轮询Kubernetes API确认Ingress是否已删除：

// 先发起删除请求
client.extensions().ingresses().inNamespace(namespaceName).withName(ingressName).delete();

// 轮询检查，最多等待60秒
long startTime = System.currentTimeMillis();
while (System.currentTimeMillis() - startTime < 60000) {
    try {
        // 尝试获取Ingress，若抛出404异常则说明已删除
        client.extensions().ingresses().inNamespace(namespaceName).withName(ingressName).get();
        TimeUnit.SECONDS.sleep(1); // 间隔1秒重试
    } catch (KubernetesClientException e) {
        if (e.getCode() == 404) {
            // 资源已删除，退出循环
            break;
        }
        // 其他异常直接抛出
        throw e;
    }
}

3. 命名空间的同步删除（可选） #

如果需要同步删除命名空间，同样可以使用waitUntilDeleted()方法，但注意命名空间删除耗时较长，需设置更长超时：

client.namespaces().withName(namespaceName)
    .delete()
    .waitUntilDeleted(5, TimeUnit.MINUTES);

但根据需求，建议先同步删除Ingress，再异步删除命名空间，避免主线程长时间阻塞。

注意事项 #

• 确保Fabric8 KubeClient版本在v4.x及以上，该版本开始支持waitUntilDeleted()方法。
• 根据集群实际情况设置合理超时：Ingress删除通常几秒内完成，命名空间删除可能需要数分钟。
• 若批量删除命名空间下所有Ingress，建议先获取Ingress列表，再逐个删除并等待，避免批量操作时部分资源未处理完成。

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