怎么使用Consul当配置中心和动态刷新配置

一、背景

由于Eureka官方已经正式宣布,自2.0起不再维护该项目,如果需要使用2.x,自行承担风险。

项目之前使用的Eureka,现在不维护了则需要寻找替代方案。现在Spring Cloud官方推荐Spring Cloud Consul替换Eureka作为注册中心,那么什么是Consul呢?

官网的描述:

HashiCorp Consul 是一种服务网络解决方案,可以帮助团队在本地和多云环境以及运行时之间管理服务之间的安全网络连接。Consul 提供服务发现、服务网格、流量管理和对网络基础设备的自动更新。您可以单独使用这些功能,也可以在单个 Consul 部署中将它们一起使用。

能干什么?

服务注册与发现:consul提供服务注册与发现功能,服务启动时会向consul注册自己的信息,其它服务可以通过consul来查询特定服务的信息,从而实现不同服务之间的通信。

健康检查:consul提供了多种健康检查的方式,对服务进行健康检查,确保服务能正常提供服务。如果检测到服务不再健康,consul会自动将其标记为不可用,并将流量路由到其它健康的实例。

KV存储:它提供了一个分布式的K/V存储系统,可用于配置和存储数据。也就是它能当配置中心的原因。

一致性的保证:consul使用Raft协议来确保数据的一致性,保证节点之间数据的一致。

DNS接口:提供了DNS接口,允许使用域名进行服务发现,使得服务发现变得更简单通用。

多数据中心:consul支持多个数据中心集群,支持在不同的地区部署多个consul集群,并在他们之间进行通讯和同步。

可视化界面:提供了一套可视化的页面,非常方便查看集群信息和进行相应的配置。

二、配置中心

1. 什么是配置中心?

在现在分布式系统和微服务架构中,每个服务都有自己的配置,这些配置又分为公共的配置(每个服务都相同的部分)和私有的配置(这个服务特有的部分配置)。并且在不同的环境中配置又不尽相同,例如在开发环境和生成环境的数据库配置就会不一样,如果单独对每个服务进行配置和管理会显得及其麻烦,所以集中式管理的思想就诞生了!

配置中心是一个集中管理和分发应用程序配置的系统。在现代分布式系统和微服务架构中,配置中心起着至关重要的作用,因为它能够提供一种统一的方式来管理不同服务的配置,并且支持动态更新配置而无需重启服务。

2. Spring Cloud Config配置中心

项目之前使用spring cloud config作为配置中心,但是需要配合git存储,且还需要配合Spring Cloud Bus来实现动态刷新配置,动态刷新配置这一块不是很方便。

3. Consul作为配置中心

了解到了上面提到的,K/V存储可以存储配置信息。Spring Cloud官方还声明Consul可以作为Spring Cloud Config配置中心的替代方案。并且不需要git配合,不需要集成Spring Cloud Bus即可实现动态刷新配置,它通过长轮询的方式从consul上检测到配置的变化,然后通知到客户端。所以,我们决定使consul作为配置中心。

三、实战演示

1. Consul下载

下载地址:Install | Consul | HashiCorp Developer

2. 在本地启动

启动命令如下,因为我们要做配置中心,配置要持久化,所以采用下面的方式启动,而不是consul.exe agent -dev

consul.exe agent -server -config-dir=C:/ProgramFiles/consul/config -data-dir=C:/ProgramFiles/consul/data -bind=127.0.0.1 -bootstrap-expect=1 -ui

启动成功后,访问http://localhost:8500/,如果出现下面的页面则启动成功。

3. 在pom文件中加入 SpringCloud Consul及其配置中心相关的包
<dependency>
	<groupId>org.springframework.boot</groupId>
	<artifactId>spring-boot-starter-actuator</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</artifactId>
</dependency>
<dependency>
	<groupId>org.springframework.cloud</groupId>
	<artifactId>spring-cloud-starter-consul-config</artifactId>
</dependency>
<dependency>
	<groupId>org.springframework.cloud</groupId>
	<artifactId>spring-cloud-starter-consul-discovery</artifactId>
</dependency>
<dependency>
	<groupId>org.springframework.cloud</groupId>
	<artifactId>spring-cloud-starter-bootstrap</artifactId>
</dependency>
4. application.yml添加consul的配置
spring:
  application:
    name: consulMicroservice
  profiles:
    active: dev
  cloud:
    consul:
      host: localhost
      port: 8500
      discovery:
        healthCheckPath: /management/health
        instanceId: consulmicroservice:${spring.application.instance-id:${random.value}}
        service-name: consulmicroservice
        prefer-ip-address: true

#consul健康检查需要开启actuator的health断点
management:
  endpoints:
    web:
      base-path: /management
      exposure:
        include:
          - health
5. bootstrap.yml添加consul配置中心的相关配置 
spring:
  application:
    name: consulMicroservice
  profiles:
    active: dev
  cloud:
    consul:
      config:
        fail-fast: false # if not in "prod" profile, do not force to use Spring Cloud Config
        format: yaml
        profile-separator: '-'
        # 是否启用配置中心,默认值 true 开启
        enabled: true
        # 设置配置的基本文件夹,默认值config 可以理解为配置文件所在的最外层文件夹
        prefix: config
        # 设置应用的文件夹名称,默认值application 一般建议设置为微服务应用名称
        default-context: application
        # Consul Key/Values 中的Key, 默认为data, Value 对应整个配置文件
        data-key: data
        #name: consulMicroservice
        # 以上配置可以理解为:加载 config/application/下Key 为data 文件夹下公共配置 和 config/jhipsterSampleMicroservice/下Key 为data 的Value 对应的私有配置
        watch:
          # 等待(或阻塞)监视查询的秒数,默认:55秒,需要小于60,如果需要修改后立刻能读取配置,则需要修改为1秒
          wait-time: 55
          # 是否开启自动刷新,默认值true 开启
          enabled: true
          # 刷新频率,单位:毫秒,默认值1000
          delay: 1000
      discovery:
        tags:
          - profile=${spring.profiles.active}
          - version=#project.version#
          - git-version=${git.commit.id.describe:}
          - git-commit=${git.commit.id.abbrev:}
          - git-branch=${git.branch:}
          - context-path=${server.servlet.context-path:}

      host: localhost
      port: 8500
6. 读取本地配置-启动项目

启动成功后在本地,看到是在8080端口运行。服务也已经注册到consul上了。

7. 在consul上创建相关的配置项

官网上的文件加载顺序:

 大概的意思是,项目启动后加载配置文件的顺序如下:

  1. config/testApp,dev/
  2. config/testApp/
  3. config/application,dev/
  4. config/application/

其中,config/testApp文件夹中的配置,只适用于testApp,config/application文件夹中的配置对所有注册到consul上的服务都可用。

接下来,我按照这个结构在consul上创建文件夹config/application存放公共的配置和文件夹config/consulMicroservice用来存放consulMicroservice私有的配置。

在application文件夹中添加公共配置,比如jwt token的密钥

 在consulMicroservice文件夹中添加私有的配置,并把端口修改为8090

8. 读取配置中心的配置-启动项目

在启动项目之前,我们先加一个controller来读取config/spplication中的配置,看能否读取到。注意需要加上@RefreshScope这个注解。

@RestController
@RefreshScope
public class DynamicConfigResource {

    private final Logger log = LoggerFactory.getLogger(DynamicConfigResource.class);

    @Value("${spring.security.authentication.jwt.base64-secret:null}")
    private String jwtKey;

    @GetMapping("/jwt")
    public String getConfigValues() {
        log.info("JWT Key: {}", jwtKey);
        return "jwt Config: " + jwtKey;
    }
}

项目启动之后,我们可以看在在8090端口上运行,说明成功加载了配置中心config/consulMicroservice中的配置数据。

接下来我们继续测试,能否读取到config/spplication中的公共配置。浏览器中访问:http://localhost:8090/jwt

将配置中心中公共配置打印出来了,说明也成功的读取到了config/application中的数据。

9. 配置动态刷新

这对我们项目来说很重要的一个特性。当配置中心的配置发生变化时,客户端能够获取到最新的配置。它是通过长轮询,和下面的两个机制实现的。

  • Consul Watch机制:监视配置变化,当配置发生变化时,通知客户端。
  • @RefreshScope注解:标记需要动态刷新的Bean,当接收到刷新事件时,这些Bean会重新加载最新的配置。

首先,我们先在配置中心更新 base64-secret的值。直接在后面加"test_refresh",然后保存。

然后,我们可以看到log中输出了下面的信息,证明配置更新了。可能不会立即看到,因为默认每次轮询等待时间为55s,如果希望立刻看到变化需要修改配置:spring.cloud.consul.config.watch.wait-time = 1

接下来,我们再到浏览器中请求一下:http://localhost:8090/jwt 可以看配置已经动态刷新。

 最后,我们来总结一下动态刷新配置的原理。

Consul使用一种叫做长轮询的机制来检测配置的变化。客户端发送一个HTTP请求到Consul服务器,服务器在有新的变更发生时立即返回响应。如果在指定的wait-time内没有变化,服务器会在超时前返回一个空响应。这种机制可以减少服务器的负载,因为客户端不会频繁地发起请求,而是等待配置变更事件的发生。

本文来自互联网用户投稿,该文观点仅代表作者本人,不代表本站立场。本站仅提供信息存储空间服务,不拥有所有权,不承担相关法律责任。如若转载,请注明出处:/a/729311.html

如若内容造成侵权/违法违规/事实不符,请联系我们进行投诉反馈qq邮箱809451989@qq.com,一经查实,立即删除!

相关文章

网络协议安全:TCP/IP协议栈的安全问题和解决方案

「作者简介」:北京冬奥会网络安全中国代表队,CSDN Top100,就职奇安信多年,以实战工作为基础对安全知识体系进行总结与归纳,著作适用于快速入门的 《网络安全自学教程》,内容涵盖Web安全、系统安全等12个知识域的一百多个知识点,持续更新。 这一章节我们需要知道TCP/IP每…

openresty(Nginx) 301重定向域名 http访问强制使用https

1 访问http 2 修改配置访问 server {listen 80;server_name example.cn;return 301 https://$server_name$request_uri;access_log /data/logs/czgzzfjgsup_access.log access;error_log /data/logs/czgzzfjg_error.log error;#location / {root /usr/local/open…

领域驱动设计(DDD)微服务架构模式总结

part1. Domain Driven Design(Strategic Design,Tactical Design) Top Down focus on business or activityy domain Ubiquitous Language:统一语言 Tactical Design Tools&#xff1a;战术性设计工具 Implementing Domain Driven Design(Event storming,DDD in code) DDD总结…

大模型基础——从零实现一个Transformer(4)

大模型基础——从零实现一个Transformer(1)-CSDN博客 大模型基础——从零实现一个Transformer(2)-CSDN博客 大模型基础——从零实现一个Transformer(3)-CSDN博客 一、前言 上一篇文章已经把Encoder模块的单个EncodeBlock已经实现了 本文我们继续了解Transformer中剩下的其他…

Flutter【组件】富文本组件

简介 flutter 富文本组件。 github地址&#xff1a; https://github.com/ThinkerJack/jac_uikit 使用方式 运行 flutter pub add jac_uikit组件文档 使用方式&#xff1a; HighlightedTextWidget.builder(text: "全部文案包含高亮文案测试用",highlights: [Hig…

1. zookeeper分布式协调者

zookeeper分布协调者 一、zookeeper介绍1、软件设计架构1.1 单体架构1.2 SOA架构/分布式1.3 微服务架构 二、zookeeper角色1、角色2、选举机制3、znode类型 三、zookeeper集群部署1、环境规划2、安装jdk3、安装配置zookeeper3.1 安装zookeeper3.2 编辑配置文件3.3 创建myid文件…

聊聊最近比较火的AI产品做互联网算法备案

今年AI&#x1f525;了&#xff0c;而且是大火&#xff0c;导致监管部门相继出台相关政策&#xff0c;需要管控下&#xff0c;所以互联网算法备案就自然而然重新被提出来。其实这个互联网算法备案去年就已经开始实施了&#xff0c;去年只有几个大厂比如BAT等互联网巨头等会去弄…

Lazada API接口——一键获取商品买家评论数据信息

一、引言 在电商领域&#xff0c;买家评论是商品销售中不可忽视的重要因素。它们不仅影响着潜在消费者的购买决策&#xff0c;还为商家提供了宝贵的客户反馈。为了满足商家和数据分析师对买家评论数据的需求&#xff0c;我们特别开发了一款针对Lazada平台的接口&#xff0c;其…

Talk|北京大学张嘉曌:NaVid - 视觉语言导航大模型

本期为TechBeat人工智能社区第602期线上Talk。 北京时间6月20日(周四)20:00&#xff0c;北京大学博士生—张嘉曌的Talk已经准时在TechBeat人工智能社区开播&#xff01; 他与大家分享的主题是: “NaVid - 视觉语言导航大模型”&#xff0c;NaVid是首个专为视觉语言导航&#xf…

Cancer Discovery | 非小细胞肺癌的空间蛋白组学研究再添新篇章

非小细胞肺癌&#xff08;NSCLC&#xff09;作为最常见的肺癌亚型&#xff0c;其治疗和预后的改善一直是医学研究的重点。由肿瘤细胞、免疫细胞、成纤维细胞等多种细胞类型组成的肿瘤微环境&#xff08;TME&#xff09;已被证实在肺癌的进展、转移和治疗响应中扮演着重要的角色…

MySQL——索引(概述和结构介绍)

一、索引概述 1、索引(index&#xff09;是帮助 MySQL 高效获取数据的数据结构(是一种有序的数据结构)。 2、在数据之外&#xff0c;数据库系统还维护着满足特定查找算法的数据结构。这些数据结构以某种方式引用&#xff08;指向&#xff09;数据&#xff0c;这样就可以在这些…

概率论与数理统计期末复习

概率论常考知识点汇总 总括 1. 基础概率论 概率定义&#xff1a;理解概率是事件发生的可能性度量&#xff0c;范围从0&#xff08;不可能&#xff09;到1&#xff08;必然发生&#xff09;。概率公理&#xff1a;掌握概率的三大公理&#xff0c;即非负性、规范性和可加性。条…

使用 cx_Oracle 在 Oracle 中等待记录并执行操作

问题背景&#xff1a; 在第一个 Python 项目中&#xff0c;需要等待记录被插入 Oracle 表中&#xff0c;一旦记录存在&#xff0c;就调用 Python 函数。目前使用 cx_Oracle 库&#xff0c;采用一种无限循环的方式来查询表。如果记录存在&#xff0c;就调用函数&#xff0c;然后…

分类预测 | ZOA-PCNN-AT-SVM斑马优化并行卷积-支持向量机融合注意力机制的故障识别

分类预测 | ZOA-PCNN-AT-SVM斑马优化并行卷积-支持向量机融合注意力机制的故障识别 目录 分类预测 | ZOA-PCNN-AT-SVM斑马优化并行卷积-支持向量机融合注意力机制的故障识别分类效果基本描述程序设计参考资料 分类效果 基本描述 1.ZOA-PCNN-AT-SVM斑马优化并行卷积-支持向量机融…

Linux【实操篇-文件目录类命令】

05【实操篇-文件目录类命令】 1.pwd 显示当前工作目录的绝对路径 pwd:print working directory 打印工作目录 到现在为止&#xff0c;我们还不知道自己在系统的什么地方。在浏览器上&#xff0c;我们能够通过导航栏上的url&#xff0c;了解到自己在互联网上的具体坐标。相似的…

金蝶云星空与MES系统深度集成对接案例全公开

项目背景 深圳市某自动化设备有限公司&#xff0c;自2006年成立以来&#xff0c;一直专注于高端精密自动化设备的研发、生产与销售。作为一家高科技企业&#xff0c;公司依托深圳这一经济特区的地理优势&#xff0c;构建了覆盖全国的服务网络&#xff0c;并拥有两个先进的生产…

椭圆的矩阵表示法

椭圆的矩阵表示法 flyfish 1. 标准几何表示法 标准几何表示法是通过椭圆的几何定义来表示的&#xff1a; x 2 a 2 y 2 b 2 1 \frac{x^2}{a^2} \frac{y^2}{b^2} 1 a2x2​b2y2​1其中&#xff0c; a a a 是椭圆的长半轴长度&#xff0c; b b b 是椭圆的短半轴长度。 2.…

LogicFlow 学习笔记——9. LogicFlow 进阶 节点

LogicFlow 进阶 节点&#xff08;Node&#xff09; 连线规则 在某些时候&#xff0c;我们可能需要控制边的连接方式&#xff0c;比如开始节点不能被其他节点连接、结束节点不能连接其他节点、用户节点后面必须是判断节点等&#xff0c;想要达到这种效果&#xff0c;我们需要为…

iOS开发工具-网络封包分析工具Charles

一、Charles简介 Charles 是在 Mac 下常用的网络封包截取工具&#xff0c;在做 移动开发时&#xff0c;我们为了调试与服务器端的网络通讯协议&#xff0c;常常需要截取网络封包来分析。 Charles 通过将自己设置成系统的网络访问代理服务器&#xff0c;使得所有的网络访问请求…

云手机群控功能讲解

接触云手机之前&#xff0c;很多企业或者个人卖家都对群控有浓厚的兴趣&#xff0c;云手机群控具体是什么呢&#xff1f;云手机群控&#xff0c;顾名思义&#xff0c;是指能够同时对多台云手机进行集中控制和管理的功能。打破了传统单台手机操作的限制&#xff0c;实现了规模化…