Kubernetes 开发 SpringCloud (一)、使用SpringCloud Kubernetes组件进行服务发现

Kubernetes 开发 SpringCloud (一)、使用SpringCloud Kubernetes组件进行服务发现

文章目录

  !版权声明:本博客内容均为原创,每篇博文作为知识积累,写博不易,转载请注明出处。


相关博文:

系统环境:

  • Kubernetes 版本:1.14.0
  • SpringCloud Kubernetes 版本:1.0.2.RELEASE
  • 示例部署文件 Github 地址:https://github.com/my-dlq/blog-example/tree/master/springcloud/springcloud-kubernetes/springcloud-kubernetes-discovery-demo

一、介绍

组件简介

       这里主要介绍的是如何在 Kubernetes 中使用 SpringCloud 框架开发 Java 应用,在这个过程中主要使用的组件就是 SpringCloud Kubernetes 来完成服务发现、动态配置,利用 Feign 来进行服务间的通信等。

       这里先简单介绍下 SpringCloud Kubernetes,它主要是提供了使用 Kubernetes 本地服务的 Spring Cloud 通用接口实现。目标是促进 Spring Cloud 和运行在 Kubernetes 中的 Spring Boot 应用程序的集成。

       SpringCloud Kubernetes 能在 Kubernetes 中完成服务发现和配置监听功能主要依赖 Fabric8 提供的 Kubernetes Client 组件,该组件是 Kubernetes Java API 的第三方客户端,它的主要功能是远程操作 Kubernetes API 完成在 Kubernetes 环境下的一系列操作。

功能简介

主要提供以下几种功能:

  • 在 Kubernetes 中实现服务发现、服务名称解析功能。
  • 在 Kubernetes 中读取 ConfigMapsSecrets 的配置,当 ConfigMap 或 Secret 更改时重新加载应用程序属性。
  • 在 Kubernetes 可去掉 Kubernetes 自带的服务负载均衡,实现与 Ribbon 结合,通过 Ribbon 完成负载均衡。

服务发现简介

       在原生的 SpringCloud 中,我们服务发现大多数是通过将服务注册到注册中心(如 Eureka)后通后,各个服务通过连接注册中心,从注册中心定时获取服务列表及服务地址的这种方式完成服务发现。

       在 Kubernetes 中所有的 ServicePod 等信息都会存入 Etcd 中记录,相当于 Ectd 扮演了一个注册中心的角色,并且在 Kubernetes 中能通过 CoreDNS 完成通过 服务名称 + 端口号 方式让各个服务间能相互通信,由此可知我们要是能获一个服务的服务名端口号就能完成服务间的通信工作,所以重点就在如何获取这两个值。

       SpringCloud Kubernetes 这个组件的服务发现目的就是获取上面所述的 Kubernetes 中一个或者多个 Namespace 下的所有 服务列表,且在过滤列表时候设置过滤的 端口号 ,这样获取到服务列表后就能让依赖它们的 SpringBoot 或者其它框架的应用完成服务发现工作,让服务能够通过 http://ServiceName:Port 这种方式进行访问。

综上个人感慨

       综上所述,应用 SpringCloud Kubernetes 作用就是通过它获取 Kubernetes 下的服务列表进行服务发现。故而在这种情况下,没必要在继续坚持在 Kubernetes 上再启动一个 Eureka,然后为了 Eureka 高可用设置为有状态模式 StatefulSet,感觉这有点.....多此一举。

二、环境配置

配置说明

       使用 SrpingCloud Kubernetes 相关组件的服务,在本地测试的时候并不需将程序构建成 Docker 镜像,然后在 Kubernetes 中部署它,因为 SpringCloud Kubernetes 组件依赖于 Fabric8 Kubernetes Java 客户端,可以通过使用 http 协议与 Kubernetes API 进行通信,通过控制 API 来完成一些列操作,所以我们只需要配置 本地环境变量,让其能够有权限调用 Kubernetes API 即可,这样也方便在本地进行程序的调试工作。

配置操作

       这里我们需要平时使用 Kubectl 工具时使用的凭证文件 config 将其放在系统的用户目录中,如果是 Linux 环境且能操作 Kubectl 命令,在该系统中直接用 SpringCloud Kubernetes 组件即可,不过考虑大多数人开发环境是 Windows 系统,本人也是,所以需要将这个 config 复制出来,放到系统的用户目录的 .kube 下面,这里记录下这个操作过程。

由于在用户目录下无法直接创建带"."的文件夹,所以这里打开 cmd 命令行窗口工具,进入个人用户目录,然后创建".kube"文件夹,之后将 config 文件复制到该文件夹下即可。

使用管理员身份打开 Windows 的 cmd 命令行窗口

1Microsoft Windows [版本 10.0.17763.1]
2
3(c) 2018 Microsoft Corporation。 保留所有权利。
4
5c:\Users\mydlq>

使用"cd"命令进入用户目录

1$ cd /users/mydlq

使用"mkdir"命令创建".kube"文件夹

1$ mkdir .kube

将 linux 中的 config 文件拷贝到上面创建的".kube"目录下

这样连接 Kubernetes API 的认证配置环境设置完成,下面将写一个基于 SpringCloud Kubernetes 例子,用于发现 Kubernetes 下的服务列表,测试一下该配置是否能用。

三、SpringCloud Kubernetes 服务发现示例项目

这里用 SpringCloud Kubernetes 中的服务发现组件 spring-cloud-starter-kubernetes 来演示获取 Kubernetes 环境中的 服务列表和服务实例信息。

1、Maven 引入相关变量

在"pom.xml"文件中引入 SpringBoot 与 SpringCloud Kubernetes 相关 Jar。

 1<?xml version="1.0" encoding="UTF-8"?>
 2<project xmlns="http://maven.apache.org/POM/4.0.0" xmlns:xsi="http://www.w3.org/2001/XMLSchema-instance"
 3         xsi:schemaLocation="http://maven.apache.org/POM/4.0.0 http://maven.apache.org/xsd/maven-4.0.0.xsd">
 4    <modelVersion>4.0.0</modelVersion>
 5
 6    <parent>
 7        <groupId>org.springframework.boot</groupId>
 8        <artifactId>spring-boot-starter-parent</artifactId>
 9        <version>2.1.6.RELEASE</version>
10        <relativePath/>
11    </parent>
12
13    <groupId>club.mydlq</groupId>
14    <artifactId>springcloud-k8s-discovery-demo</artifactId>
15    <version>0.0.1</version>
16    <name>springcloud-k8s-discovery-demo</name>
17    <description>SpringCloud Kubernetes Discovery Demo</description>
18
19    <properties>
20        <java.version>1.8</java.version>
21    </properties>
22
23    <dependencies>
24        <!--SpringBoot Web-->
25        <dependency>
26            <groupId>org.springframework.boot</groupId>
27            <artifactId>spring-boot-starter-web</artifactId>
28        </dependency>
29        <!--SpringBoot Actuator-->
30        <dependency>
31            <groupId>org.springframework.boot</groupId>
32            <artifactId>spring-boot-starter-actuator</artifactId>
33        </dependency>
34        <!--SpringCloud Kubernetes Discovery-->
35        <dependency>
36            <groupId>org.springframework.cloud</groupId>
37            <artifactId>spring-cloud-starter-kubernetes</artifactId>
38            <version>1.0.2.RELEASE</version>
39        </dependency>
40    </dependencies>
41
42    <build>
43        <plugins>
44            <plugin>
45                <groupId>org.springframework.boot</groupId>
46                <artifactId>spring-boot-maven-plugin</artifactId>
47            </plugin>
48        </plugins>
49    </build>
50
51</project>

2、创建一个 Controller 类获取服务列表

这里创建一个 /service/instance 两个接口,用于获取连接 Kubernetes 集群配置文件用户所拥有权限的 Namespace 下的所有 Service 列表和服务实例。

 1import org.springframework.beans.factory.annotation.Autowired;
 2import org.springframework.cloud.client.discovery.DiscoveryClient;
 3import org.springframework.web.bind.annotation.*;
 4import java.util.List;
 5
 6@RestController
 7public class ServiceController {
 8
 9    @Autowired
10    private DiscoveryClient discoveryClient;
11
12    @GetMapping("/service")
13    public List<String> getServiceList(){
14        return discoveryClient.getServices();
15    }
16
17    @GetMapping("/instance")
18    public Object getInstance(@RequestParam("name") String name){
19        return discoveryClient.getInstances(name);
20    }
21
22}

3、创建 application 配置文件

创建 application.yaml 配置文件,设置一些 SpringBoot 基本参数和开启服务发现

 1spring:
 2  application:
 3    name: springcloud-kubernetes-discovery-demo
 4  cloud:
 5    kubernetes:
 6      discovery:
 7        enabled: true   #开启服务发现
 8
 9server:
10  port: 8080
11
12management:
13  server:
14    port: 8081
15  endpoints:
16    web:
17      exposure:
18        include: "*"

4、创建启动类并启用服务发现注解

创建一个 SpringBoot 项目的启动类,且引入服务发现注解 @EnableDiscoveryClient。

 1import org.springframework.boot.SpringApplication;
 2import org.springframework.boot.autoconfigure.SpringBootApplication;
 3import org.springframework.cloud.client.discovery.EnableDiscoveryClient;
 4
 5@SpringBootApplication
 6@EnableDiscoveryClient
 7public class Application {
 8
 9    public static void main(String[] args) {
10        SpringApplication.run(Application.class, args);
11    }
12
13}

5、测试接口

上面示例中定义了两个接口分别为:

  • 服务列表发现接口:/service
  • 服务实例信息接口:/instance

这里先访问调用 "/service" 接口获取 Kubernetes 中的服务列表,输入地址:http://localhost:8080/service 可以看到服务列表如下所示:

 1[
 2    "jenkins",
 3    "service-customer",
 4    "service-provider",
 5    "sonatype-nexus",
 6    "springboot-admin-k8s",
 7    "springboot-helloworld",
 8    "springboot-prometheus-demo",
 9    "springcloud-k8s-config",
10    "swagger-kubernetes"
11]

然后再测试 "/instance" 接口,参数 name 输入一个上面服务列表中获取的服务名,这里输入地址:http://localhost:8080/instance?name=springboot-helloworld 可以获得这个服务信息如下所示:

 1[
 2    {
 3        "instanceId": "9950be16-95d3-11e9-a040-000c29d98697",
 4        "serviceId": "springboot-helloworld",
 5        "secure": false,
 6        "metadata": {
 7            "app": "springboot-helloworld",
 8            "port.server": "8080",
 9            "admin": "enabled",
10            "group": "A",
11            "port.management": "8081"
12        },
13        "scheme": "http://",
14        "host": "10.20.2.89",
15        "port": 8081,
16        "uri": "http://10.20.2.89:8081"
17    }
18]

由上可知通过 spring-cloud-starter-kubernetes 组件能够发现服务所在当前 Namespace 下的所有 Service 列表,且能够通过 Service名称 获取服务的基本信息。

四、服务发现可配参数

下面将介绍下 SpringCloud Kubernetes 服务发现组件有哪些基本参数可用进行配置。

1、可配置参数表

在 SpringCloud Kubernetes 官方 Github 和对应说明文档中并没有发现"服务发现"模块的配置参数,所以无奈本人只好自己查看 SpringCloud Kubernetes 的源码,分析它可配置的参数并且用 Debug 模式对这些参数进行效验,总结出下面这些配置参数和用法。

参数名称 类型 默认值 参数描述
spring.cloud.kubernetes.discovery.enabled Boolean true 是否启用服务发现
spring.cloud.kubernetes.discovery.filter String "" 从 Kubernetes 获取 Service 列表的过滤条件,通过Spring EL表达式来写
spring.cloud.kubernetes.discovery.serviceLabels Map "" 指定特定 Label 的 Service 通过筛选,为空则不根据 Label 进行筛选
spring.cloud.kubernetes.discovery.primaryPortName String "" 指定允许通过筛选的 Service 端口名称,为空则默认添加全部端口
spring.cloud.kubernetes.discovery.knownSecurePorts Set 443,8443 指定 Kubernetes 的安全端口列表
spring.cloud.kubernetes.discovery.metadata.addLabels Boolean true 是否获取服务实例后,在 Label 前面添加前缀
spring.cloud.kubernetes.discovery.metadata.labelsPrefix String "" 设置获取服务实例后往其 Label 添加前缀的值
spring.cloud.kubernetes.discovery.metadata.addAnnotations Boolean true 是否获取服务实例后,在 Annotations 前面添加前缀
spring.cloud.kubernetes.discovery.metadata.annotationsPrefix String "" 设置获取服务实例后往其 Annotations 添加前缀的值
spring.cloud.kubernetes.discovery.metadata.addPorts Boolean true 是否获取服务实例后,在 Ports 前面添加前缀
spring.cloud.kubernetes.discovery.metadata.portsPrefix String "" 设置获取服务实例后往其 Ports 添加前缀的值

2、配置参数说明及示例

(1)、开启服务发现

  • 参数:spring.cloud.kubernetes.discovery.enabled
  • 可配参数:false、true
  • 参数描述:是否开启 SpringCloud Kubernetes 服务发现。
  • 例子:

开启服务发现:

1spring:
2  cloud:
3    kubernetes:
4      discovery:
5        enabled: true

关闭服务发现:

1spring:
2  cloud:
3    kubernetes:
4      discovery:
5        enabled: false

(2)、配置标签过滤服务

  • 参数:spring.cloud.kubernetes.discovery.serviceLabels
  • 可配参数:k8s Service 的 metadata 中的 Label 属性。
  • 参数描述:可以通过设置该参数,根据该参数的 Label 键值对来过滤 Kubernetes 服务发现列表,如果服务不带设置的标签就将服务过滤掉。
  • 例子:

例如 Kubernetes 中有两个 Service 对象,内容如下:

Service A:

 1kind: Service
 2apiVersion: v1
 3metadata:
 4  name: service-A
 5  namespace: mydlqcloud
 6  labels:
 7    app: service-A
 8    group: A
 9spec:
10  type: ClusterIP
11  ports:
12    - name: server
13      port: 8080
14      targetPort: 8080
15  selector:
16    app: service-A

Service B:

 1kind: Service
 2apiVersion: v1
 3metadata:
 4  name: service-B
 5  namespace: mydlqcloud
 6  labels:
 7    app: service-B
 8    group: B
 9spec:
10  type: ClusterIP
11  ports:
12    - name: server 
13      port: 8080
14      targetPort: 8080
15  selector:
16    app: service-B

在 SpringCloud Kubernetes 服务发现例子中配置serviceLabels参数来完成只发现带"group:A"标签的服务,然后进行效果验证:

  • 配置:
1spring:
2  cloud:
3    kubernetes:
4      discovery:
5        enabled: true
6        serviceLabels:
7          group: A          #只发现带 group:A 的标签的服务

运行程序得出结论: 服务发现列表中只有 Service A,说明只服务发现带"group:A"标签的服务。

(3)、配置端口过滤服务

  • 参数:spring.cloud.kubernetes.discovery.primaryPortName
  • 可配参数:k8s Service 的 Ports 的 name 属性。
  • 参数描述:如果该 Service 只有一个端口则直接设置该端口为服务发现端口。如果存在多个端口则利用配置的端口名和 Service 的端口名称进行匹配,如果匹配上就设置该端口为服务发现端口,如果都没有匹配上,则过滤掉此服务。
  • 例子:

例如 Kubernetes 中有两个 Service 对象,内容如下:

Service A:

 1kind: Service
 2apiVersion: v1
 3metadata:
 4  name: service-A
 5  namespace: mydlqcloud
 6  labels:
 7    app: service-A
 8spec:
 9  type: ClusterIP
10  ports:
11    - name: server      #只设置一个端口
12      port: 8080
13      targetPort: 8080
14  selector:
15    app: service-A

Service B:

 1kind: Service
 2apiVersion: v1
 3metadata:
 4  name: service-B
 5  namespace: mydlqcloud
 6  labels:
 7    app: service-B
 8spec:
 9  type: ClusterIP
10  ports:
11    - name: server      #端口1
12      port: 8080
13      targetPort: 8080
14    - name: management  #端口2
15      port: 8081
16      targetPort: 8081
17  selector:
18    app: service-B

在 SpringCloud Kubernetes 服务发现例子中设置三个配置,然后进行效果验证:

  • 配置1:设置过滤端口名为 server。
  • 配置2:设置过滤端口名为 management。
  • 配置3:设置过滤端口名为两个 Service 中都不存在的端口名。

配置1:

1spring:
2  cloud:
3    kubernetes:
4      discovery:
5        enabled: true
6        primaryPortName: server     #Service A、Service B 都存在的端口名

配置2:

1spring:
2  cloud:
3    kubernetes:
4      discovery:
5        enabled: true
6        primaryPortName: management  #Service B 存在的端口名

配置3:

1spring:
2  cloud:
3    kubernetes:
4      discovery:
5        enabled: true
6        primaryPortName: none        #两个service都不存在的端口名

然后进行效果验证,得到下面结论:

  • 配置1:发现 Service A (端口名:server) 与 Service B (端口名:server) 服务实例。
  • 配置2:发现 Service A (端口名:server) 与 Service B (端口名:management) 服务实例。
  • 配置3:发现 Service A (端口名:server) 服务实例。

由此可知,当服务只存在一个端口时候,直接设置为服务发现端口,如果存在多个端口,则和设置参数中输入的端口名进行匹配来筛选服务发现端口,如果都未匹配上则过滤该服务。一般此配置参数和上一个的过滤标签参数配合使用。

(4)、通过 SpringEL 表达式过滤服务

  • 参数:spring.cloud.kubernetes.discovery.filter
  • 可配参数:SpringEL 中 Boolean 类型的表达式,表达式中的值只能为 Kubernetes Service 对象中存在的参数。
  • 参数描述:可以通过在参数中写一段 SpringEL Boolean 类型的表达式来过滤服务,如果发现的服务实例中对象参数中的值在 SpringEL 表达式中为 true,则将该服务加入服务发现类别,为 false 则过滤掉该服务。
  • 例子:

这里展示一个 Kubernetes 中的 Service,然后写 SpringEL 表达式来验证该服务是否能加入服务发现列表。

 1kind: Service
 2apiVersion: v1
 3metadata:
 4  name: service-A
 5  namespace: mydlqcloud
 6  labels:
 7    app: service-A
 8spec:
 9  type: ClusterIP
10  ports:
11    - name: server
12      port: 8080
13      targetPort: 8080
14  selector:
15    app: service-A

在 SpringCloud Kubernetes 服务发现例子中设置几个不同的 SpringEL 表达式配置进行验证:

  • 配置1:发现服务名不为 service-A 的所有服务
  • 配置2:发现服务中包含一个或两个端口的所有服务
  • 配置3:发现服务类型为 NodePort 的所有服务

配置1:

1spring:
2  cloud:
3    kubernetes:
4      discovery:
5        enabled: true
6        filter: "metadata.name != 'service-A'"

配置2:

1spring:
2  cloud:
3    kubernetes:
4      discovery:
5        enabled: true
6        filter: "spec.ports.size() == 1 or spec.ports.size() == 2"

配置3:

1spring:
2  cloud:
3    kubernetes:
4      discovery:
5        enabled: true
6        filter: "spec.type == 'NodePort'"

由于本人对 SpringEL 表达式并不精通,为了测试表达式是否正确只能查看源码,然后根据其验证模式,模拟创建 Service 实例,然后进行 SpringEL 表达式验证这个过程,可以在这个过程中验证自己写的 SpringEL 表达式是否能和 Service实例 匹配上,具体代码如下所示:

 1import io.fabric8.kubernetes.api.model.*;
 2import org.springframework.expression.ExpressionParser;
 3import org.springframework.expression.spel.standard.SpelExpressionParser;
 4import org.springframework.expression.spel.support.SimpleEvaluationContext;
 5import java.util.ArrayList;
 6import java.util.HashMap;
 7import java.util.List;
 8import java.util.Map;
 9
10/**
11 * 测试 SpringEL 表达式
12 */
13public class SpringEL {
14
15    public static void main(String[] args) {
16        // 输入待验证的表达式
17        String springEL = "metadata.name == 'test-project'";
18        // 创建模拟的 Service 对象
19        Service service = createService();
20        // 验证 SpringEL 表达式和对象中现有的值是否匹配
21        boolean isTrue = verification(service,springEL);
22        //输出结果
23        System.out.println(isTrue);
24    }
25
26    /**
27     * 创建模拟的 Service 对象,和 SpringCloud Kubernetes 服务发现实例保持一致
28     * @return
29     */
30    static Service createService(){
31        /** 设置Status **/
32        ServiceStatus serviceStatus = new ServiceStatus();
33        serviceStatus.setLoadBalancer(new LoadBalancerStatus());
34        /** 设置Spec **/
35        ServiceSpec serviceSpec = new ServiceSpec();
36        serviceSpec.setClusterIP("10.10.1.11");
37        // 设置type
38        serviceSpec.setType("NodePort");
39        // 设置 Selector
40        Map selector = new HashMap();
41        selector.put("app", "test-project");
42        serviceSpec.setSelector(selector);
43        // 设置端口1
44        ServicePort servicePort1 = new ServicePort();
45        servicePort1.setName("server");
46        servicePort1.setPort(8080);
47        servicePort1.setNodePort(30080);
48        servicePort1.setProtocol("TCP");
49        servicePort1.setTargetPort(new IntOrString("8080"));
50        // 设置端口2
51        ServicePort servicePort2 = new ServicePort();
52        servicePort2.setName("management  ");
53        servicePort2.setPort(8081);
54        servicePort2.setNodePort(30081);
55        servicePort2.setProtocol("TCP");
56        servicePort2.setTargetPort(new IntOrString("8081"));
57        // 将两个端口加如Spec
58        List<ServicePort> servicePortList = new ArrayList<>();
59        servicePortList.add(servicePort1);
60        servicePortList.add(servicePort2);
61        serviceSpec.setPorts(servicePortList);
62        /** 设置 Metadata **/
63        ObjectMeta objectMeta = new ObjectMeta();
64        objectMeta.setName("test-project");
65        objectMeta.setNamespace("mydlqcloud");
66        // 设置Label
67        Map labels = new HashMap();
68        labels.put("app", "test-project");
69        labels.put("group", "b");
70        objectMeta.setLabels(labels);
71        objectMeta.setResourceVersion("3373499");
72        objectMeta.setCreationTimestamp("2019-06-23T16:24:39Z");
73        /** 设置Service **/
74        Service service = new Service();
75        service.setKind("Service");
76        service.setApiVersion("v1");
77        service.setStatus(serviceStatus);
78        service.setSpec(serviceSpec);
79        service.setMetadata(objectMeta);
80        return service;
81    }
82
83    /**
84     * 使用 SpringEL 表达式测试 filter
85     * @param object
86     * @param springEL
87     * @return
88     */
89    static boolean verification(Object object,String springEL){
90        // 创建上下文环境
91        SimpleEvaluationContext evalCtxt = SimpleEvaluationContext.forReadOnlyDataBinding().withInstanceMethods().build();
92        // 创建SpEL表达式的解析器
93        ExpressionParser parser = new SpelExpressionParser();
94        // 验证表达式验证内容是否和对象中的值匹配并返回 Boolean 结果
95        return parser.parseExpression(springEL).getValue(evalCtxt, object, Boolean.class);
96    }
97
98}

五、源码分析

1、服务发现实现类源码

  1public class KubernetesDiscoveryClient implements DiscoveryClient {
  2
  3    ......
  4
  5    /**
  6     * 获取描述信息,默认为下面固定的字符串
  7     * @return
  8     */
  9    @Override
 10    public String description() {
 11        return "Kubernetes Discovery Client";
 12    }
 13    
 14    /**
 15     * 获取服务实例列表
 16     * @param  serviceId K8S 中的 Service 名称
 17     * @return
 18     */
 19    @Override
 20    public List<ServiceInstance> getInstances(String serviceId) {
 21        Assert.notNull(serviceId,"[Assertion failed] - the object argument must not be null");
 22        // 根据服务名查找 K8S 中 endpoints 信息和 EndpointSubset 列表
 23        Endpoints endpoints = this.client.endpoints().withName(serviceId).get();
 24        List<EndpointSubset> subsets = getSubsetsFromEndpoints(endpoints);
 25        // 创建 ServiceInstance 列表,用于存储通过 API 获取过来的 Service 实例信息
 26        List<ServiceInstance> instances = new ArrayList<>();
 27        // 判断 Subsets 是否为空,为空则代表 Endpoints 没有关联的 Pod,相当于 Service 是没有关联 Pod 的无效服务
 28        if (!subsets.isEmpty()) {
 29            // 获取 Service 信息、Service Metadata 数据、和自定义参数对象 properties 中的 metadataProps 参数
 30            final Service service = this.client.services().withName(serviceId).get();
 31            final Map<String, String> serviceMetadata = new HashMap<>();
 32            KubernetesDiscoveryProperties.Metadata metadataProps = this.properties.getMetadata();
 33            // 根据配置文件中是否设置 isAddLabels 来决定是否将自定义 Annotations 加入到 serviceMetadata
 34            if (metadataProps.isAddLabels()) {
 35                Map<String, String> labelMetadata = getMapWithPrefixedKeys(
 36                        service.getMetadata().getLabels(),
 37                        metadataProps.getLabelsPrefix());
 38                if (log.isDebugEnabled()) {
 39                    log.debug("Adding label metadata: " + labelMetadata);
 40                }
 41                serviceMetadata.putAll(labelMetadata);
 42            }
 43            // 根据配置文件中是否设置 isAddAnnotations 来决定是否将自定义 Annotations 加入到 serviceMetadata
 44            if (metadataProps.isAddAnnotations()) {
 45                Map<String, String> annotationMetadata = getMapWithPrefixedKeys(
 46                        service.getMetadata().getAnnotations(),
 47                        metadataProps.getAnnotationsPrefix());
 48                if (log.isDebugEnabled()) {
 49                    log.debug("Adding annotation metadata: " + annotationMetadata);
 50                }
 51                serviceMetadata.putAll(annotationMetadata);
 52            }
 53            // 循环 EndpointSubset 获取部分参数拼凑 KubernetesServiceInstance 对象
 54            for (EndpointSubset s : subsets) {
 55                Map<String, String> endpointMetadata = new HashMap<>(serviceMetadata);
 56                // 检测参数是否设置 isAddPorts 参数,将自定义端口前缀加入到默认端口名前
 57                if (metadataProps.isAddPorts()) {
 58                    // 获取端口列表 Map
 59                    Map<String, String> ports = s.getPorts().stream()
 60                            .filter(port -> !StringUtils.isEmpty(port.getName()))
 61                            .collect(toMap(EndpointPort::getName,port -> Integer.toString(port.getPort())));
 62                    // 设置自定义前缀,设置 portMetadata Map 的 Key 改成(prefix + key)
 63                    Map<String, String> portMetadata = getMapWithPrefixedKeys(ports,metadataProps.getPortsPrefix());
 64                    if (log.isDebugEnabled()) {
 65                        log.debug("Adding port metadata: " + portMetadata);
 66                    }
 67                    endpointMetadata.putAll(portMetadata);
 68                }
 69                // 一个 Subset 中包含多个 Address 地址,从 EndpointSubset 中获取 addresses 列表
 70                List<EndpointAddress> addresses = s.getAddresses();
 71                // 根据 Address 循环获取 UID 和端口列表,然后拼接服务实例对象 KubernetesServiceInstance
 72                for (EndpointAddress endpointAddress : addresses) {
 73                    String instanceId = null;
 74                    if (endpointAddress.getTargetRef() != null) {
 75                        instanceId = endpointAddress.getTargetRef().getUid();
 76                    }
 77                    EndpointPort endpointPort = findEndpointPort(s);
 78                    // 通过上面获取的部分数据来拼接服务实例对象
 79                    instances.add(new KubernetesServiceInstance(instanceId, serviceId,
 80                            endpointAddress, endpointPort, endpointMetadata,
 81                            this.isServicePortSecureResolver
 82                                    .resolve(new DefaultIsServicePortSecureResolver.Input(
 83                                            endpointPort.getPort(),
 84                                            service.getMetadata().getName(),
 85                                            service.getMetadata().getLabels(),
 86                                            service.getMetadata().getAnnotations()))));
 87                }
 88            }
 89        }
 90        return instances;
 91    }
 92
 93    /**
 94     * 从 EndpointSubset 获取端口号列表
 95     * @param  s EndpointSubset 
 96     * @return
 97     */
 98    private EndpointPort findEndpointPort(EndpointSubset s) {
 99        // 获取端口号列表
100        List<EndpointPort> ports = s.getPorts();
101        EndpointPort endpointPort;
102        // 判断端口号数量,如果只有一个端口,就直接获取下标0的端口号
103        if (ports.size() == 1) {
104            endpointPort = ports.get(0);
105        }
106        else {
107            // 如果存在多个端口号,就以此根据 properties 中设置的 "PrimaryPortName" 参数,
108            // 根据这个参数值和 Service 端口名对比来过滤端口号。
109            Predicate<EndpointPort> portPredicate;
110            if (!StringUtils.isEmpty(properties.getPrimaryPortName())) {
111                portPredicate = port -> properties.getPrimaryPortName()
112                        .equalsIgnoreCase(port.getName());
113            }
114            // 如果为未设置筛选端口名称参数,则默认都为 true,都加入端口列表
115            else {
116                portPredicate = port -> true;
117            }
118            // 根据上面 boolean 值,来过滤端口号
119            endpointPort = ports.stream().filter(portPredicate).findAny()
120                    .orElseThrow(IllegalStateException::new);
121        }
122        return endpointPort;
123    }
124
125    /**
126     * 从 Endpoints 中获取 Subset
127     * @param  endpoints endpoints 对象
128     * @return 
129     */
130    private List<EndpointSubset> getSubsetsFromEndpoints(Endpoints endpoints) {
131        if (endpoints == null) {
132            return new ArrayList<>();
133        }
134        if (endpoints.getSubsets() == null) {
135            return new ArrayList<>();
136        }
137        return endpoints.getSubsets();
138    }
139
140    /**
141     * 如果自定义参数中设置了前缀,如 label前缀、port前缀、annotation前缀等,就将获取的示例信息对应的key前加上这个前缀
142     * @param  map    端口 map 集合
143     * @param  prefix 自定义端口名称前缀
144     * @return  
145     */
146    private Map<String, String> getMapWithPrefixedKeys(Map<String, String> map,String prefix) {
147        if (map == null) {
148            return new HashMap<>();
149        }
150        if (!StringUtils.hasText(prefix)) {
151            return map;
152        }
153        final Map<String, String> result = new HashMap<>();
154        map.forEach((k, v) -> result.put(prefix + k, v));
155        return result;
156    }
157
158    /**
159     * 获取经过 filter 中 springEL 表达式过滤后的服务列表
160     * @return 
161     */
162    @Override
163    public List<String> getServices() {
164        // 从参数配置类中获取 filter 中的 SprngEL 表达式
165        String spelExpression = this.properties.getFilter();
166        Predicate<Service> filteredServices;
167        // 如果未设置 filter 参数,则不过滤任何服务
168        if (spelExpression == null || spelExpression.isEmpty()) {
169            filteredServices = (Service instance) -> true;
170        }
171        // 如果设置 filter 参数,则根据 filter 中的 SpringEL 表达式进行验证,符合则为 true 否则为 false
172        else {
173            Expression filterExpr = this.parser.parseExpression(spelExpression);
174            filteredServices = (Service instance) -> {
175                Boolean include = filterExpr.getValue(this.evalCtxt, instance,
176                        Boolean.class);
177                if (include == null) {
178                    return false;
179                }
180                return include;
181            };
182        }
183        // 过滤服务,然后返回过滤后的服务列表
184        return getServices(filteredServices);
185    }
186
187    /**
188     * 根据 filter 过滤服务列表
189     * @param  filter 过滤列表
190     * @return      
191     */
192    public List<String> getServices(Predicate<Service> filter) {
193        return this.kubernetesClientServicesFunction.apply(this.client).list().getItems()
194                .stream().filter(filter).map(s -> s.getMetadata().getName())
195                .collect(Collectors.toList());
196    }
197
198}

2、服务发现参数配置类源码

  1@ConfigurationProperties("spring.cloud.kubernetes.discovery")
  2public class KubernetesDiscoveryProperties {
  3
  4    /** 设置为 true 则启动服务发现 */
  5    private boolean enabled = true;
  6
  7    /** 本地服务实例的名称。 */
  8    @Value("${spring.application.name:unknown}")
  9    private String serviceName = "unknown";
 10
 11    /**
 12     * 在从Kubernetes API服务器检索到服务之后过滤服务的SpEL表达式。
 13     */
 14    private String filter;
 15
 16    /** 设置使用HTTPS的安全端口。 */
 17    private Set<Integer> knownSecurePorts = new HashSet<Integer>() {
 18        {
 19            add(443);
 20            add(8443);
 21        }
 22    };
 23
 24    /**
 25     * 如果设置了,则只从Kubernetes API服务器获取与这些标签匹配的服务。
 26     */
 27    private Map<String, String> serviceLabels = new HashMap<>();
 28
 29    /**
 30     * 如果设置了该端口,则当为服务定义多个端口时,使用具有给定名称的端口作为主要端口。
 31     */
 32    private String primaryPortName;
 33
 34    private Metadata metadata = new Metadata();
 35
 36    public boolean isEnabled() {
 37        return this.enabled;
 38    }
 39
 40    public void setEnabled(boolean enabled) {
 41        this.enabled = enabled;
 42    }
 43
 44    public String getServiceName() {
 45        return this.serviceName;
 46    }
 47
 48    public void setServiceName(String serviceName) {
 49        this.serviceName = serviceName;
 50    }
 51
 52    public String getFilter() {
 53        return this.filter;
 54    }
 55
 56    public void setFilter(String filter) {
 57        this.filter = filter;
 58    }
 59
 60    public Set<Integer> getKnownSecurePorts() {
 61        return this.knownSecurePorts;
 62    }
 63
 64    public void setKnownSecurePorts(Set<Integer> knownSecurePorts) {
 65        this.knownSecurePorts = knownSecurePorts;
 66    }
 67
 68    public Map<String, String> getServiceLabels() {
 69        return this.serviceLabels;
 70    }
 71
 72    public void setServiceLabels(Map<String, String> serviceLabels) {
 73        this.serviceLabels = serviceLabels;
 74    }
 75
 76    public String getPrimaryPortName() {
 77        return primaryPortName;
 78    }
 79
 80    public void setPrimaryPortName(String primaryPortName) {
 81        this.primaryPortName = primaryPortName;
 82    }
 83
 84    public Metadata getMetadata() {
 85        return this.metadata;
 86    }
 87
 88    public void setMetadata(Metadata metadata) {
 89        this.metadata = metadata;
 90    }
 91
 92    @Override
 93    public String toString() {
 94        return new ToStringCreator(this).append("enabled", this.enabled)
 95                .append("serviceName", this.serviceName).append("filter", this.filter)
 96                .append("knownSecurePorts", this.knownSecurePorts)
 97                .append("serviceLabels", this.serviceLabels)
 98                .append("metadata", this.metadata).toString();
 99    }
100
101    /**
102     * Metadata 配置项
103     */
104    public class Metadata {
105
106        /**
107         * 设置好后,服务的Kubernetes标签将包含在返回的ServiceInstance的metadata中。
108         */
109        private boolean addLabels = true;
110
111        /**
112         * 当设置addtags时,这将用作metadata映射中键名的前缀。
113         */
114        private String labelsPrefix;
115
116        /**
117         * 设置好后,服务的Kubernetes注释将包含为返回的ServiceInstance的元数据。
118         */
119        private boolean addAnnotations = true;
120
121        /**
122         * 当设置addAnnotations时,它将用作metadata映射中键名的前缀。
123         */
124        private String annotationsPrefix;
125
126        /**
127         * 设置好后,任何已命名的Kubernetes服务端口都将包含ServiceInstance的metadata数据。
128         */
129        private boolean addPorts = true;
130
131        /**
132         * 当设置addPorts时,这将用作 metadata 映射中键名的前缀。
133         */
134        private String portsPrefix = "port.";
135
136        public boolean isAddLabels() {
137            return this.addLabels;
138        }
139        public void setAddLabels(boolean addLabels) {
140            this.addLabels = addLabels;
141        }
142        public String getLabelsPrefix() {
143            return this.labelsPrefix;
144        }
145        public void setLabelsPrefix(String labelsPrefix) {
146            this.labelsPrefix = labelsPrefix;
147        }
148        public boolean isAddAnnotations() {
149            return this.addAnnotations;
150        }
151        public void setAddAnnotations(boolean addAnnotations) {
152            this.addAnnotations = addAnnotations;
153        }
154        public String getAnnotationsPrefix() {
155            return this.annotationsPrefix;
156        }
157        public void setAnnotationsPrefix(String annotationsPrefix) {
158            this.annotationsPrefix = annotationsPrefix;
159        }
160        public boolean isAddPorts() {
161            return this.addPorts;
162        }
163        public void setAddPorts(boolean addPorts) {
164            this.addPorts = addPorts;
165        }
166        public String getPortsPrefix() {
167            return this.portsPrefix;
168        }
169        public void setPortsPrefix(String portsPrefix) {
170            this.portsPrefix = portsPrefix;
171        }
172
173        @Override
174        public String toString() {
175            return new ToStringCreator(this).append("addLabels", this.addLabels)
176                    .append("labelsPrefix", this.labelsPrefix)
177                    .append("addAnnotations", this.addAnnotations)
178                    .append("annotationsPrefix", this.annotationsPrefix)
179                    .append("addPorts", this.addPorts)
180                    .append("portsPrefix", this.portsPrefix).toString();
181        }
182    }
183}

---END---


  !版权声明:本博客内容均为原创,每篇博文作为知识积累,写博不易,转载请注明出处。