如何使用Mutiny实现Kubernetes客户端的异步调用（以创建命名空间为例）

要解决Kubernetes客户端同步操作的限制，你可以借助支持Mutiny的Kubernetes客户端实现异步调用，具体改造步骤如下：

1. 准备依赖与客户端实例 #

首先确保引入支持Mutiny的Kubernetes客户端依赖：

• 若使用Quarkus，直接添加quarkus-kubernetes-client扩展，它自带Mutiny支持；
• 普通Java项目则添加io.fabric8:kubernetes-client-mutiny依赖（版本需与你使用的Kubernetes客户端版本匹配）。

然后获取Mutiny客户端实例：

// Quarkus环境直接注入
@Inject
MutinyKubernetesClient mutinyClient;

// 普通Java项目手动初始化
MutinyKubernetesClient mutinyClient = KubernetesClientBuilder.defaultMutinyClient();

2. 异步实现命名空间创建/替换 #

Mutiny客户端的API会返回Uni<Namespace>对象（代表单个异步结果），通过订阅处理成功或失败场景：

// 构建命名空间对象
Namespace namespace = new NamespaceBuilder()
        .withNewMetadata()
        .withName(namespaceToBeCreated)
        .endMetadata()
        .build();

// 异步执行创建/替换操作
mutinyClient.namespaces()
        .createOrReplace(namespace)
        .subscribe()
        .with(
                // 成功回调：处理创建后的命名空间对象
                createdNs -> System.out.println("命名空间 " + createdNs.getMetadata().getName() + " 创建完成"),
                // 失败回调：处理异常
                err -> System.err.println("创建命名空间失败：" + err.getMessage())
        );

3. 进阶：链式处理异步逻辑 #

Mutiny支持链式调用，可更优雅地处理后续逻辑或异常恢复：

mutinyClient.namespaces()
        .createOrReplace(namespace)
        // 成功时转换结果
        .onItem().transform(ns -> "命名空间 " + ns.getMetadata().getName() + " 已创建")
        // 失败时返回默认值或自定义处理逻辑
        .onFailure().recoverWithItem(err -> "创建失败：" + err.getMessage())
        // 订阅输出最终结果
        .subscribe().with(System.out::println);

注意事项 #

• 手动初始化的MutinyKubernetesClient使用完成后需调用mutinyClient.close()释放资源；
• 异步操作只有在调用subscribe()后才会触发执行；
• 若需批量处理多个异步操作，可使用Mutiny的Multi或合并操作符（如combine().all().unis(...)）。

内容的提问来源于stack exchange，提问作者Achraf Ibn Mrabet