IT数码 购物 网址 头条 软件 日历 阅读 图书馆
TxT小说阅读器
↓语音阅读,小说下载,古典文学↓
图片批量下载器
↓批量下载图片,美女图库↓
图片自动播放器
↓图片自动播放器↓
一键清除垃圾
↓轻轻一点,清除系统垃圾↓
开发: C++知识库 Java知识库 JavaScript Python PHP知识库 人工智能 区块链 大数据 移动开发 嵌入式 开发工具 数据结构与算法 开发测试 游戏开发 网络协议 系统运维
教程: HTML教程 CSS教程 JavaScript教程 Go语言教程 JQuery教程 VUE教程 VUE3教程 Bootstrap教程 SQL数据库教程 C语言教程 C++教程 Java教程 Python教程 Python3教程 C#教程
数码: 电脑 笔记本 显卡 显示器 固态硬盘 硬盘 耳机 手机 iphone vivo oppo 小米 华为 单反 装机 图拉丁
 
   -> Java知识库 -> 微服务配置中心Spring Cloud Config 和 Bus -> 正文阅读

[Java知识库]微服务配置中心Spring Cloud Config 和 Bus

Spring Cloud学习笔记总目录:总目录

Spring Cloud Config

  • spring cloud config是为微服务架构中的各个服务提供集中化的外部配置支持的组件
  • 分为服务端和客户端两个部分,服务端也叫分布式配置中心Config Server),是一个独立的微服务应用,用来保存配置信息(默认使用Git存储),客户端(Config Client)则就是通过指定的配置中心来获取配置内容

使用Spring Cloud Config的好处

  1. 集中管理公用配置信息
  2. 动态的配置更新,切换配置环境(开发、测试、生产),实时同步到所有服务
  3. 配置信息以REST接口形式暴露

bootstrap.yml是什么

  • 简单的说,application.yml是各个服务各自的配置,而bootstrap.yml则是系统级的、公用的,具有最高优先级
  • 必须要将Config Client服务的配置文件命名为bootstrap.yml

如何动态刷新配置到各个client

  1. 加入actuator行为监控图形化的pom依赖
  2. 暴露监控端点,让服务器中心检测到
  3. controller层加@RefreshScope
  4. 需要运维工程师发送一个post请求(如:curl -X POST http://localhost:3355/actuator/refresh)到需要刷新配置的微服务,就不用重启了

但是很麻烦,需要向每个微服务单独发请求,有没有一种广播通知,可以让我们只用发送一次广播就处处生效呢?这就是后文的Bus

@RefreshScope注解

@RestController
@RefreshScope
public class ConfigClientController
{
    @Value("${config.info}")
    private String configInfo;

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

Config Server的配置

关键依赖

<!--添加消息总线RabbitMQ支持-->
<dependency>
    <groupId>org.springframework.cloud</groupId>
    <artifactId>spring-cloud-starter-bus-amqp</artifactId>
</dependency>
<dependency>
    <groupId>org.springframework.cloud</groupId>
    <artifactId>spring-cloud-config-server</artifactId>
</dependency>

<!-- 图形监控 -->
<dependency>
    <groupId>org.springframework.boot</groupId>
    <artifactId>spring-boot-starter-actuator</artifactId>
</dependency>
  • 启动类加@EnableConfigServer
  • 其中有些是关于Bus的配置
server:
  port: 3344

spring:
  application:
    name:  cloud-config-center #注册进Eureka服务器的微服务名
  cloud:
    config:
      server:
        git:
          uri: git@github.com:zzyybs/springcloud-config.git #GitHub上面的git仓库名字
          search-paths:
            - springcloud-config # 类似于根目录
      label: master # 读取的分支
# rabbitmq相关配置 Bus要用
rabbitmq:
    host: localhost
    port: 5672
    username: guest
    password: guest

#服务注册到eureka地址
eureka:
  client:
    service-url:
      defaultZone: http://localhost:7001/eureka

# rabbitmq相关配置,暴露bus刷新配置的端点
management:
  endpoints: #暴露bus刷新配置的端点
    web:
      exposure:
        include: 'bus-refresh'

Config Client的配置

关键依赖

<!--添加消息总线RabbitMQ支持-->
<dependency>
    <groupId>org.springframework.cloud</groupId>
    <artifactId>spring-cloud-starter-bus-amqp</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>
  • 注意配置文件名叫bootstrap.yml
server:
  port: 3355

spring:
  application:
    name: config-client
  cloud:
    # Config客户端配置
    config:
      label: master # 分支名称
      name: config # 配置文件名称
      profile: dev # 读取后缀名称   上述3个综合:master分支上config-dev.yml的配置文件被读取http://config-3344.com:3344/master/config-dev.yml
      uri: http://localhost:3344 # config server的地址

#rabbitmq相关配置 15672是Web管理界面的端口;5672是MQ访问的端口
  rabbitmq:
    host: localhost
    port: 5672
    username: guest
    password: guest

#服务注册到eureka地址
eureka:
  client:
    service-url:
      defaultZone: http://localhost:7001/eureka

# 暴露监控端点
management:
  endpoints:
    web:
      exposure:
        include: "*"

Spring Cloud Bus

  • 简单的说就是在微服务架构的系统中构建了一个共用的消息主题,该主题中产生的消息会被订阅了它的所有微服务实例监听、消费
  • 基本原理:所有Config Client实例都监听MQ中同一个topic(默认叫springCloudBus),当数据更新的时候,实例就会自动更新自己的配置
  • Spring Cloud Bus配合Spring Cloud Config可以实现配置的动态刷新,Spring Cloud Bus目前只支持RabbitMQ和Kafka

两种设计思想

  1. 利用消息总线触发一个 客户端 /bus/refresh,由该客户端刷新所有客户端的配置
  2. 利用消息总线触发一个 服务端 ConfigServer 的 /bus/refresh 端点,由Server刷新所有客户端的配置(更加推荐)

方案1不适合的原因如下:

  1. 打破了微服务的职责单一性,因为微服务本身是业务模块,它本不应该承担配置刷新职责
  2. 破坏了微服务各节点的对等性
  3. 有一定的局限性。例如,微服务在迁移时,它的网络地址常常会发生变化,此时如果想要做到自动刷新,那就会增加更多的修改

主要添加的配置(简单说,前文都有)

  1. bus-amqp的依赖
  2. mq的配置
  3. 暴露 Bus 刷新配置的端点

最后只需要发送一个post请求(curl -X POST "http://localhost:3344/actuator/bus-refresh")到Config Server,就可以实现配置文件的动态刷新广播

动态刷新定点通知

  • 上文配置的是广播,假设想要实现定点通知,只需要更改一下post请求:http://localhost:配置中心的端口号/actuator/bus-refresh/{destination}
  • 其中destination是指定的微服务名+端口,如:config-client:3355
  • /bus-refresh 请求不再发送到具体的服务实例上,而是发给 config server 并通过 destination 参数类指定需要更新配置的服务或实例

总结

在这里插入图片描述

  Java知识库 最新文章
计算距离春节还有多长时间
系统开发系列 之WebService(spring框架+ma
springBoot+Cache(自定义有效时间配置)
SpringBoot整合mybatis实现增删改查、分页查
spring教程
SpringBoot+Vue实现美食交流网站的设计与实
虚拟机内存结构以及虚拟机中销毁和新建对象
SpringMVC---原理
小李同学: Java如何按多个字段分组
打印票据--java
上一篇文章      下一篇文章      查看所有文章
加:2021-12-06 15:07:02  更:2021-12-06 15:08:46 
 
开发: C++知识库 Java知识库 JavaScript Python PHP知识库 人工智能 区块链 大数据 移动开发 嵌入式 开发工具 数据结构与算法 开发测试 游戏开发 网络协议 系统运维
教程: HTML教程 CSS教程 JavaScript教程 Go语言教程 JQuery教程 VUE教程 VUE3教程 Bootstrap教程 SQL数据库教程 C语言教程 C++教程 Java教程 Python教程 Python3教程 C#教程
数码: 电脑 笔记本 显卡 显示器 固态硬盘 硬盘 耳机 手机 iphone vivo oppo 小米 华为 单反 装机 图拉丁

360图书馆 购物 三丰科技 阅读网 日历 万年历 2024年11日历 -2024/11/24 5:06:13-

图片自动播放器
↓图片自动播放器↓
TxT小说阅读器
↓语音阅读,小说下载,古典文学↓
一键清除垃圾
↓轻轻一点,清除系统垃圾↓
图片批量下载器
↓批量下载图片,美女图库↓
  网站联系: qq:121756557 email:121756557@qq.com  IT数码