乐趣区

关于云计算:Kubernetes官方java客户端之三外部应用

jiezi

欢送拜访我的 GitHub

https://github.com/zq2599/blog_demos

内容：所有原创文章分类汇总及配套源码，波及 Java、Docker、Kubernetes、DevOPS 等；

概览

  1. 以下提到的 <font color=”blue”>java 客户端 </font> 都是指 <font color=”red”>client-jar.jar</font>；
  2. 本文是《Kubernetes 官网 java 客户端》系列的第三篇，《Kubernetes 官网 java 客户端：筹备》一文中咱们为实战做好了筹备工作，从本文开始进入实战阶段；
  3. 本文的指标是开发名为 <font color=”blue”>OutsideclusterApplication 的 SpringBoot</font> 利用，该利用没有部署在 K8S 环境，应用的 config 文件是手动从 K8S 环境复制过去的，java 客户端通过此 config 文件，可能近程拜访到 K8S 上的 API Server，实现所有客户端性能，整体部署状况如下图：

  • 介绍结束，开始编码；

源码下载

  1. 如果您不想编码，能够在 GitHub 下载所有源码，地址和链接信息如下表所示 (https://github.com/zq2599/blo…：
名称 链接 备注
我的项目主页 https://github.com/zq2599/blo… 该我的项目在 GitHub 上的主页
git 仓库地址 (https) https://github.com/zq2599/blo… 该我的项目源码的仓库地址，https 协定
git 仓库地址 (ssh) git@github.com:zq2599/blog_demos.git 该我的项目源码的仓库地址，ssh 协定
  1. 这个 git 我的项目中有多个文件夹，本章的利用在 <font color=”blue”>kubernetesclient</font> 文件夹下，如下图红框所示：

部署在 K8S 之外的利用：OutsideclusterApplication

名为 <font color=”blue”>OutsideclusterApplication</font> 的利用并未部署在 K8S 环境，该利用可能拜访到 K8S 环境的要害，就是将 K8S 环境的 config 文件复制一份，而后放在 OutsideclusterApplication 可能拜访到的地位：

  1. 登录 K8S 环境，在~/.kube 目录下找到 config 文件，复制此文件到 OutsideclusterApplication 运行的机器上 (我这里寄存的门路是 /Users/zhaoqin/temp/202007/05/，和前面的代码中统一)；
  2. 关上《Kubernetes 官网 java 客户端：筹备》中创立的的 <font color=”blue”>kubernetesclient</font> 工程，在外面创立子工程，名为 <font color=”blue”>OutsideclusterApplication</font>，这是个 SpringBoot 工程，pom.xml 内容如下：
<?xml version="1.0" encoding="UTF-8"?>
<project xmlns="http://maven.apache.org/POM/4.0.0" xmlns:xsi="http://www.w3.org/2001/XMLSchema-instance"
         xsi:schemaLocation="http://maven.apache.org/POM/4.0.0 https://maven.apache.org/xsd/maven-4.0.0.xsd">
    <modelVersion>4.0.0</modelVersion>

    <parent>
        <groupId>com.bolingcavalry</groupId>
        <artifactId>kubernetesclient</artifactId>
        <version>1.0-SNAPSHOT</version>
        <relativePath>../pom.xml</relativePath>
    </parent>

    <groupId>com.bolingcavalry</groupId>
    <artifactId>outsidecluster</artifactId>
    <version>0.0.1-SNAPSHOT</version>
    <name>outsidecluster</name>
    <description>Demo project for Spring Boot</description>
    <packaging>jar</packaging>

    <dependencies>
        <dependency>
            <groupId>org.springframework.boot</groupId>
            <artifactId>spring-boot-starter-web</artifactId>
            <exclusions>
                <exclusion>
                    <groupId>org.springframework.boot</groupId>
                    <artifactId>spring-boot-starter-json</artifactId>
                </exclusion>
            </exclusions>
        </dependency>
        <dependency>
            <groupId>org.projectlombok</groupId>
            <artifactId>lombok</artifactId>
            <optional>true</optional>
        </dependency>
        <dependency>
            <groupId>io.kubernetes</groupId>
            <artifactId>client-java</artifactId>
        </dependency>
    </dependencies>

    <build>
        <plugins>
            <plugin>
                <groupId>org.springframework.boot</groupId>
                <artifactId>spring-boot-maven-plugin</artifactId>
                <version>2.3.0.RELEASE</version>
            </plugin>
        </plugins>
    </build>

</project>
  1. 上述 pom.xml 中，须要留神的是在依赖 spring-boot-starter-web 的时候，应用 exclusion 语法排除了 spring-boot-starter-json 的依赖，这样做是为了将 jackson 的依赖全副去掉 (spring-boot-starter-json 依赖了 jackson)，如此一来整个 classpath 上面就没有了 jackson 库，此时 SpringBoot 框架就会应用 gson 作为序列化和反序列化工具 (client-java.jar 依赖了 gson 库)；(这个问题在《Kubernetes 官网 java 客户端之二：序列化和反序列化问题》一文有具体介绍)
  2. 新增 OutsideclusterApplication.java，简略起见，该类即是疏导类又是 Controller：
package com.bolingcavalry.outsidecluster;

import com.google.gson.GsonBuilder;
import io.kubernetes.client.openapi.ApiClient;
import io.kubernetes.client.openapi.Configuration;
import io.kubernetes.client.openapi.apis.CoreV1Api;
import io.kubernetes.client.openapi.models.V1PodList;
import io.kubernetes.client.util.ClientBuilder;
import io.kubernetes.client.util.KubeConfig;
import lombok.extern.slf4j.Slf4j;
import org.springframework.boot.SpringApplication;
import org.springframework.boot.autoconfigure.SpringBootApplication;
import org.springframework.web.bind.annotation.RequestMapping;
import org.springframework.web.bind.annotation.RestController;

import java.io.FileReader;

@SpringBootApplication
@RestController
@Slf4j
public class OutsideclusterApplication {public static void main(String[] args) {SpringApplication.run(OutsideclusterApplication.class, args);
    }

    @RequestMapping(value = "/hello")
    public V1PodList hello() throws Exception {
        // 寄存 K8S 的 config 文件的全门路
        String kubeConfigPath = "/Users/zhaoqin/temp/202007/05/config";

        // 以 config 作为入参创立的 client 对象，能够拜访到 K8S 的 API Server
        ApiClient client = ClientBuilder
                .kubeconfig(KubeConfig.loadKubeConfig(new FileReader(kubeConfigPath)))
                .build();

        Configuration.setDefaultApiClient(client);

        CoreV1Api api = new CoreV1Api();

        // 调用客户端 API 获得所有 pod 信息
        V1PodList v1PodList = api.listPodForAllNamespaces(null, null, null, null, null, null, null, null, null);

        // 应用 jackson 将汇合对象序列化成 JSON，在日志中打印进去
        log.info("pod info \n{}", new GsonBuilder().setPrettyPrinting().create().toJson(v1PodList));

        return v1PodList;
    }

}
  1. 运行上述代码，在浏览器拜访 http://localhost:8080/hello，即可获得 K8S 所有 pod 的详情，如下所示 (为了让返回数据更加参差好看，我用的是 Firefox 浏览器)：

  1. 查看控制台，可见日志也将详情打印进去：

  • 至此，咱们的第一个应用 K8S 官网 java 客户端的利用就实现了，接下来的实战会尝试将利用部署在 K8S 环境内，在 K8S 外部进行各项操作；

你不孤独，欣宸原创一路相伴

  1. Java 系列
  2. Spring 系列
  3. Docker 系列
  4. kubernetes 系列
  5. 数据库 + 中间件系列
  6. DevOps 系列

欢送关注公众号：程序员欣宸

微信搜寻「程序员欣宸」，我是欣宸，期待与您一起畅游 Java 世界 …
https://github.com/zq2599/blog_demos

退出移动版