架构师--SpringCloud学习笔记：五、springcloud分布式配置中心和消息总线

Love The Way You Lie 2023-07-11 12:47 5阅读 0赞

本系列博文为学习资料，是根据老师讲义，加上自己理解描述整理而成。如有不当之处希望不吝指正，持续更新改正。

# 分布式配置中心 #

## 1、分布式配置中心能干什么 ##

不用分布式配置中心，可能导致多个工程需要对多个中间件配置；

*  比如连接DB或者Redis都是一样的配置，如果需要修改则要全改：**抽取公共配置**；
 *  一旦修改配置文件，设计整个项目重启：**配置文件的动态加载，热加载**；

## 2、分布式配置中心搭建 ##

### jar包导入 ###

<dependency>
                <groupId>org.springframework.cloud</groupId>
                <artifactId>spring-cloud-config-server</artifactId>
            </dependency>

### 启动类 ###

import org.springframework.boot.SpringApplication;
    import org.springframework.boot.autoconfigure.SpringBootApplication;
    import org.springframework.cloud.config.server.EnableConfigServer;
    import org.springframework.cloud.netflix.eureka.EnableEurekaClient;
    
    
    /* post * 加密：http://localhost:8085/encrypt?data=123456 * 解密：http://localhost:8085/decrypt * */
    @SpringBootApplication(scanBasePackages = { "com.xiangxue.jack"})
    @EnableConfigServer
    // 注册到eureka
    @EnableEurekaClient
    public class MicroConfigServerApplication { 
        public static void main(String[] args) { 
            SpringApplication.run(MicroConfigServerApplication.class,args);
        }
    }

### 配置文件 ###

分布式配置中心服务端是需要远程连接代码仓库的，比如 GitHub，gitlab 等，把需要管理的 配置文件放到代码仓库中管理，所以服务端就需要有连接代码仓库的配置：

# 3、分布式配置中心配置规则 #

## 连接github的配置 ##

![在这里插入图片描述][20200306203546724.png]

# 4、客户端使用配置中心 #

客户端只需要指定连接的服务端就行了，从服务端拉取配置信息

## 1、jar包依赖 ##

<dependency>
                <groupId>org.springframework.cloud</groupId>
                <artifactId>spring-cloud-starter-config</artifactId>
                <version>LATEST</version>
            </dependency>

## 2、配置文件 ##

spring.cloud.config.profile=dev spring.cloud.config.label=master 
    #这种配置是configserver还单机情况，直接连接这个单机服务就行
    spring.cloud.config.uri=http://localhost:8085/

# 5、客户端快速失败和重试 #

## 快速失败 ##

当你启动客户端的时候，发现连不上；启动的过程有一个去远端的配置中心拉去的动作，是否还需要继续启动服务，所以这里需要快速失败；

# 如果连接不上获取配置有问题 ，快速响应失败
    spring.cloud.config.fail-fast=true

## 重试 ##

客户端也有重试功能，连不上服务端是有重试机制  
重试功能 jar 包导入

### pom文件加上配置包 ###

<dependency>
                <groupId>org.springframework.retry</groupId>
                <artifactId>spring-retry</artifactId>
            </dependency>

### 重试配置 ###

#默认重试的间隔时间，默认1000ms
    spring.cloud.config.retry.multiplier=1000
    #下一间隔时间的乘数，默认是1.1
    #spring.cloud.config.retry.initial-interval=1.1
    #最大间隔时间，最大2000ms
    spring.cloud.config.retry.max-interval=2000
    #最大重试次数，默认6次
    spring.cloud.config.retry.max-attempts=6

测试场景：关闭配置环境关闭，启动客户端。观察日志，会发现相关效果

重试效果  
![在这里插入图片描述][watermark_type_ZmFuZ3poZW5naGVpdGk_shadow_10_text_aHR0cHM6Ly9ibG9nLmNzZG4ubmV0L2tlZW5zdHlsZQ_size_16_color_FFFFFF_t_70]

# 6、配置信息的加密 #

在配置中心中，有些信息是比较敏感的，比如密码信息，在配置密码信息的时候有必要对密 码信息加密以免密码信息泄露，springcloud 配置中心也支持配置信息加密的，这里一 RSA 非对称加密举例。

服务端：我们的配置信息往往是敏感信息（账号/密码），所以需要对数据进行加解密。

## 1、本地生成秘钥对 ##

cd 到 jdk 的 keytool 目录:D:\\ProgramFiles\\Java\\jdk1.8.0\_92\\jre\\bin 里面有一个 keytool.exe 可执行文件

## 2、执行指令生成秘钥文件 ##

keytool-genkeypair-aliasconfig-server-keyalgRSA-keystoreconfig-server.keystore-validity365 指令执行成功后会在 bin 目录生成一个 config-server.keystore 文件，把该文件 copy 到配置中 心服务工程中 resources 目录下。

## 3、服务端工程配置 ##

*  了解：
    
     *  对称加密
     *  非对称加密：RSA设计加密方和解密方；
 *  Properties 配置文件 添加秘钥配置

#加密配置
    encrypt.key-store.location=config-server.keystore
    encrypt.key-store.alias=config-server
    encrypt.key-store.password=123456
    encrypt.key-store.secret=123456

*  pom 中添加静态文件扫描，让能够扫描到.keystore 文件

<resources>
                <resource>
                    <directory>src/main/java</directory>
                    <includes>
                        <include>**/*.properties</include>
                        <include>**/*.xml</include>
                    </includes>
                    <filtering>false</filtering>
                </resource>
                <resource>
                    <directory>src/main/resources</directory>
                    <includes>
                        <include>**/*.properties</include>
                        <include>**/*.xml</include>
                        <include>**/*.txt</include>
                        <include>**/*.keystore</include>//重点  重点  重点
                    </includes>
                    <filtering>false</filtering>
                </resource>
            </resources>

## 4、密码加密和解密接口 ##

### 加密接口： ###

在服务端中有提供对信息加密和解密接口的 加密接口：http://localhost:8085/encrypt?data=123456，post 请求  
![在这里插入图片描述][watermark_type_ZmFuZ3poZW5naGVpdGk_shadow_10_text_aHR0cHM6Ly9ibG9nLmNzZG4ubmV0L2tlZW5zdHlsZQ_size_16_color_FFFFFF_t_70 1]  
在配置到远程的配  
置中心时必须加上：\{cipher\}（表示这是密文，需要解密）

### 解密接口： ###

解密接口：http://localhost:8085/decrypt，post 请求

![在这里插入图片描述][watermark_type_ZmFuZ3poZW5naGVpdGk_shadow_10_text_aHR0cHM6Ly9ibG9nLmNzZG4ubmV0L2tlZW5zdHlsZQ_size_16_color_FFFFFF_t_70 2]  
**注：所有配置信息的值都是冲Environment对象拿的；** 是在Spring容器里面（所以自家人，所以不好修改）；

config配置中心本身有缓存，会导致github修改后会不生效，需要配置直接拿最新配置，不要走缓存；

# 5、代码仓库密文配置 #

![在这里插入图片描述][watermark_type_ZmFuZ3poZW5naGVpdGk_shadow_10_text_aHR0cHM6Ly9ibG9nLmNzZG4ubmV0L2tlZW5zdHlsZQ_size_16_color_FFFFFF_t_70 3]  
密文前面一定要加上\{cipher\}标识这个是密文配置，需要服务端来解密的。

# 6、配置动态加载刷新 #

这个是一个革命性的功能，在运行期修改配置文件后，我们通过这个动态刷新功能可以不重 启服务器，这样我们系统理论上可以保证 7\*24 小时的工作

*  1、Environment的动态刷新 动态刷新其实要有一个契机，其实这个契机就是手动调用刷新接口，如果你想刷新哪台主机 的配置，就调用哪台注解的刷新接口 刷新接口为：http://localhost:8088/actuator/refresh
 *  2、@Value注入的属性动态刷新 其实前面在调用刷新接口后，@Value 注入的属性是没有刷新的还是老的配置，这个也好理 解，@Value 注入的属性是项目启动就已经定了的。如果要使@Value 属性也刷新，就必须要 在类上面加上：@RefreshScope 注解。  
    但是调用每台主机的刷新接口显然太麻烦了，如果需要刷新的集群机器有几百台，是不是就 需要手动调用几百次呢，这几乎是一个不能完成的工作量。 Springcloud 中也提供了消息总线的东西，借助 mq 来完成消息的广播，当需要刷新时我们就 只要调用一次刷新接口即可。

# 7、服务化配置中心 #

我们前面的配置，是直接连接一台主机；其实我们也可以直接连接某服务；  
通过服务名称获取信息；

# 8、高可用 #

启动多个configService服务；

# 9、配置动态刷新 #

当我们前面做了，配置动态加载和热加载以后。

这个功能当我们修改了配置文件以后不需要重启服务。**（SpringCloud这一点做的不好）**

SpringCloud的获取配置文件信息，是在服务启动的时候就已经存在；所以在修改远程配置文件的值以后，再次拿到的值还是之前的。

这里需要我们手动调用一个接口刷新值（如下）：  
上面可以看到：

*  @Value的值还是原来的值；
 *  Environment的值已经刷新：只要调用刷新就可以获取新的参数；

所以，@Value的值不能刷新；

可以加上@RefreshScope可以解决

**注：这中解决方案，需要先加上@RefreshScope注解，在调用刷新接口再能完成（不推荐）**  
弊端：

*  1、手动调用刷新接口：
 *  2、多个服务的时候，一旦修改必须全部手动调用接口，才能刷新最新配置；

所以我们需要通过消息总线的方式，广播订阅该信息（就是往mq里面查消息，然后广播给所有的客户端）

# 10、消息总线 #

消息总线其实很简单，就是为了解决一点刷新的功能，在一个点调用请求刷新接口，然后所 有的在消息总线中的端点都能接到刷新的消息，所有我们必须把每一个端点都拉入到消息总 线中来。

实现：  
在我们的客户端加上

## 1、Jar包的依赖 ##

<dependency>
                <groupId>org.springframework.cloud</groupId>
                <artifactId>spring-cloud-starter-bus-amqp</artifactId>
            </dependency>

## 2、properties配置文件 ##

*  MQ的配置
 *  刷新配置

其实就是连接mq的配置

spring.rabbitmq.host=192.168.67.139spring.rabbitmq.port=5672
    spring.rabbitmq.username=adminspring.rabbitmq.password=admin
    #刷新配置urlhttp://localhost:8081/actuator/bus-refre
    shspring.cloud.bus.refresh.enabled=true
    spring.cloud.bus.trace.enabled=true

通过这两步就已经完成了拉入消息总线的工作了。  
如果要刷新配置，就只要调用任意一个消息总线端点调用刷新接口即可，其他的端点就会收 到刷新配置的消息。 刷新接口：http://localhost:8085/actuator/bus-refresh  
这个接口也可以配置到 GitHub 中，只要 GitHub 有代码变更，就会调用这个接口  
![在这里插入图片描述][watermark_type_ZmFuZ3poZW5naGVpdGk_shadow_10_text_aHR0cHM6Ly9ibG9nLmNzZG4ubmV0L2tlZW5zdHlsZQ_size_16_color_FFFFFF_t_70 4]  
![在这里插入图片描述][watermark_type_ZmFuZ3poZW5naGVpdGk_shadow_10_text_aHR0cHM6Ly9ibG9nLmNzZG4ubmV0L2tlZW5zdHlsZQ_size_16_color_FFFFFF_t_70 5]  
![在这里插入图片描述][watermark_type_ZmFuZ3poZW5naGVpdGk_shadow_10_text_aHR0cHM6Ly9ibG9nLmNzZG4ubmV0L2tlZW5zdHlsZQ_size_16_color_FFFFFF_t_70 6]  
![在这里插入图片描述][watermark_type_ZmFuZ3poZW5naGVpdGk_shadow_10_text_aHR0cHM6Ly9ibG9nLmNzZG4ubmV0L2tlZW5zdHlsZQ_size_16_color_FFFFFF_t_70 7]  
当然这里配置的 URL 是你生产环境的外网地址，这样当你 GitHub 中修改了配置后，就会主 动调用消息总线的刷新接口。  
消息总线弊端就是太重了，一个集群通知刷新配置功能，还得用一个 rabbitmq 来做，如果 项目中根本用不到 rabbitmq 呢？就加大了项目负担，加大了维护成本。差评。

BUS总结：

*  使用简单；
 *  依赖MQ；

下面有一个思考：

## 解决手动问题 ##

可以在github上面添加回调地址，当github配置信息更新后就自动回调了

## 为了一个消息通知，整合了MQ没有必要 ##

在实际项目中，可能我们不会用到MQ，大多公司只会用到Redis。  
下一个我们介绍一下如何自己实现一个分布式配置；

总的来说，这玩意儿太重了。为整合配置热部署还需要整合MQ。

[20200306203546724.png]: https://img-blog.csdnimg.cn/20200306203546724.png
[watermark_type_ZmFuZ3poZW5naGVpdGk_shadow_10_text_aHR0cHM6Ly9ibG9nLmNzZG4ubmV0L2tlZW5zdHlsZQ_size_16_color_FFFFFF_t_70]: https://img-blog.csdnimg.cn/20200306205722867.png?x-oss-process=image/watermark,type_ZmFuZ3poZW5naGVpdGk,shadow_10,text_aHR0cHM6Ly9ibG9nLmNzZG4ubmV0L2tlZW5zdHlsZQ==,size_16,color_FFFFFF,t_70
[watermark_type_ZmFuZ3poZW5naGVpdGk_shadow_10_text_aHR0cHM6Ly9ibG9nLmNzZG4ubmV0L2tlZW5zdHlsZQ_size_16_color_FFFFFF_t_70 1]: https://img-blog.csdnimg.cn/20200306210501590.png?x-oss-process=image/watermark,type_ZmFuZ3poZW5naGVpdGk,shadow_10,text_aHR0cHM6Ly9ibG9nLmNzZG4ubmV0L2tlZW5zdHlsZQ==,size_16,color_FFFFFF,t_70
[watermark_type_ZmFuZ3poZW5naGVpdGk_shadow_10_text_aHR0cHM6Ly9ibG9nLmNzZG4ubmV0L2tlZW5zdHlsZQ_size_16_color_FFFFFF_t_70 2]: https://img-blog.csdnimg.cn/20200306210556852.png?x-oss-process=image/watermark,type_ZmFuZ3poZW5naGVpdGk,shadow_10,text_aHR0cHM6Ly9ibG9nLmNzZG4ubmV0L2tlZW5zdHlsZQ==,size_16,color_FFFFFF,t_70
[watermark_type_ZmFuZ3poZW5naGVpdGk_shadow_10_text_aHR0cHM6Ly9ibG9nLmNzZG4ubmV0L2tlZW5zdHlsZQ_size_16_color_FFFFFF_t_70 3]: https://img-blog.csdnimg.cn/20200306210803475.png?x-oss-process=image/watermark,type_ZmFuZ3poZW5naGVpdGk,shadow_10,text_aHR0cHM6Ly9ibG9nLmNzZG4ubmV0L2tlZW5zdHlsZQ==,size_16,color_FFFFFF,t_70
[watermark_type_ZmFuZ3poZW5naGVpdGk_shadow_10_text_aHR0cHM6Ly9ibG9nLmNzZG4ubmV0L2tlZW5zdHlsZQ_size_16_color_FFFFFF_t_70 4]: https://img-blog.csdnimg.cn/20200306211732170.png?x-oss-process=image/watermark,type_ZmFuZ3poZW5naGVpdGk,shadow_10,text_aHR0cHM6Ly9ibG9nLmNzZG4ubmV0L2tlZW5zdHlsZQ==,size_16,color_FFFFFF,t_70
[watermark_type_ZmFuZ3poZW5naGVpdGk_shadow_10_text_aHR0cHM6Ly9ibG9nLmNzZG4ubmV0L2tlZW5zdHlsZQ_size_16_color_FFFFFF_t_70 5]: https://img-blog.csdnimg.cn/20200306211749506.png?x-oss-process=image/watermark,type_ZmFuZ3poZW5naGVpdGk,shadow_10,text_aHR0cHM6Ly9ibG9nLmNzZG4ubmV0L2tlZW5zdHlsZQ==,size_16,color_FFFFFF,t_70
[watermark_type_ZmFuZ3poZW5naGVpdGk_shadow_10_text_aHR0cHM6Ly9ibG9nLmNzZG4ubmV0L2tlZW5zdHlsZQ_size_16_color_FFFFFF_t_70 6]: https://img-blog.csdnimg.cn/2020030621181094.png?x-oss-process=image/watermark,type_ZmFuZ3poZW5naGVpdGk,shadow_10,text_aHR0cHM6Ly9ibG9nLmNzZG4ubmV0L2tlZW5zdHlsZQ==,size_16,color_FFFFFF,t_70
[watermark_type_ZmFuZ3poZW5naGVpdGk_shadow_10_text_aHR0cHM6Ly9ibG9nLmNzZG4ubmV0L2tlZW5zdHlsZQ_size_16_color_FFFFFF_t_70 7]: https://img-blog.csdnimg.cn/20200306211831842.png?x-oss-process=image/watermark,type_ZmFuZ3poZW5naGVpdGk,shadow_10,text_aHR0cHM6Ly9ibG9nLmNzZG4ubmV0L2tlZW5zdHlsZQ==,size_16,color_FFFFFF,t_70