springCloud - 第9篇 - 同步配置文件（消息总线方式）

心已赠人 2021-11-11 07:46 385阅读 0赞

[前些天发现了一个巨牛的人工智能学习网站，通俗易懂，风趣幽默，忍不住分享一下给大家。点击跳转到教程。][Link 1]

一、 微服务系统中有多个服务应用，也会有多个配置文件。此时也可用 springcloud bus 来实现对配置文件的管理。

PS：rabbitmq的安装见文章：[Docker 方式安装 RabbitMQ（ribbitmq linux 部署）][Docker _ RabbitMQ_ribbitmq linux]

二、springcloud bus 的使用

1. 修改 config-client 工程。修改 pom、启动类、配置。

1.1 在 pom 中加入依赖：

<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>

几经测试，父级 pom 使用 2.1.6 始终不成功。故换为 2.0.3 版本。运行成功。完整 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>com.config</groupId>
        <artifactId>config-client</artifactId>
        <version>0.0.1-SNAPSHOT</version>
        <name>config-client</name>
        <description>配置文件管理 client</description>
    
        <parent>
            <groupId>org.springframework.boot</groupId>
            <artifactId>spring-boot-starter-parent</artifactId>
            <version>2.0.3.RELEASE</version>
            <relativePath/>
        </parent>
    
        <properties>
            <project.build.sourceEncoding>UTF-8</project.build.sourceEncoding>
            <project.reporting.outputEncoding>UTF-8</project.reporting.outputEncoding>
            <java.version>1.8</java.version>
            <spring-cloud.version>Finchley.RELEASE</spring-cloud.version>
        </properties>
    
        <dependencies>
    
            <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-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-netflix-eureka-client</artifactId>
            </dependency>
    
            <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>
        </dependencies>
    
        <dependencyManagement>
            <dependencies>
                <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>
            <plugins>
                <plugin>
                    <groupId>org.springframework.boot</groupId>
                    <artifactId>spring-boot-maven-plugin</artifactId>
                </plugin>
            </plugins>
        </build>
    
    </project>

1.2 启动类中加上 注解：@RefreshScope 。刷新配置文件 。

完整启动类：

package com.config.configclient;
    
    import org.springframework.beans.factory.annotation.Value;
    import org.springframework.boot.SpringApplication;
    import org.springframework.boot.autoconfigure.SpringBootApplication;
    import org.springframework.cloud.context.config.annotation.RefreshScope;
    import org.springframework.context.annotation.Bean;
    import org.springframework.context.support.PropertySourcesPlaceholderConfigurer;
    import org.springframework.web.bind.annotation.RequestMapping;
    import org.springframework.web.bind.annotation.RestController;
    
    @RestController
    @SpringBootApplication
    
    // 刷新配置
    @RefreshScope
    public class ConfigClientApplication {
    
        public static void main(String[] args) {
            SpringApplication.run(ConfigClientApplication.class, args);
        }
    
        @Value("${version}")
        String version;
    
            @RequestMapping(value = "/getVersion")
        public String getVersion() {
            return version;
        }
    
        /**
         * 增加此方法用以解决报错：Could not resolve placeholder 'version' in value "${version}"
         * @return
         */
        @Bean
        public static PropertySourcesPlaceholderConfigurer placeholderConfigurer() {
            PropertySourcesPlaceholderConfigurer c = new PropertySourcesPlaceholderConfigurer();
            c.setIgnoreUnresolvablePlaceholders(true);
            return c;
        }
    
    }

1.3 配置文件调整为2份： application.properties 、bootstrap.properties 。分别配置不同内容。

bootstrap.properties：

# 项目名
    spring.application.name=config-client
    
    # 端口
    server.port=4445
    
    # 指定远程仓库分支
    spring.cloud.config.label=master
    
    # 读取文件：dev开发环境、test测试、pro生产
    spring.cloud.config.profile=dev
    
    # 配置文件管理中心 config-server 地址
    # 配置中心-集群模式时不使用 ip方式
    # spring.cloud.config.uri=http://localhost:3333/
    
    
    
    # 配置中心-集群模式 start -----------------
    
    # 注册中心 - 端口： 1234、工程名： eureka （见 eureka 工程中配置）。
    eureka.client.serviceUrl.defaultZone= http://localhost:1234/eureka/
    
    # 从配置中心读取文件
    spring.cloud.config.discovery.enabled=true
    
    # 配置文件管理中心（服务名） ：config-server
    spring.cloud.config.discovery.serviceId=config-server
    
    # 配置中心-集群模式 end -----------------

application.properties：

# rabbitmq 心跳检查
    eureka.client.healthcheck.enabled=true
    
    # rabbitmq 服务所在ip
    spring.rabbitmq.host=ergouzi.fun
    
    # rabbitmq 端口
    spring.rabbitmq.port=5672
    
    # rabbitmq 账号
    spring.rabbitmq.username=jiangyu
    
    # rabbitmq 密码
    spring.rabbitmq.password=loveU
    
    # 消息总线相关
    spring.cloud.bus.enabled=true
    spring.cloud.bus.trace.enabled=true
    management.endpoints.web.exposure.include=bus-refresh

2. 启动 eureka 、config-server。

3. 分不同端口号启动 2 个 config-client ：（端口号为 4444、4445）

![20190805113438493.png][]

![watermark_type_ZmFuZ3poZW5naGVpdGk_shadow_10_text_aHR0cHM6Ly9ibG9nLmNzZG4ubmV0L3UwMTEzMTQ0NDI_size_16_color_FFFFFF_t_70][]eureka  中注册服务为：

![watermark_type_ZmFuZ3poZW5naGVpdGk_shadow_10_text_aHR0cHM6Ly9ibG9nLmNzZG4ubmV0L3UwMTEzMTQ0NDI_size_16_color_FFFFFF_t_70 1][]

4.  确认配置文件内容为：

![20190805113919441.png][]

5. 分别请求 4444 和 4445：

![20190805113732303.png][] ![20190805113800383.png][]

6. 以往，配置文件更新后，需要重启工程才会读取到最新的配置内容。

使用消息总线 则只需要向任意一个 config-client 发送一个更新配置信息的 post 类型提示请求便可。

请求 URL 为：[http://localhost:4444/actuator/bus-refresh][http_localhost_4444_actuator_bus-refresh] ，返回状态码 204 ，表示请求成功，服务端无内容返回。

此时，更新配置文件流程是：

1）前提：不同 config-server、config-client 向 eureka 注册。

2）远程配置文件更新。

3）接口向任意一个 config-client 发起请求：[http://localhost:4444/actuator/bus-refresh][http_localhost_4444_actuator_bus-refresh] ，表示更新配置。

4） config-client 收到请求并发起消息到消息总线。

5）消息总线向其它应用服务传递最新配置信息内容，整个系统配置文件更新完成。

\-------------------------------------------------------------

下一篇：[springCloud - 第10篇 - 服务间调用追踪 （zipkin 的使用）][springCloud - _10_ - _ _zipkin]

源码见：

[https://gitee.com/FJ\_WoMenDeShiJie/springcloud-base][https_gitee.com_FJ_WoMenDeShiJie_springcloud-base]

[https://gitee.com/FJ\_WoMenDeShiJie/springcloud-config-server][https_gitee.com_FJ_WoMenDeShiJie_springcloud-config-server]

[https://gitee.com/FJ\_WoMenDeShiJie/springcloud-config-client][https_gitee.com_FJ_WoMenDeShiJie_springcloud-config-client]

\-------------------------------------------------------------

PS：这个系列不定时更新，只是个人的学习分享，

内容全程参考书目：

《Spring Cloud 与 Docker 微服务架构空实战 》、

《Spring Cloud 微服务实战》、

《深入理解 Spring Cloud 与微服务构建》、

及大神博客：https://blog.csdn.net/forezp/article/details/70148833  
\----------------------------------------------------------------

[Link 1]: https://www.captainai.net/jiangyu1013/
[Docker _ RabbitMQ_ribbitmq linux]: https://blog.csdn.net/jiangyu1013/article/details/97956771
[20190805113438493.png]: /images/20211109/8c8da91cddbc4fdf8cbf50624d0c8903.png
[watermark_type_ZmFuZ3poZW5naGVpdGk_shadow_10_text_aHR0cHM6Ly9ibG9nLmNzZG4ubmV0L3UwMTEzMTQ0NDI_size_16_color_FFFFFF_t_70]: /images/20211109/c6672e7fe97242a3adc0457bf7ea32a9.png
[watermark_type_ZmFuZ3poZW5naGVpdGk_shadow_10_text_aHR0cHM6Ly9ibG9nLmNzZG4ubmV0L3UwMTEzMTQ0NDI_size_16_color_FFFFFF_t_70 1]: /images/20211109/41ef4fc41b6941ea9e012ecd000d60d3.png
[20190805113919441.png]: /images/20211109/27521c7d06584bf4912b833c51b6708b.png
[20190805113732303.png]: https://img-blog.csdnimg.cn/20190805113732303.png
[20190805113800383.png]: /images/20211109/08e9d89f2d884a5fb1855ad0d5a73d55.png
[http_localhost_4444_actuator_bus-refresh]: http://localhost:4444/actuator/bus-refresh
[springCloud - _10_ - _ _zipkin]: https://blog.csdn.net/jiangyu1013/article/details/98727959
[https_gitee.com_FJ_WoMenDeShiJie_springcloud-base]: https://gitee.com/FJ_WoMenDeShiJie/springcloud-base
[https_gitee.com_FJ_WoMenDeShiJie_springcloud-config-server]: https://gitee.com/FJ_WoMenDeShiJie/springcloud-config-server
[https_gitee.com_FJ_WoMenDeShiJie_springcloud-config-client]: https://gitee.com/FJ_WoMenDeShiJie/springcloud-config-client