背景

现在kubernetes广泛应用于devops各个领域，很多时候你可能需要使用Kubenetes Java客户端库来监听Kubenets中的任何更改，以便您可以设置钩子逻辑，以便在K8s中的任何更改时调用业务逻辑处理这些数据。

痛点

一般情况下，默认监听所有的变动信息是又浪费资源又慢，因此您可以通过安装Kube标签来对特定更改进行过滤监听。这个博客就是来展示如何做到这一点。

检查如何过滤已经过滤哪个标签

这是Kubenetes LENS的快照页面，我将使用labelrun=dummy-service作为示例。如下图所示。

Java代码示例

如果您在Kubenetse中的部署标签是run=dummy-service，您可以使用以下代码逻辑

public void run() {

        Watch<V1Deployment> watch = null;
        try {
            watch = Watch.createWatch(
                    client,
                    appsApi.listNamespacedDeploymentCall("YOU_NAME_SPACE", null, null, null, null, "run=dummy-service", null,
                            null, null, null, true, null),
                    new TypeToken<Watch.Response<V1Deployment>>() {
                    }.getType());
        } catch (ApiException e) {
            LOGGER.error("Error occurred in DeploymentWatcher,", e);           
        }
        assert watch != null;
        watch.forEach(this::setMetadata);
    }

因此，上述代码将返回所有带有“run=dummy-service”标签的部署，这样你就可以对此过滤过的子集进行任何相应的处理

参考链接

https://appdoc.app/artifact/io.kubernetes/client-java-api/0.1/io/kubernetes/client/apis/AppsV1beta1Api.html#listNamespacedDeploymentCall-java.lang.String-java.lang.String-java.lang.String-java.lang.String-java.lang.String-java.lang.Integer-java.lang.Boolean-io.kubernetes.client.ProgressResponseBody.ProgressListener-io.kubernetes.client.ProgressRequestBody.ProgressRequestListener-

–结束–

欢迎大家浏览关注我的公众号 “竹书纪年的IT男”. 更多类似文章，请访问我的网站www.todzhang.com