拨开荷叶行,寻梦已然成。仙女莲花里,翩翩白鹭情。
IMG-LOGO
主页 文章列表 SpringCloud -- Config、Bus决议

SpringCloud -- Config、Bus决议

白鹭 - 2022-03-14 2101 0 0

文章目录

  • 1、Config
    • 1.1、概述简介
    • 1.2、Config服务端配置与测验
    • 1.3、Config客户端配置与测验
    • 1.4、Config客户端之动态重绘(手动版)
      • 1.4.1、面临的问题
      • 1.4.2、动态重绘配置与测验
  • 2、Bus
    • 2.1、概述简介
    • 2.2、全域广播形式的动态重绘
      • 2.2.1、新添加一个客户端
      • 2.2.2、两种导致全域动态重绘的方式
      • 2.2.3、添加讯息总线支持的配置
      • 2.2.4、测验结果
    • 2.3、定点通知形式的动态重绘

1、Config

1.1、概述简介

1. 分布式面临的问题

  • 微服务意味着要将单体应用中的业务拆分成一个个子服务,每个服务的粒度相对较小,因此系统中会出现大量的服务,由于每个服务都需要必要的配置信息才能运行,所以一套集中式的、动态的配置管理设施是必不可少的,

2. Config是什么

在这里插入图片描述

  • Spring Cloud Config分为服务端和客户端两部分,
  • 服务端也成为分布式配置中心,它是一个独立的微服务应用,用来连接配置服务器并为客户端提供获取配置信息,加密/解密信息等访问界面,
  • 客户端则是通过指定的配置中心来管理应用资源,以及与业务相关的配置内容,并在启动的时候从配置中心获取和加载配置信息配置服务器默认采用git来存盘配置信息,这样就有助于对环境配置进行版本管理,并且可以通过git客户端工具来方便的管理和访问配置内容,

3. 能干嘛

  1. 集中管理组态档
  2. 不同环境不同配置,动态化的配置更新,分环境部署比如dev/test/prod/beta/release
  3. 运行期间动态调整配置,不再需要在每个服务部署的机器上撰写组态档,服务会向配置中心统一拉取配置自己的信息
  4. 当配置发生变动时,服务不需要重启即可感知到配置的变化并应用新的配置
  5. 将配置信息以REST界面的形式暴露

官网地址

1.2、Config服务端配置与测验

1. 建Module

  • Module的名称为cloud-config-center-3344

2. 改POM

    <dependencies>


        <dependency>
            <groupId>org.springframework.cloud</groupId>
            <artifactId>spring-cloud-config-server</artifactId>
        </dependency>
        <dependency>
            <groupId>org.springframework.cloud</groupId>
            <artifactId>spring-cloud-starter-netflix-eureka-client</artifactId>
        </dependency>
        <dependency>
            <groupId>com.xiao</groupId>
            <artifactId>cloud-api-commons</artifactId>
            <version>1.0-SNAPSHOT</version>
        </dependency>
        <dependency>
            <groupId>org.springframework.boot</groupId>
            <artifactId>spring-boot-starter-web</artifactId>
        </dependency>

        <dependency>
            <groupId>org.springframework.boot</groupId>
            <artifactId>spring-boot-starter-actuator</artifactId>
        </dependency>

        <dependency>
            <groupId>org.springframework.boot</groupId>
            <artifactId>spring-boot-devtools</artifactId>
            <scope>runtime</scope>
            <optional>true</optional>
        </dependency>

        <dependency>
            <groupId>org.projectlombok</groupId>
            <artifactId>lombok</artifactId>
            <optional>true</optional>
        </dependency>
        <dependency>
            <groupId>org.springframework.boot</groupId>
            <artifactId>spring-boot-starter-test</artifactId>
            <scope>test</scope>
        </dependency>
    </dependencies>

3. 改YML

server:
  port: 3344
spring:
  application:
    name: cloud-config-center
  profiles:
    active: dev
  cloud:
    config:
      server:
        git:
          uri:  https://gitee.com/henryxjh/springcloud-config.git # url地址
          search-paths: # 搜索路径
            - springcloud-config
      label: master  # 配置的是主分支



eureka:
  client:
    service-url:
      defaultZone:  http://localhost:7001/eureka

4. 主启动

import org.springframework.boot.SpringApplication;
import org.springframework.boot.autoconfigure.SpringBootApplication;
import org.springframework.cloud.config.server.EnableConfigServer;

@SpringBootApplication
@EnableConfigServer
public class ConfigCenterMain3344 {
    public static void main(String[] args) {
        SpringApplication.run(ConfigCenterMain3344.class,args);
    }
}

5. 测验结果

在这里插入图片描述

(1)、其他的访问路径格式

/{application}/{profile}[/{label}]
/{application}-{profile}.yml   ## 推荐使用这个
/{label}/{application}-{profile}.yml
/{application}-{profile}.properties
/{label}/{application}-{profile}.properties

1.3、Config客户端配置与测验

1. 建Module

  • Module的名称为cloud-config-client-3355

2. 改POM

   <dependencies>

        <dependency>
            <groupId>org.springframework.cloud</groupId>
            <artifactId>spring-cloud-starter-config</artifactId>
        </dependency>
        <dependency>
            <groupId>org.springframework.cloud</groupId>
            <artifactId>spring-cloud-starter-netflix-eureka-client</artifactId>
        </dependency>
        <dependency>
            <groupId>com.xiao</groupId>
            <artifactId>cloud-api-commons</artifactId>
            <version>1.0-SNAPSHOT</version>
        </dependency>
        <dependency>
            <groupId>org.springframework.boot</groupId>
            <artifactId>spring-boot-starter-web</artifactId>
        </dependency>

        <dependency>
            <groupId>org.springframework.boot</groupId>
            <artifactId>spring-boot-starter-actuator</artifactId>
        </dependency>

        <dependency>
            <groupId>org.springframework.boot</groupId>
            <artifactId>spring-boot-devtools</artifactId>
            <scope>runtime</scope>
            <optional>true</optional>
        </dependency>

        <dependency>
            <groupId>org.projectlombok</groupId>
            <artifactId>lombok</artifactId>
            <optional>true</optional>
        </dependency>
        <dependency>
            <groupId>org.springframework.boot</groupId>
            <artifactId>spring-boot-starter-test</artifactId>
            <scope>test</scope>
        </dependency>
    </dependencies>

3. 改YML

server:
  port: 3355

spring:
  application:
    name: config-client
  cloud:
    config:
      label: master
      name: config
      profile: dev
      uri: http://localhost:3344

eureka:
  client:
    service-url:
      defaultZone: http://eureka7001.com:7001/eureka


  • 要将application.yaml文件名称改为bootstrap.yaml是很关键的,bootstrap.yaml是比application.yaml优先加载的,且它是系统级的,优先级更高,
  • SpringCloud会创建一个Bootstrap Context,作为Spring应用的Application Context的父背景关系,初始化的时候,Bootstrap Context负责从外部源加载配置属性并决议配置,这两个背景关系共享一个从外部获取的Environment

4. 主启动

import org.springframework.boot.SpringApplication;
import org.springframework.boot.autoconfigure.SpringBootApplication;
import org.springframework.cloud.netflix.eureka.EnableEurekaClient;

@SpringBootApplication
@EnableEurekaClient
public class ConfigClientMain3355 {
    public static void main(String[] args) {
        SpringApplication.run(ConfigClientMain3355.class,args);
    }
}

5. Controller类

import org.springframework.beans.factory.annotation.Value;
import org.springframework.web.bind.annotation.GetMapping;
import org.springframework.web.bind.annotation.RestController;

@RestController
public class ConfigClientController {

    @Value("${spring.application.name}")
    private String configInfo;

    @GetMapping("/configInfo")
    public String getConfigInfo(){
        return configInfo;
    }
}

6. 测验结果

在这里插入图片描述


在这里插入图片描述

  • 如图所示,我们成功的从相应的组态档中读取到内容

1.4、Config客户端之动态重绘(手动版)

1.4.1、面临的问题

  1. Linux运维修改GitHub上的组态档内容做调整

  2. 重绘3344,发现ConfigServer配置中心立刻回应

  3. 重绘3355,发现ConfigServer客户端没有任何回应

  4. 3355没有变化除非自己重启或者重新加载

1.4.2、动态重绘配置与测验

1. POM引入actuator监控

<dependency>
    <groupId>org.springframework.boot</groupId>
    <artifactId>spring-boot-starter-actuator</artifactId>
</dependency>

2. 在yml档案中添加以下代码

management:
  endpoints:
    web:
      exposure:
        include: "*"

3. 修改controller类

import org.springframework.beans.factory.annotation.Value;
import org.springframework.cloud.context.config.annotation.RefreshScope;
import org.springframework.web.bind.annotation.GetMapping;
import org.springframework.web.bind.annotation.RestController;

@RestController
@RefreshScope
public class ConfigClientController {

    @Value("${spring.application.name}")
    private String configInfo;

    @GetMapping("/configInfo")
    public String getConfigInfo(){
        return configInfo;
    }
}

4. 需要发送一个请求重绘客户端

curl -X POST "http://localhost:3355/actuator/refresh"

在这里插入图片描述

5. 测验结果

(1)、访问3344埠

在这里插入图片描述

(2)、访问3355埠

在这里插入图片描述

2、Bus

2.1、概述简介

1. 是什么

  • Spring Cloud Bus是用来将分布式系统的节点与轻量级讯息系统连接起来的框架,它整合了Java的事件处理机制和讯息中间件的功能,Spring Cloud Bus目前支持RabbitMQKafka
  • 在微服务架构的系统中,通常会使用轻量级的讯息代理来构建一个公用的讯息主题,并让系统中所有微服务实体都连接上来,由于该主题中产生的讯息会被所有实体监听和消费,所以称它为讯息总线,在总线的各个实体,都可以方便地广播一些需要让其他连接在该主题上的实体都知道的讯息,
  • 其原理是ConfigClient实体都监听MQ中同一个topic默认是SpringCloudBus,当一个服务重绘资料的时候,他会把这个讯息放入到Topic中,这样其它监听到同一Topic的服务就能得到通知,然后去更新自身的配置,

2. 能干嘛

在这里插入图片描述

  • Spring Cloud Bus能管理和传播分布式系统间的讯息,就像一个分布式执行器,可用于广播状态更改、时间推送等,也可以当作微服务间的通信通道,

2.2、全域广播形式的动态重绘

2.2.1、新添加一个客户端

1. 建Module

  • Module的名称为cloud-config-client-3366

2. 改POM


<dependencies>

    <dependency>
        <groupId>org.springframework.cloud</groupId>
        <artifactId>spring-cloud-starter-config</artifactId>
    </dependency>
    <dependency>
        <groupId>org.springframework.cloud</groupId>
        <artifactId>spring-cloud-starter-netflix-eureka-client</artifactId>
    </dependency>
    <dependency>
        <groupId>com.atguigu.springcloud</groupId>
        <artifactId>cloud-api-commons</artifactId>
        <version>${project.version}</version>
    </dependency>
    <dependency>
        <groupId>org.springframework.boot</groupId>
        <artifactId>spring-boot-starter-web</artifactId>
    </dependency>

    <dependency>
        <groupId>org.springframework.boot</groupId>
        <artifactId>spring-boot-starter-actuator</artifactId>
    </dependency>

    <dependency>
        <groupId>org.springframework.boot</groupId>
        <artifactId>spring-boot-devtools</artifactId>
        <scope>runtime</scope>
        <optional>true</optional>
    </dependency>

    <dependency>
        <groupId>org.projectlombok</groupId>
        <artifactId>lombok</artifactId>
        <optional>true</optional>
    </dependency>
    <dependency>
        <groupId>org.springframework.boot</groupId>
        <artifactId>spring-boot-starter-test</artifactId>
        <scope>test</scope>
    </dependency>
</dependencies>

3. 改YML

server:
  port: 3366

spring:
  application:
    name: config-client
  cloud:
    config:
      label: master
      name: config
      profile: dev
      uri: http://localhost:3344
eureka:
  client:
    service-url:
      defaultZone: http://eureka7001.com:7001/eureka
management:
  endpoints:
    web:
      exposure:
        include: "*"
 

4. 主启动

import org.
							
标签:

0 评论

发表评论

您的电子邮件地址不会被公开。 必填的字段已做标记 *