Spring-Cloud之Config配置中心-7

　　一、我们前面基本上都是讲解的Spring Cloud Netflix的组件，下面我们会重点说Spring Cloud Config分布式配置中心。为什么需要这个组件来管理配置呢？在分布式应用开发过程中我们的大小服务会特别多，如果一个个去配置的话会带来更多的工作量，所以Spring Cloud 催生一种集中配置的方式，这种方式就是Config组件。这个主键主要介绍一下几个部分。

　　1）Config Server从本地读取配置。

　　2）Config Server从远程仓库Git上面读取配置。

　　3）搭建高可用的Config Server集群。

　　4）使用Spring Cloud Bus刷新配置。

　　二、Config Server从本地读取配置。

　　1、Config Server编写。

　　1）首先在Springboot和SpringCloud的基础上加入一下依赖。

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

　　2）编写启动项

package com.cetc;

import org.springframework.boot.SpringApplication;
import org.springframework.boot.autoconfigure.SpringBootApplication;
import org.springframework.cloud.config.server.EnableConfigServer;

@SpringBootApplication
@EnableConfigServer
public class ConfigServerApplication {

    public static void main(String[] args) {
        SpringApplication.run(ConfigServerApplication.class, args);
    }
}

　　3）编写配置application.yaml

server:
  port: 8683
#  port: 8684
spring:
  application:
    name: config-server
  cloud:
    config:
      server:
        native:
          search-locations: classpath:/shared # 指定本地配置目录
  profiles:
    active: native # 本地读取配置

　　说明：这里profiles.active这里一定要配置native从本地读取。spring.cloud.server.native.search-locations为指定扫描的路径。

　　4）编写需要配置的客户端配置文件config-client.yaml

server:
  port: 8685
version: 1.0

　　说明：config-client必须和服务名称一样。如何存在不同环境，比如：dev,test,prod等环境。可以通过spring.profiles.active来激活指定文件。

　　服务端的配置就完成了。那么下面编写客户端。

　　2、编写Config Client客户端。

　　1）加入相关配置pom.xml

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

　　2）编写启动项和测试接口。

package com.cetc;

import org.springframework.boot.SpringApplication;
import org.springframework.boot.autoconfigure.SpringBootApplication;

@SpringBootApplication
public class ConfigClientApplication {

    public static void main(String[] args) {
        SpringApplication.run(ConfigClientApplication.class, args);
    }
}

package com.cetc.web.rest;

import org.springframework.beans.factory.annotation.Value;import org.springframework.web.bind.annotation.GetMapping;
import org.springframework.web.bind.annotation.RequestMapping;
import org.springframework.web.bind.annotation.RestController;

@RestController
@RequestMapping("/api/test")
public class TestResource {

    @Value("${version}")
    private String version;

    @GetMapping("/getVersion")
    public String getVersion() {
        return version;
    }
}

　　3）重点来了，这里我们不编写application.yaml类似的文件了，这里我们使用bootstrap.yaml。为什么是bootstrap.yaml，因为bootstrap相对于application有优先执行权。

spring:
  application:
    name: config-client
  cloud:
    config:
      uri: http://127.0.0.1:8683
      fail-fast: true

　　说明：这里的spring.cloud.config的uri为服务配置地址。fail-fast为快速失败配置。

　　3、测试。启动Config Server、Config Client端口为8683,8685。

　　Config Client启动过程节点。

　　测试接口：

　　三、Config Server从Git仓库获取配置文件。可以自己使用github，也可以自己打架gitlab服务。我这里是自己搭建的gitlab。

　　1）上面的工程基本上都是一样的，需要修改的地方就是Config Server 的application.yaml配置文件，修改如下：

server:
  port: 8683
#  port: 8684
spring:
  application:
    name: config-server
  cloud:
    config:
      server:
        git:
          uri: http://127.0.0.1/lilin/SpringCloudConfig.git
          search-paths: shared
          username: lilin
          password:
      label: master

　　说明：一般配置文件都是私有的，所以一般都是使用账号登录，如果需要公开的可以使用github等方式。label：为那个分支。search-paths为搜索路径。

　　2）在Git上面编写config-client.yaml配置文件，为了方便我把之前的传上Git了。

　　3）启动Config Server和Config Client，端口8683,8685。

　　Config Server的展示如下：

　　客户端和从本地获取没有什么区别。

　　测试接口如下：

　　四、构建高可用的Config Server集群。为了方便管理，配置采用注册方式，所以需要加入Eureka服务注册中心。这里我们还是使用以前的注册中心Eureka Server端口8670。结构图如下

　　1、改造Config Server

　　1）在上面工程中，加入Eureka Client依赖。

        <dependency>
            <groupId>org.springframework.cloud</groupId>
            <artifactId>spring-cloud-starter-netflix-eureka-client</artifactId>
        </dependency>

　　2）在上面工程中，加入启动配置

package com.cetc;

import org.springframework.boot.SpringApplication;
import org.springframework.boot.autoconfigure.SpringBootApplication;
import org.springframework.cloud.config.server.EnableConfigServer;
import org.springframework.cloud.netflix.eureka.EnableEurekaClient;

@SpringBootApplication
@EnableConfigServer
@EnableEurekaClient
public class ConfigServerApplication {

    public static void main(String[] args) {
        SpringApplication.run(ConfigServerApplication.class, args);
    }
}

　　3）在上面工程基础上，修改配置。

server:
  port: 8683
#  port: 8684
spring:
  application:
    name: config-server
  cloud:
    config:
      server:
        git:
          uri: http://127.0.0.1/lilin/SpringCloudConfig.git
          search-paths: shared
          username: lilin
          password:
      label: master
eureka:
  client:
    service-url:
      defaultZone:
        http://127.0.0.1:8670/eureka/ # 实际开发中建议使用域名的方式

　　2、改造Config Client.

　　1）在上面工程基础上，加入Euraka Client依赖。

        <dependency>
            <groupId>org.springframework.cloud</groupId>
            <artifactId>spring-cloud-starter-netflix-eureka-client</artifactId>
        </dependency>

　　2）在上面工程基础上，修改启动项。

package com.cetc;

import org.springframework.boot.SpringApplication;
import org.springframework.boot.autoconfigure.SpringBootApplication;
import org.springframework.cloud.netflix.eureka.EnableEurekaClient;

@SpringBootApplication
@EnableEurekaClient
public class ConfigClientApplication {

    public static void main(String[] args) {
        SpringApplication.run(ConfigClientApplication.class, args);
    }
}

　　3）修改bootstrap.yaml配置文件。

spring:
  application:
    name: config-client
  cloud:
    config:
      fail-fast: true
      discovery:
        enabled: true
        service-id: config-server
eureka:
  client:
    service-url:
      defaultZone:
        http://127.0.0.1:8670/eureka/ # 实际开发中建议使用域名的方式

　　3、启动Eureka Server、2个Config Server、Config Client。端口8670,8683/8684、8685。

　　可以得知，启动一切正常。

　　测试接口：

　　五、使用Spring Cloud bus刷新配置。

　　1）简介：Spring Cloud Bus 是用轻量的消息代理将分布式的节点连接起来，可以用于广播配置文件的更改或者服务的监控管理。一个关键的意思就是，消息总线可以为微服务总监控，也可以实现应用之间的通信。Spring Cloud Bus 可以选择的组件有RabbitMQ，AMQP和Kafka等。我们这里使用RabbitMQ来实现消息总线的管理。

　　2）为什么需要Spring Cloud Bus去刷新配置呢？如果有几十个微服务，并且每个微服务都存在很多实例，当更改配置时，需要重启很多微服务实例，会特别麻烦。Spring Cloud Bus就将这个过程进行了简化，当远程Git配置文件修改后，我们只需要向某一个微服务实例发送一个POST请求，通过消息组件通知其他微服务重新拉取配置文件。请求接口为：/actuator/bus-refresh（不同版本可能存在差异）。

　　3）我们开始改造Config Client。

　　（1）首先需要加入两个依赖。

        <dependency>
            <groupId>org.springframework.cloud</groupId>
            <artifactId>spring-cloud-starter-bus-amqp</artifactId>
        </dependency>
        <dependency>
            <groupId>org.springframework.boot</groupId>
            <artifactId>spring-boot-starter-actuator</artifactId>
        </dependency>

　　（2）修改配置文件bootstrap.yaml。

spring:
  application:
    name: config-client
  cloud:
    config:
      fail-fast: true
      discovery:
        enabled: true
        service-id: config-server
  rabbitmq:
    host: 127.0.0.1
    port: 5672
    username: admin
    password: admin
eureka:
  client:
    service-url:
      defaultZone:
        http://127.0.0.1:8670/eureka/ # 实际开发中建议使用域名的方式
management:
  endpoints:
    web:
      exposure:
        include: ["*"]

　　说明：目前Spring 2.0版本是通过actuator的接口进行外部访问的所以在使用的时候，一定要配置management.endpoints.web.exposure.include。

　　（3）在需要刷新配置的地方加入@RefreshScope注解，注意这个注解只针对于当前类生效。我们这里是获取的版本号所以在TestResource类加上。

package com.cetc.web.rest;

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.RequestMapping;
import org.springframework.web.bind.annotation.RestController;

@RestController
@RequestMapping("/api/test")
@RefreshScope
public class TestResource {

    @Value("${version}")
    private String version;

    @GetMapping("/getVersion")
    public String getVersion() {
        return version;
    }
}