SpringCloud_Config分布式配置中心&Bus消息总线

比眉伴天荒 2023-07-25 05:28 26阅读 0赞

### 文章目录 ###

*  Config概述
 *  Config服务端配置
 *  Config客户端配置
 *  Bus概述
 *  动态刷新全局广播
 *  动态刷新定点通知
 *  参考Demo

# Config概述 #

![在这里插入图片描述][watermark_type_ZmFuZ3poZW5naGVpdGk_shadow_10_text_aHR0cHM6Ly9ibG9nLmNzZG4ubmV0L0NoaWxsX0x5bg_size_16_color_FFFFFF_t_70]  
SpringCloud Config为微服务架构中的微服务提供集中化的外部配置支持，配置服务器为各个不同微服务应用的所有环境提供了一个中心化的外部配置。

SpringCloud Config分为服务端和客户端两个部分。

服务端也称为分布式配置中心，它是一个独立的微服务，用来连接配置服务器并为客户端提供获取配置信息，加密、解密信息等访问接口。

客户端则是通过指定的配置中心来管理应用资源，以及与业务相关的配置内容，并在启动的时候从配置中心获取加载配置信息，配置服务器默认采用git来存储配置信息，有助于对环境配置进行版本管理，并且可以通过git客户端工具来方便管理和访问。

*  集中管理配置文件
 *  不同环境不同配置，动态化配置更新，分环境比如dev、test、prod、beta、release
 *  运行期间动态调整配置，不再需要在每个服务部署的机器上编写配置文件，服务会向配置中心拉取配置信息
 *  当配置发生改变时，服务不需要重启即可感知到配置的变化并应用新配置
 *  将配置信息以Rest接口的形式暴露，post、crul访问刷新即可

# Config服务端配置 #

1.  在GitHub上创建一个Repository
2.  在本地clone
3.  新建module
4.  pom

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

1.  yaml

server:
      port: 3344
    
    spring:
      application:
        name:  cloud-config-center #注册进Eureka服务器的微服务名
      cloud:
        config:
          server:
            git:
              #GitHub上面的git仓库名字
              uri: git@github.com:zzyybs/springcloud-config.git 
              #搜索目录
              search-paths:
                - springcloud-config
          #读取分支
          label: master
    
    #服务注册到eureka地址
    eureka:
      client:
        service-url:
          defaultZone: http://localhost:7001/eureka

1.  读取配置规则

*  /\{label\}/\{application\}-\{profile\}.yml（http://config-3344.com:3344/master/config-dev.yml）
 *  /\{application\}-\{profile\}.yml
 *  /\{application\}/\{profile\}/\{/label\}

# Config客户端配置 #

1.  pom

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

1.  bootstrap.yaml

server:
      port: 3355
    
    spring:
      application:
        name: config-client
      cloud:
        #Config客户端配置
        config:
          label: master #分支名称
          name: config #配置文件名称
          #读取后缀名称   上述3个综合：master分支上config-dev.yml的配置文件被读取
          #http://config-3344.com:3344/master/config-dev.yml
          profile: dev 
          uri: http://localhost:3344 #配置中心地址
    
    #服务注册到eureka地址
    eureka:
      client:
        service-url:
          defaultZone: http://localhost:7001/eureka
    
    # 暴露监控端点
    management:
      endpoints:
        web:
          exposure:
            include: "*"

1.  controller

@RestController
    @RefreshScope
    public class ConfigClientController

1.  动态刷新  
    除了`@RefreshScope`，还需要运维人员每次修改配置文件过后发送`curl -X POST "http://localhost:3355/actuator/refresh"`

# Bus概述 #

![在这里插入图片描述][watermark_type_ZmFuZ3poZW5naGVpdGk_shadow_10_text_aHR0cHM6Ly9ibG9nLmNzZG4ubmV0L0NoaWxsX0x5bg_size_16_color_FFFFFF_t_70 1]  
Bus配合Config使用可以实现配置的动态刷新。Bus是用来将分布式系统的节点与轻量级消息系统链接起来的框架，整合了Java的事件处理机制和消息中间件功能。目前支持RabbitMQ和Kafka  
![在这里插入图片描述][watermark_type_ZmFuZ3poZW5naGVpdGk_shadow_10_text_aHR0cHM6Ly9ibG9nLmNzZG4ubmV0L0NoaWxsX0x5bg_size_16_color_FFFFFF_t_70 2]  
在微服务架构的系统中，通常会使用轻量级的消息代理来构建一个共用的消息主题，并让系统中所有微服务实例都连接上来，由于该主题中产生的消息会被所有实例监听和消费，所以称之为消息总线。

# 动态刷新全局广播 #

1.  启动RabbitMQ  
    [SpringBoot\_消息(整合RabbitMQ)][SpringBoot_RabbitMQ]
2.  pom

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

1.  yaml

#rabbitmq相关配置
    rabbitmq:
        host: localhost
        port: 5672
        username: guest
        password: guest

1.  动态刷新

curl -X POST "http://localhost:3344/actuator/bus-refresh"

# 动态刷新定点通知 #

#公式：http://localhost:3344/actutor/bus-refresh/{destination}
    curl -X POST "http://localhost:3344/actuator/bus-refresh/config-client:3355"

# 参考Demo #

[https://github.com/zzyybs/atguigu\_spirngcloud2020][https_github.com_zzyybs_atguigu_spirngcloud2020]

[watermark_type_ZmFuZ3poZW5naGVpdGk_shadow_10_text_aHR0cHM6Ly9ibG9nLmNzZG4ubmV0L0NoaWxsX0x5bg_size_16_color_FFFFFF_t_70]: /images/20230528/efe0a9dde8a54610b10435285225bbb4.png
[watermark_type_ZmFuZ3poZW5naGVpdGk_shadow_10_text_aHR0cHM6Ly9ibG9nLmNzZG4ubmV0L0NoaWxsX0x5bg_size_16_color_FFFFFF_t_70 1]: /images/20230528/a2760fdeaf2c4e508aea667e69cc53c1.png
[watermark_type_ZmFuZ3poZW5naGVpdGk_shadow_10_text_aHR0cHM6Ly9ibG9nLmNzZG4ubmV0L0NoaWxsX0x5bg_size_16_color_FFFFFF_t_70 2]: /images/20230528/2a69eed9b1604c32a8bfdbefeaf67c01.png
[SpringBoot_RabbitMQ]: https://blog.csdn.net/Chill_Lyn/article/details/104914254?ops_request_misc=%257B%2522request%255Fid%2522%253A%2522158676067419195239823291%2522%252C%2522scm%2522%253A%252220140713.130056874..%2522%257D&request_id=158676067419195239823291&biz_id=0&utm_source=distribute.pc_search_result.none-task-blog-blog_SOOPENSEARCH-1
[https_github.com_zzyybs_atguigu_spirngcloud2020]: https://github.com/zzyybs/atguigu_spirngcloud2020