配置中心--Spring Cloud Config

目录

概述

环境说明

步骤

创建远端git仓库

准备配置文件

配置中心--服务端

配置中心--客户端

配置中心的高可用

配置中心--服务端

配置中心--客户端

消息总线刷新配置

配置中心--服务端

配置中心--客户端


概述

因为微服务架构有很多个服务,手动一个一个管理各个服务配置很麻烦,不同的环境(开发、测试、生产)往往需要不同的配置文件,运行期间也需要动态调整配置,修改配置后微服务需要自动更新配置,所以需要一个统一管理应用配置的组件。

配置中心是一种统一管理各种应用配置的基础服务组件。本文讲解的配置中心组件为Spring Cloud Config。

本文的操作可在 微服务调用链路追踪 的基础上进行 或者 在 Spring Cloud Stream实践 的基础上进行。

环境说明

jdk1.8

maven3.6.3

mysql8

spring cloud2021.0.8

spring boot2.7.12

idea2022

rabbitmq3.12.4

步骤

创建远端git仓库

创建远端git仓库,管理配置文件,使用gitee,创建仓库名称为config-repo(创建时点击创建README文件,方便直接用浏览器上传文件)

可使用远端仓库管理微服务公共的配置,而非公共的配置可放在各自微服务的application.yml中。

公共的配置,例如:数据库配置、Eureka配置等

非公共的配置,例如:端口号、应用名称等

准备配置文件

配置中心的配置文件命名规则为:

{application}-{profile}.yml
{application}-{profile}.properties

application为应用名称 profile指的开发环境(用于区分开发环境、测试环境、生产环境等)

复制product-serviceapplication.yml,重命名为application-pro.yml,抽取公共配置,例如:数据库配置、zipkin、sleuth、rabbitmq、eureka等,同时添加一个name属性(用于区别不同的环境配置),公共的配置放在远端git仓库。

application-pro.yml

spring:datasource:driver-class-name: com.mysql.cj.jdbc.Driverurl: jdbc:mysql://localhost:3306/shop1?useUnicode=true&characterEncoding=utf-8&serverTimezone=GMT%2B8username: rootpassword: 123jpa:database: MySQLshow-sql: trueopen-in-view: truegenerate-ddl: true #自动创建表zipkin:sender:type: rabbit #数据的传输方式,以rabbit的方式向server端发送数据sleuth:sampler:probability: 1 #采样比,日志的采样比例,默认0.1,测试环境设置为100%收集日志rabbitmq:host: localhostport: 5672username: guestpassword: guestlistener: #这里配置重试策略direct:retry:enabled: truesimple:retry:enabled: trueeureka:client:service-url:defaultZone: http://localhost:9000/eureka/instance:prefer-ip-address: trueinstance-id: ${spring.cloud.client.ip-address}:${server.port}logging:level:root: infoorg.springframework.web.servlet.DispatcherServlet: DEBUGorg.springframework.cloud.sleuth: DEBUGname: product-pro

复制application-pro.yml得到application-dev.yml

application-dev.yml

配置内容如下,区别在于name的值为product-dev

spring:datasource:driver-class-name: com.mysql.cj.jdbc.Driverurl: jdbc:mysql://localhost:3306/shop1?useUnicode=true&characterEncoding=utf-8&serverTimezone=GMT%2B8username: rootpassword: 123jpa:database: MySQLshow-sql: trueopen-in-view: truegenerate-ddl: true #自动创建表zipkin:sender:type: rabbit #数据的传输方式,以rabbit的方式向server端发送数据sleuth:sampler:probability: 1 #采样比,日志的采样比例,默认0.1,测试环境设置为100%收集日志rabbitmq:host: localhostport: 5672username: guestpassword: guestlistener: #这里配置重试策略direct:retry:enabled: truesimple:retry:enabled: trueeureka:client:service-url:defaultZone: http://localhost:9000/eureka/instance:prefer-ip-address: trueinstance-id: ${spring.cloud.client.ip-address}:${server.port}logging:level:root: infoorg.springframework.web.servlet.DispatcherServlet: DEBUGorg.springframework.cloud.sleuth: DEBUGname: product-dev

通过浏览器界面,手动上传application-pro.ymlapplication-dev.yml到git仓库

点击上传文件区域,选中需要上传的文件:application-pro.ymlapplication-dev.yml

 填写提交信息,点击提交

上传成功后,如下图

配置中心--服务端

创建子工程config_server

引入依赖

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

启动类

package org.example.config;import org.springframework.boot.SpringApplication;
import org.springframework.boot.autoconfigure.SpringBootApplication;
import org.springframework.cloud.config.server.EnableConfigServer;@SpringBootApplication
@EnableConfigServer //开启配置中心服务端功能
public class ConfigServerApplication {public static void main(String[] args) {SpringApplication.run(ConfigServerApplication.class, args);}
}

配置application.yml

server:port: 11111
spring:application:name: config-servercloud:config:server:git:uri: https://gitee.com/xxx/config-repo.git

uri的值是刚才创建的远端git仓库的地址,注意修改为自己的仓库地址。

启动config_server服务

浏览器访问

http://localhost:11111/application-dev.yml

访问不到数据

原因是gitee仓库是私有的,需要把仓库公开或者配置gitee的登录信息。

解决方法1:将git仓库开源

解决方法2:修改配置,加上gitee的用户名和密码

cloud:config:server:git:uri: https://gitee.com/xxx/config-repo.gitusername: xxxpassword: xxx

两种方法选择其中一个。

解决后,再次访问

http://localhost:11111/application-dev.yml

成功看到数据如下 

配置中心--客户端

配置中心客户端就是各个微服务

这里创建一个微服务:config_client_1

config_client_1项目结构如下

添加依赖

	<dependencies><dependency><groupId>org.springframework.boot</groupId><artifactId>spring-boot-starter-web</artifactId></dependency><dependency><groupId>mysql</groupId><artifactId>mysql-connector-java</artifactId><version>8.0.33</version></dependency><dependency><groupId>org.springframework.boot</groupId><artifactId>spring-boot-starter-data-jpa</artifactId></dependency><!--引入EurekaClient--><dependency><groupId>org.springframework.cloud</groupId><artifactId>spring-cloud-starter-netflix-eureka-client</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><!--消息总线bus--><dependency><groupId>org.springframework.cloud</groupId><artifactId>spring-cloud-bus</artifactId></dependency><dependency><groupId>org.springframework.cloud</groupId><artifactId>spring-cloud-stream-binder-rabbit</artifactId></dependency><dependency><groupId>org.springframework.cloud</groupId><artifactId>spring-cloud-starter-bootstrap</artifactId></dependency></dependencies>

刷新依赖

非公共的配置application.yml

server:port: 9101
spring:application:name: config-client1

bootstrap.yml

spring:cloud:config:name: application #应用名称对应git配置文件的前半部分,例如:application-dev.yml,这里就写applicationprofile: dev #开发环境label: master #git中的分支uri: http://localhost:11111 #config_server的请求地址

ConfigClientApplication.java

package org.example.config.client;import org.springframework.boot.SpringApplication;
import org.springframework.boot.autoconfigure.SpringBootApplication;
import org.springframework.boot.autoconfigure.domain.EntityScan;@SpringBootApplication
@EntityScan("org.example.config.client.entity.Product")
public class ConfigClientApplication {public static void main(String[] args) {SpringApplication.run(ConfigClientApplication.class, args);}
}

Product.java

package org.example.config.client.entity;import lombok.Data;import javax.persistence.Entity;
import javax.persistence.Id;
import javax.persistence.Table;
import java.math.BigDecimal;/*** 商品实体类*/
@Data
@Entity
@Table(name="tb_product")
public class Product {@Idprivate Long id;private String productName;private Integer status;private BigDecimal price;private String productDesc;private String caption;private Integer inventory;
}

ProductController.java

package org.example.config.client.controller;import org.example.config.client.entity.Product;
import org.springframework.beans.factory.annotation.Value;
import org.springframework.stereotype.Controller;
import org.springframework.web.bind.annotation.RequestMapping;
import org.springframework.web.bind.annotation.RestController;@RestController
@RequestMapping("/config-client/product")
public class ProductController {@Value("${name}")private String name;@RequestMapping("/get")public Product getProduct(){Product product = new Product();product.setProductName(name);return product;}
}

启动eureka、config_server、config_client_1服务

注意:因为远端git仓库的配置文件有eureka配置,所以拉取到配置后,需要启动eureka服务

浏览器访问

http://localhost:9101/config-client/product/get

响应
{"id":null,"productName":"product-dev","status":null,"price":null,"productDesc":null,"caption":null,"inventory":null}

pruductName为product-dev,与git的application-dev.yml的name属性一致

config_client_1bootstrap.yml的profile改为pro

重启config_client_1服务

再次访问

http://localhost:9101/config-client/product/get
响应
{"id":null,"productName":"product-pro","status":null,"price":null,"productDesc":null,"caption":null,"inventory":null}

 pruductName为product-pro,与git的application-pro.yml的name属性一致

修改git的配置

查看application-pro.yml文件,点击编辑

product-pro改为product-pro1 

点击提交

浏览器访问

http://localhost:9101/config-client/product/get

发现数据未更新,还是product-pro

解决方式:

方式一:重启config_client_1服务

发现重启可以拿到最新数据,但是,在生产环境中,重启服务有时候不太方便。

方式二:手动刷新

修改config_client_1服务

pom.xml,引入actuator依赖(之前已引入,跳过)

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

在需要的更新数据的类上添加@RefreshScope,开启动态刷新

修改bootstrap.yml

#开启动态刷新的端点
management:endpoints:web:exposure:include: refresh

重启config_client_1服务

访问

http://localhost:9101/config-client/product/get

productName是product-pro1

将git配置文件的name值修改为product-pro2

发起post请求刷新数据

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

可使用postman或cmd命令行发起请求,这里使用cmd命令行发起post请求

再次访问

http://localhost:9101/config-client/product/get

响应最新的数据:product-pro2

手动刷新操作总结:

  1. 引入actuator依赖

  2. 需要的更新数据的类上添加@RefreshScope,开启动态刷新

  3. bootstrap.yml开启动态刷新的端点

  4. 修改git配置

  5. 发起post请求手动刷新数据

手动刷新能解决在不重启应用情况下,能做到动态刷新配置。但当服务很多时或需要更新的数据接口很多的情况下,就需要发起很多次Post请求,手动刷新显得很麻烦。可以使用消息总线技术解决该问题。

配置中心的高可用

一台配置中心服务容易出现单点故障问题,将配置中心集群化构成高可用的配置中心可以解决配置中心单点故障问题。

将多个配置中心注册到eureka,提供统一的服务名称,客户端通过服务名称调用配置中心。

配置中心--服务端

修改config_server服务

添加依赖

        <dependency><groupId>org.springframework.cloud</groupId><artifactId>spring-cloud-starter-netflix-eureka-client</artifactId></dependency><dependency><groupId>org.springframework.boot</groupId><artifactId>spring-boot-starter-actuator</artifactId></dependency>

刷新依赖

application.yml添加eureka相关配置

eureka:client:service-url:defaultZone: http://localhost:9000/eurekainstance:prefer-ip-address: trueinstance-id: ${spring.cloud.client.ip-address}:${server.port}

修改config_server配置文件,添加default-label: master配置

cloud:config:server:git:uri: https://gitee.com/xxx/config-repo.gitdefault-label: master

注意修改uri为自己git远端仓库地址。 

启动eureka、config_server服务

查看Eureka Web UI,看到了一台配置中心服务

http://localhost:9000/

通过复制配置方式,得到另外一台配置中心

修改端口号,复制运行配置,再启动一台配置中心服务

刷新查看Eureka Web UI,看到CONFIG-SERVER配置中心服务有两个实例。

配置中心--客户端

config_client_1服务

修改bootstrap.yml,添加eureka配置,修改通过服务名称(config-server)拿到配置

spring:cloud:config:name: application #应用名称对应git配置文件的前半部分,例如:application-dev.yml,这里就写applicationprofile: pro #开发环境label: master #git中的分支#uri: http://localhost:11111 #config_server的请求地址discovery:enabled: true #开启服务发现service-id: config-server #配置服务的服务名称
#开启动态刷新的端点
management:endpoints:web:exposure:include: refresheureka:client:service-url:defaultZone: http://localhost:9000/eurekainstance:prefer-ip-address: trueinstance-id: ${spring.cloud.client.ip-address}:${server.port}

重启config_client_1服务

访问

http://localhost:9101/config-client/product/get
响应
{"id":null,"productName":"product-pro2","status":null,"price":null,"productDesc":null,"caption":null,"inventory":null}

能正常拿到数据,说明配置正常

高可用测试

测试关闭其中一个服务,是否还可以正常提供服务

再次访问

访问依然正常,说明实现了配置中心的高可用。

总结:

  1. 服务端,添加服务注册依赖及配置,注册到eureka中,开启两个服务。

  2. 客户端,添加eureka配置,使用服务名称获取配置

  3. 测试:断开一个服务,不影响访问

消息总线刷新配置

此前,通过发起Post请求手动刷新配置,服务接口很多时,就需要发起很多次Post请求,显得很麻烦。

通过消息总线刷新配置流程如下:

配置中心--服务端

config_server服务

添加依赖

		<!--消息总线依赖--><dependency><groupId>org.springframework.cloud</groupId><artifactId>spring-cloud-starter-bus-amqp</artifactId></dependency><dependency><groupId>org.springframework.cloud</groupId><artifactId>spring-cloud-starter-stream-rabbit</artifactId></dependency>

刷新依赖

配置application.yml

配置Spring Cloud Bus的RabbitMQ连接信息,启用Spring Cloud Bus(spring.cloud.bus.enabled=true默认已启动),同时暴露动态刷新的端点。

server:port: 11112
spring:application:name: config-servercloud:config:server:git:uri: https://gitee.com/liang_123456/config-repo.gitdefault-label: master
#    bus:
#      enabled: truerabbitmq:host: 127.0.0.1port: 5672username: guestpassword: guest#开启动态刷新的端点
management:endpoints:bus-refresh:enabled: trueweb:exposure:include: bus-refresheureka:client:service-url:defaultZone: http://localhost:9000/eurekainstance:prefer-ip-address: trueinstance-id: ${spring.cloud.client.ip-address}:${server.port}

注意:开启动态刷新端点的management要顶格写

配置中心--客户端

spring-client_1服务

和config_server一样,添加依赖,如果已经存在就不用再添加

		<!--消息总线依赖--><dependency><groupId>org.springframework.cloud</groupId><artifactId>spring-cloud-starter-bus-amqp</artifactId></dependency><dependency><groupId>org.springframework.cloud</groupId><artifactId>spring-cloud-starter-stream-rabbit</artifactId></dependency>

刷新依赖

配置rabbitmq信息,因为是配置中心,所以在git远端仓库的配置文件配置即可,查看远端git配置文件,已经配置,如下

重启eureka、config_server和spring-client_1服务

访问

http://localhost:9101/config-client/product/get
响应
{"id":null,"productName":"product-pro2","status":null,"price":null,"productDesc":null,"caption":null,"inventory":null}

修改git远端配置

访问

http://localhost:9101/config-client/product/get
响应
{"id":null,"productName":"product-pro2","status":null,"price":null,"productDesc":null,"caption":null,"inventory":null}

响应product-pro2,说明还不是最新配置

发起Post请求, 刷新服务端配置

curl -X POST "http://localhost:11112/actuator/busrefresh"

注意:新版本发起post请求路径要改为busrefresh,而不是bus-refresh

访问

http://localhost:9101/config-client/product/get

响应
{"id":null,"productName":"product-pro3","status":null,"price":null,"productDesc":null,"caption":null,"inventory":null}

响应的数据也是product-pro3,说明使用消息总线方式刷新配置成功。 


 

完成!enjoy it!

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

如若内容造成侵权/违法违规/事实不符,请联系多彩编程网进行投诉反馈email:809451989@qq.com,一经查实,立即删除!

相关文章

wireshark自定义协议插件开发

目录 脚本代码 报文显示 脚本代码 local NAME "test" test_proto Proto("test", "test Protocol") task_id ProtoField.uint16("test.task_id", "test id", base.DEC) cn ProtoField.uint8("test.cn", &qu…

【Java 基础】15 注解

文章目录 1.什么是注解2.元注解1&#xff09;定义2&#xff09;分类 3.内置注解4.自定义注解5.注解的基本语法6.验证注解是否生效7.注解的使用场景8.注解的注意事项结语 1.什么是注解 注解&#xff08;Annotation&#xff09;可以理解成一种特殊的 “注释” 注解定义时以 符号…

多线程06 单例模式,阻塞队列以及模拟实现

前言 上篇文章我们讲了wait和notify两个方法的使用.至此,多线程的一些基本操作就已经结束了,今天我们来谈谈多线程的一些简单应用场景. 单例模式 单例模式,顾名思义,只有一个实例的模式,我们有两种实现方式,分别是懒汉式和饿汉式,我们来分别给出代码. 饿汉式(此处的饿表示创建实…

详解Spring中的Aop编程原理JDK动态代理和CGLIB动态代理

&#x1f609;&#x1f609; 学习交流群&#xff1a; ✅✅1&#xff1a;这是孙哥suns给大家的福利&#xff01; ✨✨2&#xff1a;我们免费分享Netty、Dubbo、k8s、Mybatis、Spring...应用和源码级别的视频资料 &#x1f96d;&#x1f96d;3&#xff1a;QQ群&#xff1a;583783…

yolov8模型 onnxruntime推理及可视化

参考:https://github.com/ultralytics/ultralytics/blob/main/examples/YOLOv8-ONNXRuntime/main.py 1、yolov8 onnxruntime推理代码 1)导出参考:https://blog.csdn.net/weixin_42357472/article/details/131412851 2)查看保存的模型onnx的输入格式等信息 登录https://n…

使用PCReg.PyTorch项目训练自己的数据集进行点云配准

项目地址&#xff1a; https://github.com/zhulf0804/PCReg.PyTorch/tree/main 网络简介&#xff1a; 网络是基于PointNet Concat FC的&#xff0c;它没有其它复杂的结构&#xff0c;易于复现。因其简洁性&#xff0c;这里暂且把其称作点云配准的Benchmark。因作者源码中复杂…

剑指 Offer(第2版)面试题 14:剪绳子

剑指 Offer&#xff08;第2版&#xff09;面试题 14&#xff1a;剪绳子 剑指 Offer&#xff08;第2版&#xff09;面试题 14&#xff1a;剪绳子解法1&#xff1a;动态规划解法2&#xff1a;数学 剑指 Offer&#xff08;第2版&#xff09;面试题 14&#xff1a;剪绳子 题目来源…

DOM 事件的注册和移除

前端面试大全DOM 事件的注册和移除 &#x1f31f;经典真题 &#x1f31f;DOM 注册事件 HTML 元素中注册事件 DOM0 级方式注册事件 DOM2 级方式注册事件 &#x1f31f;DOM 移除事件 &#x1f31f;真题解答 &#x1f31f;总结 &#x1f31f;经典真题 总结一下 DOM 中如何…

TCP连接为什么是三次握手,而不是两次和四次

答案 阻止重复的历史连接同步初始序列号避免资源浪费 原因 阻止重复的历史连接&#xff08;首要原因&#xff09; 考虑这样一种情况&#xff1a; 客户端现在要给服务端建立连接&#xff0c;向服务端发送了一个SYN报文段&#xff08;第一次握手&#xff09;&#xff0c;以表示请…

固定Microsoft Edge浏览器的位置设置,避免自动回调至中国

问题描述 在使用Copilot等功能时&#xff0c;需要将Microsoft Edge浏览器的位置设置为国外。但每次重新打开浏览器后&#xff0c;位置设置又自动回调至中国&#xff0c;导致每次均需要手动调整。 原因分析 这个问题的出现是因为每次启动Microsoft Edge时&#xff0c;默认打开…

cmake和vscode 下的cmake的使用详解(三)

第七讲&#xff1a;【实战】使用 VSCode 进行完整项目开发 案例&#xff1a;士兵突击 需求&#xff1a; 1. 士兵 许三多 有一把 枪 &#xff0c;叫做 AK47 2. 士兵 可以 开火 3. 士兵 可以 给枪装填子弹 4. 枪 能够 发射 子弹 5. 枪 能够 装填子弹 ——…

2022年9月6日 Go生态洞察:Go的漏洞管理新支持

&#x1f337;&#x1f341; 博主猫头虎&#xff08;&#x1f405;&#x1f43e;&#xff09;带您 Go to New World✨&#x1f341; &#x1f984; 博客首页——&#x1f405;&#x1f43e;猫头虎的博客&#x1f390; &#x1f433; 《面试题大全专栏》 &#x1f995; 文章图文…

docker-速通

1.命令-镜像操作 docker pull nginx #下载最新版 docker pull nginx:1.20.1 #下载指定版本 镜像名:版本名&#xff08;标签&#xff09; docker images #查看所有镜像 # 如果只写镜像名实际就是redis redis:latest 记住这个不是命令 docker rmi 镜像名:版本号/镜像id…

利用段落检索和生成模型进行开放域问答12.2

利用段落检索和生成模型进行开放域问答 摘要引言2 相关工作3 方法 摘要 事实证明&#xff0c;开放域问答的生成模型具有竞争力&#xff0c;无需借助外部知识。虽然很有希望&#xff0c;但这种方法需要使用具有数十亿个参数的模型&#xff0c;而这些模型的训练和查询成本很高。…

在linux服上部署vue+springboot+nginx项目

一、环境准备 1、安装winscp便于可视化操作linux&#xff1a;winscp安装及关联putty使用_putty.exe没有找到_cherishSpring的博客-CSDN博客 2、安装jdk&#xff1a;linux系统安装jdk-CSDN博客 3、安装mysql&#xff1a;Linux7安装mysql数据库以及navicat远程连接mysql-CSDN博…

Fiddler抓包工具之fiddler设置断点和简单的并发测试

断点有两种方式&#xff1a; 1、全局断点 2、局部断点 全局断点 全局断点的特点是&#xff1a;不能针对一个请求&#xff0c;是给所有抓到的请求打断点 全局断点如何设置&#xff1a; 1、快速设置断点&#xff1a;直接点击底部状态栏断点处 &#xff1b;点击第一下是请求…

【算法专题】二分查找

二分查找 二分查找1. 二分查找2. 在排序数组中查找元素的第一和最后一个位置3. 搜索插入位置4. x 的平方根5. 山脉数组的峰顶索引6. 寻找峰值7. 寻找旋转排序数组中的最小值8. 点名 二分查找 1. 二分查找 题目链接 -> Leetcode -704.二分查找 Leetcode -704.二分查找 题…

【Geoserver】SLD点位样式(PointSymbolizer)设计全通

SLD文件可以控制geoserver的样式管理&#xff0c;这里专门针对点位进行设计&#xff0c;首先点位的设计需要用到这面这个大标签 之前的项目中已经用到了很多关于面的样式管理&#xff0c;这里新学习的是关于点的样式管理 PointSymbolizer 参考资料地址&#xff1a;https://doc…

LeetCode算法题解(动态规划)|LeetCode1143. 最长公共子序列、LeetCode1035. 不相交的线、LeetCode53. 最大子数组和

一、LeetCode1143. 最长公共子序列 题目链接&#xff1a;1143. 最长公共子序列 题目描述&#xff1a; 给定两个字符串 text1 和 text2&#xff0c;返回这两个字符串的最长 公共子序列 的长度。如果不存在 公共子序列 &#xff0c;返回 0 。 一个字符串的 子序列 是指这样一…

论文编写软件latex安装教程

目录 1.下载安装包2.安装texlive 本人系统为windows&#xff0c;本教程基于windows系统&#xff0c;如果是其它系统请参考对应教程&#xff0c;注意选择对应系统的安装包&#xff01; 1.下载安装包 有三种集成环境安装包 texlive 是主流的环境&#xff0c;集成了较多的包&…