• java连接kubernete

    最近需要做一个项目，将k8s上的日志经过java工程输出到前端，大概想了下思路，首先要java连接kubernete监控到job的日志，然后通过websocket将日志持续输出到前端，因为这些从来没有写过，所以只能一点一点积累知识，一点一点攻破，目前是java连接kubernete成功了，并取到了日志，暂时记录一下

    1、java连接kubernete方法：配置文件方式，这个文件需要配置到你的工程里面，怎么获取到配置文件？问你们单位的运维，告诉他在机器上帮你取这个文件~/.kube/config 运维说这个是开发环境的超级证书，这个证书只能运维取，因为估计普通测试员没有权限，运维有管理员权限的账号才能取下来

    创建k8sclient文件

    1. package com.example.demo.config;
    2.  
    3. /**
    4.  * @Author: lxx
    5.  * @Date: 2022/8/4 下午5:43
    6.  */
    7.  
    8. import io.kubernetes.client.custom.IntOrString;
    9. import io.kubernetes.client.openapi.ApiClient;
    10. import io.kubernetes.client.openapi.ApiException;
    11. import io.kubernetes.client.openapi.apis.CoreV1Api;
    12. import io.kubernetes.client.openapi.apis.ExtensionsV1beta1Api;
    13. import io.kubernetes.client.openapi.apis.NetworkingV1Api;
    14. import io.kubernetes.client.openapi.models.*;
    15. import io.kubernetes.client.util.ClientBuilder;
    16. import io.kubernetes.client.util.KubeConfig;
    17. import lombok.extern.slf4j.Slf4j;
    18. import okhttp3.Call;
    19. import org.slf4j.Logger;
    20.  
    21. import java.io.FileReader;
    22. import java.io.IOException;
    23. import java.util.Map;
    24.  
    25. /**
    26.  * k8s客户端
    27.  *
    28.  * @author wanghuidong
    29.  * @date 2021/6/18 14:14
    30.  */
    31. @Slf4j
    32. public class K8sClient {
    33.  
    34.     /**
    35.      * k8s-api客户端
    36.      */
    37.     private ApiClient apiClient;
    38.  
    39.     /**
    40.      * 构建集群POD内通过SA访问的客户端
    41.      * loading the in-cluster config, including:
    42.      * 1. service-account CA
    43.      * 2. service-account bearer-token
    44.      * 3. service-account namespace
    45.      * 4. master endpoints(ip, port) from pre-set environment variables
    46.      */
    47.     public K8sClient() {
    48.         try {
    49.             this.apiClient = ClientBuilder.cluster().build();
    50.         } catch (IOException e) {
    51.             log.error("构建K8s-Client异常", e);
    52.             throw new RuntimeException("构建K8s-Client异常");
    53.         }
    54.     }
    55.  
    56.     /**
    57.      * 构建集群外通过UA访问的客户端
    58.      * loading the out-of-cluster config, a kubeconfig from file-system
    59.      *
    60.      * @param kubeConfigPath kube连接配置文件
    61.      */
    62.     public K8sClient(String kubeConfigPath) {
    63.         try {
    64.             this.apiClient = ClientBuilder.kubeconfig(KubeConfig.loadKubeConfig(new FileReader(kubeConfigPath))).build();
    65.         } catch (IOException e) {
    66.             log.error("读取kubeConfigPath异常", e);
    67.             throw new RuntimeException("读取kubeConfigPath异常");
    68.         } catch (Exception e) {
    69.             log.error("构建K8s-Client异常", e);
    70.             throw new RuntimeException("构建K8s-Client异常");
    71.         }
    72.     }
    73.  
    74.     /**
    75.      * 获取所有的Pod
    76.      *
    77.      * @return podList
    78.      */
    79.     public V1PodList getAllPodList() throws Exception {
    80.         // new a CoreV1Api
    81.         CoreV1Api api = new CoreV1Api(apiClient);
    82.  
    83.         // invokes the CoreV1Api client
    84. //        V1Pod pod = api.readNamespacedPod("reconcile-l75kp","dev5",null,null,null);
    85.         try {
    86.             //V1PodList list = api.listPodForAllNamespaces(null, null, null, null, null, null, null, null, null, null);
    87.             V1PodList list = api.listNamespacedPod("dev5",null,null,null,null,null,null,null,null,null,null);
    88.             return list;
    89.         } catch (ApiException e) {
    90.             log.error("获取podlist异常:" + e.getResponseBody(), e);
    91.         }
    92.         return null;
    93.     }
    94.  
    95.     /**
    96.      * 创建k8s service
    97.      *
    98.      * @param namespace   命名空间
    99.      * @param serviceName 服务名称
    100.      * @param port        服务端口号（和目标pod的端口号一致）
    101.      * @param selector    pod标签选择器
    102.      * @return 创建成功的service对象
    103.      */
    104.     public V1Service createService(String namespace, String serviceName, Integer port, Map selector) {
    105.         //构建service的yaml对象
    106.         V1Service svc = new V1ServiceBuilder()
    107.                 .withNewMetadata()
    108.                 .withName(serviceName)
    109.                 .endMetadata()
    110.                 .withNewSpec()
    111.                 .addNewPort()
    112.                 .withProtocol("TCP")
    113.                 .withPort(port)
    114.                 .withTargetPort(new IntOrString(port))
    115.                 .endPort()
    116.                 .withSelector(selector)
    117.                 .endSpec()
    118.                 .build();
    119.  
    120.         // Deployment and StatefulSet is defined in apps/v1, so you should use AppsV1Api instead of CoreV1API
    121.         CoreV1Api api = new CoreV1Api(apiClient);
    122.         V1Service v1Service = null;
    123.         try {
    124.             v1Service = api.createNamespacedService(namespace, svc, null, null, null);
    125.         } catch (ApiException e) {
    126.             log.error("创建service异常:" + e.getResponseBody(), e);
    127.         } catch (Exception e) {
    128.             log.error("创建service系统异常:", e);
    129.         }
    130.         return v1Service;
    131.     }
    132.  
    133.     /**
    134.      * 创建k8s V1Ingress
    135.      *
    136.      * @param namespace   命名空间
    137.      * @param ingressName ingress名称
    138.      * @param annotations ingress注解
    139.      * @param path        匹配的路径
    140.      * @param serviceName 路由到的服务名称
    141.      * @param servicePort 路由到的服务端口
    142.      * @return 创建成功的ingress对象
    143.      */
    144.     public V1Ingress createV1Ingress(String namespace, String ingressName, Map annotations, String path,
    145.                                      String serviceName, Integer servicePort) {
    146.         //构建ingress的yaml对象
    147.         V1Ingress ingress = new V1IngressBuilder()
    148.                 .withNewMetadata()
    149.                 .withName(ingressName)
    150.                 .withAnnotations(annotations)
    151.                 .endMetadata()
    152.                 .withNewSpec()
    153.                 .addNewRule()
    154.                 .withHttp(new V1HTTPIngressRuleValueBuilder().addToPaths(new V1HTTPIngressPathBuilder()
    155.                         .withPath(path)
    156.                         .withPathType("Prefix")
    157.                         .withBackend(new V1IngressBackendBuilder()
    158.                                 .withService(new V1IngressServiceBackendBuilder()
    159.                                         .withName(serviceName)
    160.                                         .withPort(new V1ServiceBackendPortBuilder()
    161.                                                 .withNumber(servicePort).build()).build()).build()).build()).build())
    162.                 .endRule()
    163.                 .endSpec()
    164.                 .build();
    165.  
    166.         //调用对应的API执行创建ingress的操作
    167.         NetworkingV1Api api = new NetworkingV1Api(apiClient);
    168.         V1Ingress v1Ingress = null;
    169.         try {
    170.             v1Ingress = api.createNamespacedIngress(namespace, ingress, null, null, null);
    171.         } catch (ApiException e) {
    172.             log.error("创建ingress异常:" + e.getResponseBody(), e);
    173.         } catch (Exception e) {
    174.             log.error("创建ingress系统异常:", e);
    175.         }
    176.         return v1Ingress;
    177.     }
    178.  
    179.  
    180.     /**
    181.      * 创建k8s ExtensionIngress
    182.      *
    183.      * @param namespace   命名空间
    184.      * @param ingressName ingress名称
    185.      * @param annotations ingress注解
    186.      * @param path        匹配的路径
    187.      * @param serviceName 路由到的服务名称
    188.      * @param servicePort 路由到的服务端口
    189.      * @return 创建成功的ingress对象
    190.      */
    191.     public ExtensionsV1beta1Ingress createExtensionIngress(String namespace, String ingressName, Map annotations, String path,
    192.                                                            String serviceName, Integer servicePort) {
    193.         //构建ingress的yaml对象
    194.         ExtensionsV1beta1Ingress ingress = new ExtensionsV1beta1IngressBuilder()
    195.                 .withNewMetadata()
    196.                 .withName(ingressName)
    197.                 .withAnnotations(annotations)
    198.                 .endMetadata()
    199.                 .withNewSpec()
    200.                 .addNewRule()
    201.                 .withHttp(new ExtensionsV1beta1HTTPIngressRuleValueBuilder().addToPaths(new ExtensionsV1beta1HTTPIngressPathBuilder()
    202.                         .withPath(path)
    203.                         .withBackend(new ExtensionsV1beta1IngressBackendBuilder()
    204.                                 .withServiceName(serviceName)
    205.                                 .withServicePort(new IntOrString(servicePort)).build()).build()).build())
    206.                 .endRule()
    207.                 .endSpec()
    208.                 .build();
    209.  
    210.         //调用对应的API执行创建ingress的操作
    211.         ExtensionsV1beta1Api api = new ExtensionsV1beta1Api(apiClient);
    212.         ExtensionsV1beta1Ingress extensionsV1beta1Ingress = null;
    213.         try {
    214.             extensionsV1beta1Ingress = api.createNamespacedIngress(namespace, ingress, null, null, null);
    215.         } catch (ApiException e) {
    216.             log.error("创建ingress异常:" + e.getResponseBody(), e);
    217.         } catch (Exception e) {
    218.             log.error("创建ingress系统异常:", e);
    219.         }
    220.         return extensionsV1beta1Ingress;
    221.     }
    222. public V1Pod readNamespacedPod(String podName,String spaceName)throws Exception{
    223.     CoreV1Api api = new CoreV1Api(apiClient);
    224.     V1Pod pod = api.readNamespacedPod(podName,spaceName,null,null,null);
    225.     return pod;
    226. }
    227.  
    228.     public Call readNamespacedPodLogCall (String podName, String spaceName, Integer tailLines)throws Exception{
    229.         CoreV1Api api = new CoreV1Api(apiClient);
    230.         Call log = api.readNamespacedPodLogCall(podName,spaceName,null,true,null,null,null,null,null,100,null,null);
    231.         return log;
    232.     }
    233.     public String readNamespacedPodLog (String podName, String spaceName, Integer tailLines)throws Exception{
    234. //        CoreV1Api api = new CoreV1Api(apiClient);
    235.         CoreV1Api api = new CoreV1Api(apiClient);
    236.         String log = api.readNamespacedPodLog(podName,spaceName,null,true,false,1024,"true",false,null,10,false);
    237.         return log;
    238.     }
    239. }

    写单元测试

    1. package com.example.demo;
    2.  
    3. import com.example.demo.config.K8sClient;
    4. import io.kubernetes.client.openapi.models.V1Pod;
    5. import io.kubernetes.client.openapi.models.V1PodList;
    6. import org.junit.Test;
    7. import java.io.File;
    8.  
    9. /**
    10.  * @Author: 
    11.  * @Date: 2022/8/4 下午5:31
    12.  */
    13. public class KuberneteTest {
    14.  
    15.     @Test
    16. public void testK8sLog()throws Exception{
    17.         String kubeConfigPath = "/Users/xxx/k8s/config";
    18.         if (!new File(kubeConfigPath).exists()) {
    19.             System.out.println("kubeConfig不存在，跳过");
    20.             return;
    21.         }
    22.         K8sClient k8sClient = new K8sClient(kubeConfigPath);
    23.         String call=k8sClient.readNamespacedPodLog("test-l75kp","dev5",100);
    24.         System.out.println(call);
    25.     }
    26. }

    这样就可以连上kubernete啦，连接k8的用户名密码什么的都在/Users/xxx/k8s/config这个配置文件中,连上之后读取 space为dev5  job名为test-l75kp的日志

    不要觉得代码多，亲自试一试吧！

  • 相关阅读:
    MFC的定义和实际操作方法
    两个输入信号同时输入判断
    教你如何在map上添加自定义控件
    AlexNet重点介绍和源码测试
    经典匹配算法: KMP、Sunday与ShiftAnd
    【2022国赛模拟】[SDWC Day4] 数列——树形DP
    iOS之crash分析篇--捕获signal类型的崩溃信息
    创建型设计模式
    CSS的含义和作用：优化网页外观的编程语言
    安防视频监控平台EasyCVR集成到ios系统不能播放是什么原因？如何解决？
  • 原文地址：https://blog.csdn.net/giiiig/article/details/126221779