1 前言

欢送拜访南瓜慢说 www.pkslow.com获取更多精彩文章！

Kubernetes有专门的ConfigMap和Secret来治理配置，但它也有一些局限性，所以还是心愿通过Spring Cloud Config来治理。在Kubernetes下面的微服务零碎会有所不同，咱们来摸索一下如何整合Spring Cloud Kubernetes来做配置管理。

整体计划与《应用Spring Cloud Config对立治理配置，别再到处放配置文件了》差不多，只是引入Spring Cloud Kubernetes来应用Kubernetes的服务发现，而不应用Eureka等。

2 服务端

引入依赖：

<dependency>  <groupId>org.springframework.cloud</groupId>  <artifactId>spring-cloud-config-server</artifactId>  <version>2.2.0.RELEASE</version></dependency><dependency>  <groupId>org.springframework.cloud</groupId>  <artifactId>spring-cloud-starter-kubernetes</artifactId></dependency>

服务端启动类如下：

package com.pkslow.config;import org.springframework.boot.SpringApplication;import org.springframework.boot.autoconfigure.SpringBootApplication;import org.springframework.cloud.client.discovery.EnableDiscoveryClient;import org.springframework.cloud.config.server.EnableConfigServer;@SpringBootApplication@EnableConfigServer@EnableDiscoveryClientpublic class ConfigServerK8s {    public static void main(String[] args) {        SpringApplication.run(ConfigServerK8s.class, args);    }}

服务端的application.properties配置如下：

server.port=8888spring.application.name=config-server-k8sspring.cloud.config.server.git.uri=https://github.com/pkslow/pkslow-configspring.cloud.config.server.git.username=admin@pkslow.comspring.cloud.config.server.git.password=***spring.cloud.config.server.git.default-label=masterspring.cloud.config.server.git.search-paths=demo

这里的利用名字为config-server-k8s，后续部署到k8s也是用这个名字。

k8s的资源定义文件如下：

apiVersion: apps/v1kind: Deploymentmetadata:  name: config-server-k8s-deploymentspec:  selector:    matchLabels:      app: config-server-k8s  replicas: 1  template:    metadata:      labels:        app: config-server-k8s    spec:      containers:        - name: config-server-k8s          image: pkslow/config-server-k8s:1.0-SNAPSHOT          ports:            - containerPort: 8888---apiVersion: v1kind: Servicemetadata:  labels:    app: config-server-k8s  name: config-server-k8sspec:  ports:    - port: 8888      name: config-server-k8s      protocol: TCP      targetPort: 8888  selector:    app: config-server-k8s  type: ClusterIP---apiVersion: extensions/v1beta1kind: Ingressmetadata:  name: config-server-k8s  annotations:    kubernetes.io/ingress.class: nginxspec:  rules:    - http:        paths:          - path: /            backend:              serviceName: config-server-k8s              servicePort: 8888      host: config-server-k8s.localhost

放弃Service名字对立为config-server-k8s。

3 客户端

引入依赖：

<dependency>  <groupId>org.springframework.boot</groupId>  <artifactId>spring-boot-starter-web</artifactId></dependency><dependency>  <groupId>org.springframework.cloud</groupId>  <artifactId>spring-cloud-starter-kubernetes</artifactId></dependency><dependency>  <groupId>org.springframework.cloud</groupId>  <artifactId>spring-cloud-starter-config</artifactId></dependency><dependency>  <groupId>org.springframework.boot</groupId>  <artifactId>spring-boot-starter-actuator</artifactId></dependency>

spring-cloud-starter-kubernetes为服务发现；

spring-cloud-starter-config作为配置客户端；

spring-boot-starter-actuator提供EndPoint来刷新配置。

启动类为：

package com.pkslow.config;import org.springframework.boot.SpringApplication;import org.springframework.boot.autoconfigure.SpringBootApplication;import org.springframework.cloud.client.discovery.EnableDiscoveryClient;@SpringBootApplication@EnableDiscoveryClientpublic class ConfigClientK8s {    public static void main(String[] args) {        SpringApplication.run(ConfigClientK8s.class, args);    }}

配置文件bootstrap.properties如下：

server.port=8080# 服务名spring.application.name=config-client-k8s# 读取配置时的profilespring.profiles.active=dev# 读取配置时的代码分支spring.cloud.config.label=release# 凋谢刷新接口management.endpoints.web.exposure.include=*management.endpoint.health.show-details=always# 通过服务名找到配置服务器spring.cloud.config.discovery.enabled=truespring.cloud.config.discovery.service-id=config-server-k8s

展现配置后果的Web服务：

package com.pkslow.config;import org.springframework.beans.factory.annotation.Value;import org.springframework.cloud.context.config.annotation.RefreshScope;import org.springframework.web.bind.annotation.GetMapping;import org.springframework.web.bind.annotation.RestController;import java.util.HashMap;import java.util.Map;@RefreshScope@RestControllerpublic class PkslowController {    @Value("${pkslow.age:0}")    private Integer age;    @Value("${pkslow.email:null}")    private String email;    @Value("${pkslow.webSite:null}")    private String webSite;    @GetMapping("/pkslow")    public Map<String, String> getConfig() {        Map<String, String> map = new HashMap<>();        map.put("age", age.toString());        map.put("email", email);        map.put("webSite", webSite);        return map;    }}

客户端的k8s文件：

apiVersion: apps/v1kind: Deploymentmetadata:  name: config-client-k8s-deploymentspec:  selector:    matchLabels:      app: config-client-k8s  replicas: 1  template:    metadata:      labels:        app: config-client-k8s    spec:      containers:        - name: config-client-k8s          image: pkslow/config-client-k8s:1.0-SNAPSHOT          ports:            - containerPort: 8080---apiVersion: v1kind: Servicemetadata:  labels:    app: config-client-k8s  name: config-client-k8sspec:  ports:    - port: 8080      name: config-client-k8s      protocol: TCP      targetPort: 8080  selector:    app: config-client-k8s  type: ClusterIP---apiVersion: extensions/v1beta1kind: Ingressmetadata:  name: config-client-k8s  annotations:    kubernetes.io/ingress.class: nginxspec:  rules:    - http:        paths:          - path: /            backend:              serviceName: config-client-k8s              servicePort: 8080      host: config-client-k8s.localhost

留神Service名字为config-client-k8s。

4 部署与测试

总结一下，服务端次要做了两件事：

（1）提供配置服务，从Github中读取配置；

（2）把本人注册到Kubernetes中去，以让客户端发现并读取配置。

客户端次要做了件事：

（1）作为配置客户端，从服务端读配置；

（2）把本人注册到Kubernetes中去，让服务端能够拜访；

（3）提供刷新配置的性能给外界调用。

依据客户端的名字、配置的label和profile，客户端便会读取release分支的配置文件config-client-k8s-dev.properties的外部。

拜访http://config-client-k8s.localhost/pkslow后果如下：

如果批改了配置信息，客户端不能及时失效，须要通过发送POST申请到http://config-client-k8s.localhost/actuator/refresh，这点不再赘述。

5 服务端对立刷新

如果改了大量配置，或者根底配置，想让所有客户端失效怎么办？总不能一个个去刷新？而且在客户端有多个Pod须要LoadBalance的状况下，无奈确保每个Java利用都能刷新到。

所以让服务去读取所有相干的客户端，并刷新。实现很简略，间接新增一个RefreshController就能够了：

package com.pkslow.config;import org.springframework.beans.factory.annotation.Autowired;import org.springframework.cloud.client.ServiceInstance;import org.springframework.cloud.client.discovery.DiscoveryClient;import org.springframework.http.HttpEntity;import org.springframework.http.HttpHeaders;import org.springframework.http.MediaType;import org.springframework.http.ResponseEntity;import org.springframework.web.bind.annotation.GetMapping;import org.springframework.web.bind.annotation.RestController;import org.springframework.web.client.RestTemplate;import java.util.HashMap;import java.util.List;import java.util.Map;@RestControllerpublic class RefreshController {    @Autowired    private DiscoveryClient discoveryClient;    private RestTemplate rest = new RestTemplate();    @GetMapping("/refresh")    public Map<String, String> refresh() {        Map<String, String> result = new HashMap<>();        List<String> services = discoveryClient.getServices();        result.put("Basic Info", "Total services in k8s:" + services.size());        services.stream()                .filter(s -> (!"config-server-k8s".equals(s)) && s.startsWith("config-client"))                .forEach(service -> {                    List<ServiceInstance> instances = discoveryClient.getInstances(service);                    instances.forEach(instance -> {                        String url = "http://" + instance.getHost() + ":" + instance.getPort() + "/actuator/refresh";                        try {                            HttpHeaders headers = new HttpHeaders();                            headers.setContentType(MediaType.APPLICATION_JSON);                            HttpEntity<String> entity = new HttpEntity<>(null, headers);                            ResponseEntity<String> response = rest.postForEntity(url, entity, String.class);                            result.put(service + " " + url, response.getStatusCode().getReasonPhrase());                        } catch (Exception e) {                            result.put(service + " " + url, e.getMessage());                        }                    });                });        return result;    }}

留神下面的过滤逻辑，因为不是所有Service都能够、都须要refresh，具体逻辑看业务。

申请http://config-server-k8s.localhost/refresh后果如下（把客户端的replicas设置成了3）：

{  "config-client-k8s http://10.1.0.126:8080/actuator/refresh": "OK",  "config-client-k8s http://10.1.0.125:8080/actuator/refresh": "OK",  "Basic Info": "Total services in k8s:7",  "config-client-k8s http://10.1.0.122:8080/actuator/refresh": "OK"}

注：可能会遇到权限有余的问题，创立一个对应的Kubernetes ServiceAccount即可，不分明能够参考：把Spring Cloud Data Flow部署在Kubernetes上，再跑个工作试试

客户端其实不肯定须要引入DiscoveryService，如果不通过Server的ServiceId来寻找地址，而是间接配置服务端地址spring.cloud.config.uri。但服务端是须要的，因为要获取客户端的信息来实现对立reload。

6 总结

配置管理其实是一门大学问，把Spring Cloud Config放在Kubernetes上用只是其中一种场景。

对于配置的一些文章：

Spring Cloud Config在Spring Cloud Task中的利用，比Web利用更简略

Spring Cloud Config整合Spring Cloud Kubernetes，在k8s上治理配置

应用Spring Cloud Config对立治理配置，别再到处放配置文件了

Java怎么从这四个地位读取配置文件Properties（一般文件系统-classpath-jar-URL）

注解@ConfigurationProperties让配置参差而简略

只想用一篇文章记录@Value的应用，不想再找其它了

Springboot整合Jasypt，让配置信息安全最优雅不便的形式

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

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