11、SpringCloud Bus刷新Config

作者: adced06edef5 | 来源:发表于2020-03-29 13:09 被阅读0次

一、代码示例

说明：此处使用的SpringBoot版本为2.1.13.RELEASE，SpringCloud版本为Greenwich.SR5
前面介绍了SpringCloud Config的Server端和Client端，通过某以微服务实现刷新配置，但是实际中微服务有但多，我们不可能每一个都去刷新。下面我们将Config添加到Eureka Server并使用SpringCloud Bus进行刷新。
使用SpringCloud Bus需要使用RabbitMQ或kafka，此文使用的是RabbitMQ。安装方式参照：https://www.cnblogs.com/nongzihong/p/11578255.html
注意Erlang和RabbitMQ的版本一定要一致，不然会很坑。。。
本文的github地址为https://github.com/panli1988/config-server
此例读取的配置文件为/cloud02下的

image.png
此处我们创建三个工程

image.png
具体代码如下：
parent.pom

<?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 http://maven.apache.org/xsd/maven-4.0.0.xsd">
    <modelVersion>4.0.0</modelVersion>

    <groupId>org.example</groupId>
    <artifactId>cloud02</artifactId>
    <version>1.0-SNAPSHOT</version>
    <modules>
        <module>eureka-server-7001</module>
        <module>provider-8001</module>
        <module>provider-8002</module>
    </modules>

    <packaging>pom</packaging>

    <properties>
        <java.version>1.8</java.version>
        <spring-cloud.version>Greenwich.SR5</spring-cloud.version>
        <spring-boot.version>2.1.13.RELEASE</spring-boot.version>
        <maven.compiler.source>${java.version}</maven.compiler.source>
        <project.build.sourceEncoding>UTF-8</project.build.sourceEncoding>
        <maven.compiler.target>${java.version}</maven.compiler.target>
    </properties>

    <dependencyManagement>
        <dependencies>
            <dependency>
                <groupId>org.springframework.boot</groupId>
                <artifactId>spring-boot-dependencies</artifactId>
                <version>${spring-boot.version}</version>
                <type>pom</type>
                <scope>import</scope>
            </dependency>
            <dependency>
                <groupId>org.springframework.cloud</groupId>
                <artifactId>spring-cloud-dependencies</artifactId>
                <version>${spring-cloud.version}</version>
                <type>pom</type>
                <scope>import</scope>
            </dependency>
        </dependencies>
    </dependencyManagement>

    <build>
        <finalName>cloud02</finalName>
        <resources>
            <resource>
                <directory>src/main/resources</directory>
                <filtering>true</filtering>
            </resource>
        </resources>
        <plugins>
            <plugin>
                <groupId>org.apache.maven.plugins</groupId>
                <artifactId>maven-resources-plugin</artifactId>
                <configuration>
                    <delimiters>
                        <delimit>$</delimit>
                    </delimiters>
                </configuration>
            </plugin>
        </plugins>
    </build>
</project>

eureka-server-7001
1、maven依赖

    <dependencies>
        <dependency>
            <groupId>org.springframework.cloud</groupId>
            <artifactId>spring-cloud-starter-netflix-eureka-server</artifactId>
        </dependency>
        <dependency>
            <groupId>org.springframework.cloud</groupId>
            <artifactId>spring-cloud-config-server</artifactId>
        </dependency>
        <dependency>
            <groupId>org.springframework.cloud</groupId>
            <artifactId>spring-cloud-starter-bus-amqp</artifactId>
        </dependency>
    </dependencies>

2、application.yml

server:
  port: 7001
spring:
  application:
    name: eureka-server
  cloud:
    config:
      server:
        git:
          search-paths: /cloud02
          username:
          password:
          default-label: master
          uri: https://github.com/panli1988/config-server
  rabbitmq:
    host: localhost
    port: 5672
    username: guest
    password: guest
eureka:
  client:
    #要不要去注册中心获取其他服务的地址
    fetch-registry: false
    #自己就是注册中心，不用注册自己
    register-with-eureka: false
    service-url:
      defaultZone: http://localhost:7001/eureka
  instance:
    hostname: localhost
    instance-id: eureka-server
management:
  endpoints:
    web:
      exposure:
        include: "*"

3、启动类

package org.example;

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

@SpringBootApplication
@EnableEurekaServer
@EnableConfigServer
public class EurekaServer7001Application {

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

provider-8001
1、maven依赖
2、application.yml
3、启动类
4、其他类
provider-8002
1、maven依赖

<dependencies>
        <dependency>
            <groupId>org.springframework.boot</groupId>
            <artifactId>spring-boot-starter-actuator</artifactId>
        </dependency>
        <dependency>
            <groupId>org.springframework.cloud</groupId>
            <artifactId>spring-cloud-starter-netflix-eureka-client</artifactId>
        </dependency>
        <dependency>
            <groupId>org.springframework.boot</groupId>
            <artifactId>spring-boot-starter-web</artifactId>
        </dependency>
        <dependency>
            <groupId>org.springframework.boot</groupId>
            <artifactId>spring-boot-starter-test</artifactId>
            <scope>test</scope>
        </dependency>
        <dependency>
            <groupId>org.springframework.cloud</groupId>
            <artifactId>spring-cloud-starter-config</artifactId>
        </dependency>
        <dependency>
            <groupId>org.springframework.cloud</groupId>
            <artifactId>spring-cloud-starter-bus-amqp</artifactId>
        </dependency>
    </dependencies>

2、application.yml

#info信息
info:
  app:
    name: provider-8001
  company:
    name: www.xxx.com
  build:
    artifactId: ${project.artifactId}
    version: ${project.version}
spring:
  rabbitmq:
    host: localhost
    port: 5672
    username: guest
    password: guest

3、bootstrap.yml

spring:
  application:
    #要读取的配置文件：如git上的文件为provider2-dev.yml
    name: provider
  cloud:
    config:
      label: master
      #环境
      profile: dev
      uri: http://localhost:7001/config

3、启动类

package org.example;

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

@SpringBootApplication
public class Provider8001Application {

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

4、其他类
controller类

package org.example.controller;

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

@RestController
@RefreshScope
public class ProviderController {

    @Value("${spring.application.name}")
    public String name;

    @Value("${text}")
    public String text;

    @GetMapping("/hello/{name}")
    public String hello(@PathVariable("name") String name){
        return "hello,"+name;
    }

    @GetMapping("/name")
    public String name(){
        return name+"===="+text;
    }
}

provider-8002
1、maven依赖

   <dependencies>
        <dependency>
            <groupId>org.springframework.boot</groupId>
            <artifactId>spring-boot-starter-actuator</artifactId>
        </dependency>
        <dependency>
            <groupId>org.springframework.cloud</groupId>
            <artifactId>spring-cloud-starter-netflix-eureka-client</artifactId>
        </dependency>
        <dependency>
            <groupId>org.springframework.boot</groupId>
            <artifactId>spring-boot-starter-web</artifactId>
        </dependency>
        <dependency>
            <groupId>org.springframework.boot</groupId>
            <artifactId>spring-boot-starter-test</artifactId>
            <scope>test</scope>
        </dependency>
        <dependency>
            <groupId>org.springframework.cloud</groupId>
            <artifactId>spring-cloud-starter-config</artifactId>
        </dependency>
        <dependency>
            <groupId>org.springframework.cloud</groupId>
            <artifactId>spring-cloud-starter-bus-amqp</artifactId>
        </dependency>
    </dependencies>

2、application.yml

#info信息
info:
  app:
    name: provider-8002
  company:
    name: www.xxx.com
  build:
    artifactId: ${project.artifactId}
    version: ${project.version}
spring:
    rabbitmq:
      host: localhost
      port: 5672
      username: guest
      password: guest

3、bootstrap.yml

spring:
  application:
    #要读取的配置文件：如git上的文件为provider2-dev.yml
    name: provider2
  cloud:
    config:
      label: master
      #环境
      profile: dev
      uri: http://localhost:7001/config

4、启动类

package org.example;

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

@SpringBootApplication
public class Provider8002Application {

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

5、其他类

package org.example.controller;

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

@RestController
@RefreshScope
public class ProviderController {

    @Value("${spring.application.name}")
    public String name;

    @Value("${text}")
    public String text;

    @GetMapping("/hello/{name}")
    public String hello(@PathVariable("name") String name){
        return "hello2,"+name;
    }

    @GetMapping("/name")
    public String name(){
        return name+"===="+text;
    }
}

其实provider-8001和provider-8002区别很小，此处可以不贴代码，为了完整性还是贴一些，且方便后续测试。

2、测试验证

先启动RabbitMQ，再一次启动eureka-server-7001、provider-8001、provider-8002。启动后测试下服务是否正常，不然就笑了。
先访问下http://localhost:7001/

image.png
再访问http://localhost:8001/hello/zs
http://localhost:8001/hello/zs

image.png
还有http://localhost:8002/hello/zs

image.png
以上服务均正常。
下面测试下获取的配置：

image.png

image.png
此处读取了spring.application.name和text两个属性，均正常获取。
特别说明一下：provider-8001和provider-8002分别读取的是provider-profile.yml和provider2-profile.yml,所以我们要修改两个配置文件，此处我们修改text属性：