天天看点

SpringCloud-分布式配置中心【动态刷新】

案例代码: https://github.com/q279583842q/springcloud-e-book

 本文我们来讨论下如何在配置中心的信息被改变的情况下,及时刷新客户端的数据的情况。

一、配置中心原理

1.原理结构图

SpringCloud-分布式配置中心【动态刷新】

2.原理描述

 通过上图我们能看到配置服务其实是从本地的Git仓库中获取的信息,Git本地库通过pull命令同步远程库中的内容。当配置中心客户端重新启动的时候会显示的执行pull命令来拉取最新的配置信息,这个我们可以通过如下案例来得到演示.

2.1 关闭配置中心客户端

 关闭配置中心客户端服务。

2.2 显示修改git中内容

 直接在码云仓库中修改内容

SpringCloud-分布式配置中心【动态刷新】

2.3 启动客户端服务

 启动客户端,观察控制台信息,访问获取配置信息

SpringCloud-分布式配置中心【动态刷新】

获取的是修改后的数据,说明启动客户端服务可以同步刷新配置信息。但是总归要重启服务,不是太方便,所以我们来考虑不重启服务来同步配置信息

二、动态刷新配置信息

 此处我们可以使用actuator监控服务中的refuse命令来刷新服务。所以我们需要创建一个新的包含Actuator服务的配置中心客户端。

1.创建项目

SpringCloud-分布式配置中心【动态刷新】
2.pom文件

<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>
    <parent>
        <groupId>org.springframework.boot</groupId>
        <artifactId>spring-boot-starter-parent</artifactId>
        <version>1.5.13.RELEASE</version>
    </parent>
    <groupId>com.bobo</groupId>
    <artifactId>config-client-refresh</artifactId>
    <version>0.0.1-SNAPSHOT</version>
    <dependencyManagement>
        <dependencies>
            <dependency>
                <groupId>org.springframework.cloud</groupId>
                <artifactId>spring-cloud-dependencies</artifactId>
                <version>Dalston.SR5</version>
                <type>pom</type>
                <scope>import</scope>
            </dependency>
        </dependencies>
    </dependencyManagement>
    <dependencies>
        <dependency>
            <groupId>org.springframework.boot</groupId>
            <artifactId>spring-boot-starter-web</artifactId>
        </dependency>
        <dependency>
            <groupId>org.springframework.cloud</groupId>
            <artifactId>spring-cloud-starter-eureka</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>
    </dependencies>
    <build>
        <plugins>
            <plugin>
                <groupId>org.springframework.boot</groupId>
                <artifactId>spring-boot-maven-plugin</artifactId>
            </plugin>
        </plugins>
    </build>
</project>
      

3.修改配置

spring.application.name=config-client-refresh
server.port=9051
#设置服务注册中心地址,指向另一个注册中心
eureka.client.serviceUrl.defaultZone=http://dpb:123456@eureka1:8761/eureka/,http://dpb:123456@eureka2:8761/eureka/

#默认 false,这里设置 true,表示开启读取配置中心的配置
spring.cloud.config
.discovery.enabled=true
#对应 eureka 中的配置中心 serviceId,默认是 configserver
spring.cloud.config.discovery.serviceId=config-server
#指定环境
spring.cloud.config.profile=dev
#git 标签
spring.cloud.config.label=master

#springboot 默认开启了权限拦截 会导致 /refresh 出现 401,拒绝访问
management.security.enabled=false      

同时我们需要在码云中创建一个新的配置文件

SpringCloud-分布式配置中心【动态刷新】
SpringCloud-分布式配置中心【动态刷新】

4.刷新请求

 因为refresh命令只支持post方式提交,所以我们不能直接在浏览器中访问。

SpringCloud-分布式配置中心【动态刷新】

现在获取信息

SpringCloud-分布式配置中心【动态刷新】

5.修改bean对象的作用域

 在spring中bean对象默认是单例模式,所以即便项目被刷新了,成员变量的值也不会改变,所以我们需要改变了bean对象的作用域

@RestController
@RefreshScope //刷新作用域
public class ShowController {
    
    @Value("${e-book}")
    private String msg;
    
    @RequestMapping("/showMsg")
    public String showMsg(){
        return msg;
    }

}      

6.通过RestTemplate发送post请求

/**
     * 通过RestTemplate发送post请求来刷新
     * @param args
     */
    public static void main(String[] args) {
        RestTemplate template = new RestTemplate();
        String url = "http://localhost:9051/refresh";
        template.postForLocation(url, null);
        System.out.println("----");
    }      

7.测试

 在服务都在运行的情况下,修改码云中的配置数据

SpringCloud-分布式配置中心【动态刷新】

访问数据为

SpringCloud-分布式配置中心【动态刷新】

然后执行RestTemplate的post方式访问

SpringCloud-分布式配置中心【动态刷新】

如此实现了在没有重新启动服务的情况下动态同步的配置信息~