我最新最全的文章都在南瓜慢说 www.pkslow.com ，欢送大家来喝茶！

1 Kubernetes Java客户端

对于Kubernetes集群的操作，官网提供了命令行工具kubectl，这也是咱们最罕用且必须把握的形式。通过kubectl来实现增删改查操作，不便而间接。但总有一些更简单的场景难以满足，比方我心愿在数据库的某个值达到10万后就触发一个Kubernetes Job去解决某项工作。即便shell编程仿佛也能够解决，但为了我的项目保护，如果能整合到现有代码里，岂不是更好？

从Kubernetes的架构图能够看出，咱们只有和API server做好交互就能够了，实际上kubectl也是如此的。那咱们就能够应用任何语言来操作Kubernetes。

本文将介绍Java方面最好用的客户端库fabric8io/kubernetes-client，它反对Kubernetes和OpenShift，并被许多我的项目援用，如Spring Cloud、Spark、Istio Java API等，可见它的优良之处。

2 如何应用

本文将通过代码演示一些罕用操作。

2.1 引入依赖

目前的最新版本为5.0.0，通过maven引入最新依赖如下：

<dependency>  <groupId>io.fabric8</groupId>  <artifactId>kubernetes-client</artifactId>  <version>5.0.0</version></dependency>

这个依赖蕴含了相干的外围类、模型类、Json和okhttp3等。

看它的依赖就能够学习优良的我的项目是如何组织和治理的。

2.2 创立客户端

创立客户端最简略的形式是应用默认配置：

KubernetesClient client = new DefaultKubernetesClient();

它会从目录~/.kube/config中读取配置文件。如果想要批改配置，能够通过配置以下设置：

零碎属性（System Properties）
环境变量（Enviroment Variables）
Kube配置文件
ServiceAccount的Token和加载的CA证书

零碎属性和环境变量列表可查看官网。

当然，还能够通过Java来自定义配置：

Config config = new ConfigBuilder()  .withMasterUrl("https://localhost:6443")  .build();KubernetesClient client = new DefaultKubernetesClient(config);

2.3 创立资源

这个Java库应用了大量的Builder模式来创建对象，创立命令空间如下：

Namespace namespace = new NamespaceBuilder()  .withNewMetadata()  .withName("pkslow")  .addToLabels("reason", "pkslow-sample")  .endMetadata()  .build();client.namespaces().createOrReplace(namespace);

非常灵活，下面例子增加了名字和标签，最初通过createOrReplace办法可新建，如果存在可替换。

对于Pod也是相似的：

Pod pod = new PodBuilder()  .withNewMetadata()  .withName("nginx")  .addToLabels("app", "nginx")  .endMetadata()  .withNewSpec()  .addNewContainer()  .withName("nginx")  .withImage("nginx:1.19.5")  .endContainer()  .endSpec()  .build();client.pods().inNamespace("pkslow").createOrReplace(pod);

指定名字、标签和镜像后就能够创立了。

2.4 查看资源

查看资源能够查问所有，或者通过条件options来过滤，具体代码如下：

// 查看命名空间NamespaceList namespaceList = client.namespaces().list();namespaceList.getItems()  .forEach(namespace ->           System.out.println(namespace.getMetadata().getName() + ":" + namespace.getStatus().getPhase()));// 查看PodListOptions options = new ListOptions();options.setLabelSelector("app=nginx");Pod nginx = client.pods().inNamespace("pkslow")  .list(options)  .getItems()  .get(0);System.out.println(nginx);

2.5 批改资源

批改资源是通过edit办法来实现的，可通过命名空间和名字来定位到资源，而后进行批改，示例代码如下：

// 批改命名空间client.namespaces().withName("pkslow")  .edit(n -> new NamespaceBuilder(n)        .editMetadata()        .addToLabels("project", "pkslow")        .endMetadata()        .build()       );// 批改Podclient.pods().inNamespace("pkslow").withName("nginx")  .edit(p -> new PodBuilder(p)        .editMetadata()        .addToLabels("app-version", "1.0.1")        .endMetadata()        .build()       );

2.6 删除资源

删除资源也是相似的，先定位再操作：

client.pods().inNamespace("pkslow")  .withName("nginx")  .delete();

2.7 通过yaml文件操作

咱们还能够间接通过yaml文件来形容资源，而不必Java来定义，这样能够更直观和不便。实现yaml文件的编写后，Load成对应的对象，再进行各种增删改查操作，示例如下：

yaml文件定义了一个Deployment：

apiVersion: apps/v1kind: Deploymentmetadata:  name: nginx-deployment  labels:    myapp: nginxspec:  replicas: 1  selector:    matchLabels:      myapp: nginx  template:    metadata:      labels:        myapp: nginx    spec:      containers:        - name: nginx          image: nginx:1.7.9          ports:            - containerPort: 80

Java代码如下：

Deployment deployment = client.apps().deployments()  .load(Fabric8KubernetesClientSamples.class.getResourceAsStream("/deployment.yaml"))  .get();client.apps().deployments().inNamespace("pkslow")  .createOrReplace(deployment);

2.8 监听事件

咱们还能够通过监听资源的事件，来进行对应的反馈，比方有人删除了Pod就记录日志到数据库等，这个性能还是十分有用的。示例代码如下：

client.pods().inAnyNamespace().watch(new Watcher<Pod>() {  @Override  public void eventReceived(Action action, Pod pod) {    System.out.println("event " + action.name() + " " + pod.toString());  }  @Override  public void onClose(WatcherException e) {    System.out.println("Watcher close due to " + e);  }});

通过一个Watcher监听了Pod的所有动作事件，而后打印动作名和对应的Pod。输入后的日志如下：

event ADDED Pod(apiVersion=v1, kind=Pod, metadata=ObjectMeta(event MODIFIED Pod(apiVersion=v1, kind=Pod, metadata=ObjectMeta(event DELETED Pod(apiVersion=v1, kind=Pod, metadata=ObjectMeta(event MODIFIED Pod(apiVersion=v1, kind=Pod, metadata=ObjectMeta(

日志太长，就不齐全显示。

3 总结

这个Kubernetes的Java客户端切实是好用，API简略易用，即便不必文档也能通过办法名判断。最让人惊喜的是，官网还提供了许多绝佳的示例，几乎不要太敌对。

应用这个API，在我的项目中能够更灵便地治理和应用Kubernetes利用了。

代码请查看：https://github.com/LarryDpk/p...

欢送关注微信公众号<南瓜慢说>，将继续为你更新...

多读书，多分享；多写作，多整顿。