创建config-bus-server

1. 引入依赖

   <dependencies>
   <dependency>
       <groupId>org.springframework.cloud</groupId>
       <artifactId>spring-cloud-config-server</artifactId>
   </dependency>
   <dependency>
       <groupId>org.springframework.cloud</groupId>
       <artifactId>spring-cloud-starter-netflix-eureka-client</artifactId>
   </dependency>
   <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>
   <dependency>
       <groupId>org.springframework.cloud</groupId>
       <artifactId>spring-cloud-starter-bootstrap</artifactId>
   </dependency>
   </dependencies>

2. 创建启动类

   /**
   * @description: some desc
   * @author: Binlin B Wang
   * @email: binlin.b.wang@cn.pwc.com
   * @date: 2022/5/19 14:29
   */
   @SpringBootApplication
   @EnableConfigServer
   @EnableDiscoveryClient
   public class ConfigBusServerApplication {
   public static void main(String[] args) {
       new SpringApplicationBuilder(ConfigBusServerApplication.class)
               .web(WebApplicationType.SERVLET)
               .run(args);
   }
   }

3. 新增application.yml配置文件

   server:
   port: 60002
   spring:
   application:
   name: config-bus-server
   rabbitmq:
   host: 43.142.15.107
   port: 5672
   username: guest
   password: guest
   cloud:
   config:
     server:
       git:
         uri: https://github.com/afterglow-now/config-repo.git
         # 强制拉去资源文件
         force-pull: true
         # 解决could not be established because of SSL problems错误
         skipSslValidation: true
   eureka:
   instance:
   preferIpAddress: true
   instance-id: ${spring.cloud.client.ip-address}:${server.port}
   client:
   service-url:
     defaultZone: http://localhost:20000/eureka/
   management:
   security:
   enabled: false
   endpoints:
   web:
     exposure:
       include: "*"
   endpoint:
   health:
     show-details: always

4. 新增bootstrap.yml配置文件(加密相关)

   encrypt:
   key: clay

   创建config-bus-client

5. 引入pom依赖

   <dependencies>
   <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>
   <!--在SpringCloud 2020.* 版本把bootstrap禁用了，导致在读取文件的时候读取不到而报错-->
   <dependency>
       <groupId>org.springframework.cloud</groupId>
       <artifactId>spring-cloud-starter-bootstrap</artifactId>
   </dependency>
   <dependency>
       <groupId>org.springframework.boot</groupId>
       <artifactId>spring-boot-starter-actuator</artifactId>
   </dependency>
   <!-- rabbit mq 适配插件-->
   <dependency>
       <groupId>org.springframework.cloud</groupId>
       <artifactId>spring-cloud-starter-bus-amqp</artifactId>
   </dependency>
   <!-- kafka mq 适配插件-->
   <dependency>
       <groupId>org.springframework.cloud</groupId>
       <artifactId>spring-cloud-starter-bus-kafka</artifactId>
   </dependency>
   <dependency>
       <groupId>org.springframework.cloud</groupId>
       <artifactId>spring-cloud-starter-netflix-eureka-client</artifactId>
   </dependency>
   </dependencies>

6. 创建启动类

   /**
   * @description: some desc
   * @author: Binlin B Wang
   * @email: binlin.b.wang@cn.pwc.com
   * @date: 2022/5/19 14:29
   */
   @SpringBootApplication
   @EnableDiscoveryClient
   public class ConfigBusClientApplication {
   public static void main(String[] args) {
       new SpringApplicationBuilder(ConfigBusClientApplication.class)
               .web(WebApplicationType.SERVLET)
               .run(args);
   }
   }

7. yml配置文件

   server:
   port: 61001
   spring:
   application:
   name: config-bus-client
   rabbitmq:
   host: 43.142.15.107
   port: 5672
   username: guest
   password: guest
   cloud:
   # 引入多个binder需要指定默认的binder
   stream:
     default-binder: rabbit
   config:
     name: config-consumer
   #      uri: http://localhost:60000
     discovery:
       enabled: true
       service-id: config-bus-server
     profile: dev
     label: main
   eureka:
   instance:
   preferIpAddress: true
   instance-id: ${spring.cloud.client.ip-address}:${server.port}
   client:
   service-url:
     defaultZone: http://localhost:20000/eureka/
   management:
   security:
   enabled: false
   endpoints:
   web:
     exposure:
       include: "*"
   endpoint:
   health:
     show-details: always
   myWord: ${word}

   进行验证

8. 将config-bus-client启动多份
9. 访问两个连接验证结果
   • http://localhost:61001/refresh/word
   • http://localhost:61002/refresh/word
10. 对配置中心进行配置刷新
    • post请求发送none数据类型访问:http://localhost:60002/actuator/busrefresh
11. 访问2点进行验证
12. 将端口改为其中一个config-client的节点,对节点进行单独刷新,其他节点不受影响
    • http://localhost:61001/actuator/busrefresh