第十三章 Spring Cloud Config 统一配置中心详解-客户端动态刷新

痛定思痛。 2024-04-01 09:31 69阅读 0赞

**目录**

一、问题分析及解决方案

1、问题分析：

2、解决方案

二、手动刷新

1、添加服务监控

2、暴露服务端点，让客户端能感受到配置的更新。

3、刷新业务类controller

4、手动刷新

三、自动刷新

--------------------

## 一、问题分析及解决方案 ##

### 1、问题分析： ###

上一章我们讲过远程仓储统一管理配置信息，客户端可以通过统一配置服务中心 **config server** 服务端获取配置信息。现在我们来做一个改变，并进行分析。  
首先启动注册中心、统一配置中心configserver服务端、订单服务。浏览器访问地址：http://localhost:9000/order/getConfig 查看效果。

![2081cd7d0fd24a8e86ab24b80ec239b0.png][]  
然后将远程仓储的订单服务dev环境的信息进行改变，在info上增加版本 version=01。  
浏览器访问地址：http://localhost:9000/order/getConfig 查看效果

![2081cd7d0fd24a8e86ab24b80ec239b0.png][]  
重新启动订单服务，浏览器访问地址http://localhost:9000/order/getConfig 查看效果

![08c9a21341f84a209d5947f9e595b3c4.png][]

我们看到，远端仓储的配置信息改变，如果不重新启动订单服务，则无法刷新远端仓储的配置信息。

### 2、解决方案 ###

使用动态刷新，动态刷新分为两种形式，一种是手动刷新，一种是自动刷新。

## 二、手动刷新 ##

### 1、添加服务监控 ###

在pom文件中添加服务监控依赖 spring-boot-starter-actuator ，修改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">
        <parent>
            <artifactId>springcloudbase</artifactId>
            <groupId>com.hwadee.springcloud2022</groupId>
            <version>0.0.1-SNAPSHOT</version>
        </parent>
        <modelVersion>4.0.0</modelVersion>
    
        <groupId>com.hwadee.springcloud</groupId>
        <artifactId>orderServer9000</artifactId>
    
        <dependencies>
            
            <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>
            
    
            
            <dependency>
                <groupId>org.springframework.boot</groupId>
                <artifactId>spring-boot-starter-web</artifactId>
    
            </dependency>
            
            <dependency>
                <groupId>com.hwadee.springcloud</groupId>
                <artifactId>springcloud-api</artifactId>
                <version>0.0.1-SNAPSHOT</version>
            </dependency>
            
            <dependency>
                <groupId>org.springframework.cloud</groupId>
                <artifactId>spring-cloud-starter-netflix-eureka-client</artifactId>
            </dependency>
            
            <dependency>
                <groupId>org.projectlombok</groupId>
                <artifactId>lombok</artifactId>
            </dependency>
        </dependencies>
    
    </project>

### 2、暴露服务端点，让客户端能感受到配置的更新。 ###

暴露服务端点，让客户端能感受到配置的更新，在bootstrap配置文件中修改如下：

spring:
      cloud:
        config:
          label: master # 指定分支
          name: order # 指定应用名称
          profile: dev # 指定激活环境
          uri: http://localhost:7009 #硬编码 指定访问 config server 远程仓储的地址的ip和端口
          
    #暴露服务端点，让客户端能感受到配置的更新
    management:
      endpoints:
        web:
          exposure:
            include: "*"

### 3、刷新业务类controller ###

刷新业务类controller，在订单服务的controller上使用注解 @RefreshScope ，使用后具备刷新能力，@Refreshscope用来在不需要重启徽服务情况下,将当前scope域中信息刷新为最新配置信息，订单服务的controller代码修改如下：

import com.hwadee.springcloud.entity.Product;
    import org.springframework.beans.factory.annotation.Value;
    import org.springframework.cloud.context.config.annotation.RefreshScope;
    import org.springframework.web.bind.annotation.RequestMapping;
    import org.springframework.web.bind.annotation.RestController;
    
    @RestController
    @RequestMapping("/order")
    @RefreshScope
    public class OrderController {
    
        @Value("${env}")
        private String env;
        @Value("${port}")
        private String port;
        @Value("${info}")
        private String info;
    
        @RequestMapping(value = "/getConfig")
        public Product getConfigInfo() {
            Product product = new Product();
            product.setName(env +"环境 端口："+ port +" "+ info);
            return product;
        }
    
    }

### **4、手动刷新** ###

在cmd窗口进行手动刷新，必须是post请求，且地址固定：curl -X POST "http://localhost:9000/actuator/refresh"。

![53cc7eddb84d47d391db394b2cb5b63d.png][]

再次访问：http://localhost:9000/order/getConfig

![08c9a21341f84a209d5947f9e595b3c4.png][]

## 三、自动刷新 ##

问题：每个微服务如果需要加载最新配置信息，必须向每个微服务手动发送post请求，才能加载最新配置信息。因为微服务一般是集群方式，所以此种方式不方便，我们可以使用一个组件Bus总线，实现自动刷新。Bus总线支持RubbitMQ和kafak消息代理。

什么是总线  
在微服务架构的系统中，通常会使用轻量级的消息代理来构建一个共用的消息主题，并让系统中所有微服务实例都连接上来。由于该主题中产生的消息会被所有实例监听和消费，所以称它为消息总线。在总线上的各个实例，都可以方便地广播一些需要让其他连接在该主题上的实例都知道的消息。

基本原理  
ConfigClient实例都监听MQ中同一个topic(默认是springCloudBus)。当一个服务刷新数据的时候，它会把这个信息放入到Topic中，这样其它监听同一Topic的服务就能得到通知，然后去更新自身的配置。

![da9378cd8f9f456586860735bd82da21.png][]

![d8b5bfd59c5e4defafa2abd2740b4e47.png][]

**后续待更新。**

第十二章：[Spring Cloud Config 统一配置中心详解][Spring Cloud Config]

第十四章：[Spring Cloud Bus消息总线详解][Spring Cloud Bus]

[2081cd7d0fd24a8e86ab24b80ec239b0.png]: https://image.dandelioncloud.cn/pgy_files/images/2024/04/01/8ab149beb8564e128a8c583ffab94601.png
[08c9a21341f84a209d5947f9e595b3c4.png]: https://image.dandelioncloud.cn/pgy_files/images/2024/04/01/ded594657f174ef1b95daad181f58272.png
[53cc7eddb84d47d391db394b2cb5b63d.png]: https://image.dandelioncloud.cn/pgy_files/images/2024/04/01/f3e514fbef14490d964c3880d01cf9e2.png
[da9378cd8f9f456586860735bd82da21.png]: https://image.dandelioncloud.cn/pgy_files/images/2024/04/01/94d6040ee07b4c089fce20a1514ff0d6.png
[d8b5bfd59c5e4defafa2abd2740b4e47.png]: https://image.dandelioncloud.cn/pgy_files/images/2024/04/01/5ecd5cc476394e98adf99dd6f49df8b1.png
[Spring Cloud Config]: https://blog.csdn.net/qq_41946216/article/details/127422810?spm=1001.2014.3001.5502
[Spring Cloud Bus]: https://blog.csdn.net/qq_41946216/article/details/127495048?spm=1001.2014.3001.5502