配置中心--Spring Cloud Config

概述

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

配置中心是一种统一管理各种应用配置的基础服务组件。本文讲解的配置中心组件为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仓库

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

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

公共的配置，例如：数据库配置、Eureka配置等

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

准备配置文件

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

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

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

复制product-service的application.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.yml和application-dev.yml到git仓库

点击上传文件区域，选中需要上传的文件：application-pro.yml和application-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_1的bootstrap.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.hqwc.cn/news/239264.html

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

相关文章

从“芯”到云，看亚马逊云科技如何让未来“平等”发生

从“芯”到云，看亚马逊云科技如何让未来“平等”发生

文章目录 业界最全面算力选择&#xff0c;有效解决多样性需求多年自研芯片积累&#xff0c;带来性能与性价比双重优势全球基础设施与独特的业务模式&#xff0c;让创新不受限 “科幻作家威廉吉布森说‘未来已至&#xff0c;只是还没有均匀分布’。”2023年6月底&#xff0c;当亚…
阅读更多...
C语言实现猜数字游戏

C语言实现猜数字游戏

前面我们已经了解了分支循环、数据类型及变量的知识点&#xff0c;今天我将用之前学过的知识进行实操&#xff0c;将所学的知识进行巩固和提升。下面的讲解仅我个人认知水平&#xff0c;如有欠缺之处&#xff0c;欢迎大家指正&#xff0c;并且我希望初学者在看完讲解后可以独立…
阅读更多...
spring boot 3.2.0 idea从零开始

spring boot 3.2.0 idea从零开始

spring boot 3.2.0 idea从零开始 最新的spring initilizer 不再支持低版本java&#xff0c;只能选择17、21 。 我也被迫尝试下最新版本的java。 jdk下载地址 自定义好artifact和group之后点击下一步。 在这里选择需要的组件&#xff0c;我准备做web项目所以只选择spring web …
阅读更多...
智慧工地平台源码，支持多端展示：PC端、手机端、平板端，实现数据同步

智慧工地平台源码，支持多端展示：PC端、手机端、平板端，实现数据同步

智慧工地源码&#xff0c;微服务架构JavaSpring Cloud UniApp MySql&#xff1b; 依托组件化开发平台&#xff0c;支持多端展示&#xff1a;PC端、手机端、平板端&#xff0c;实现数据同步&#xff1b; 智慧工地平台主要利用智能终端、物联网、移动互联等技术&#xff0c;实时采…
阅读更多...
【LeetCode:1094. 拼车 | 差分数组】

【LeetCode:1094. 拼车 | 差分数组】

&#x1f680; 算法题 &#x1f680; &#x1f332; 算法刷题专栏 | 面试必备算法 | 面试高频算法 &#x1f340; &#x1f332; 越难的东西,越要努力坚持&#xff0c;因为它具有很高的价值&#xff0c;算法就是这样✨ &#x1f332; 作者简介&#xff1a;硕风和炜&#xff0c;…
阅读更多...
最长连续递增序列

最长连续递增序列

最长连续递增序列 描述 : 给定一个未经排序的整数数组&#xff0c;找到最长且 连续递增的子序列&#xff0c;并返回该序列的长度。 连续递增的子序列 可以由两个下标 l 和 r&#xff08;l < r&#xff09;确定&#xff0c;如果对于每个 l < i < r&#xff0c;都有 …
阅读更多...
C/C++，图算法——求强联通的Tarjan算法之源程序

C/C++，图算法——求强联通的Tarjan算法之源程序

1 文本格式 #include <bits/stdc.h> using namespace std; const int maxn 1e4 5; const int maxk 5005; int n, k; int id[maxn][5]; char s[maxn][5][5], ans[maxk]; bool vis[maxn]; struct Edge { int v, nxt; } e[maxn * 100]; int head[maxn], tot 1; vo…
阅读更多...
【学习记录】从0开始的Linux学习之旅——应用开发（helloworld）

【学习记录】从0开始的Linux学习之旅——应用开发（helloworld）

一、概述 Linux操作系统通常是基于Linux内核&#xff0c;并结合GNU项目中的工具和应用程序而成。Linux操作系统支持多用户、多任务和多线程&#xff0c;具有强大的网络功能和良好的兼容性。本文主要讲述如何在linux系统上进行应用开发。 二、概念及原理 应用程序通过系统调用与…
阅读更多...
JS 实现一键复制文本内容

JS 实现一键复制文本内容

1、演示&#xff1a; 2、代码 <!DOCTYPE html> <html lang"en"><head><meta charset"UTF-8"><meta name"viewport" content"widthdevice-width, initial-scale1.0"><title>一键复制</title&g…
阅读更多...
机器学习---EM算法

机器学习---EM算法

1. 极大似然估计与EM算法 极大似然估计是一种常用的参数估计方法&#xff0c;它是以观测值出现的概率最大作为准则。关于极 大似然估计&#xff0c;假设现在已经取到样本值了&#xff0c;这表明取到这一样本的概率L(θ) 比较 大。我们自然不会考虑那些不能使样本出现的θ作为…
阅读更多...
分治算法——912. 排序数组

分治算法——912. 排序数组

文章目录 &#x1f348;1. 题目&#x1f34c;2. 算法原理&#x1f34f;3. 代码实现 &#x1f348;1. 题目 题目链接&#xff1a;912. 排序数组 - 力扣&#xff08;LeetCode&#xff09; 给你一个整数数组 nums&#xff0c;请你将该数组升序排列。 示例 1&#xff1a; 输入&am…
阅读更多...
经典神经网络——VGGNet模型论文详解及代码复现

经典神经网络——VGGNet模型论文详解及代码复现

论文地址&#xff1a;1409.1556.pdf。 (arxiv.org)&#xff1b;1409.1556.pdf (arxiv.org) 项目地址&#xff1a;Kaggle Code 一、背景 ImageNet Large Scale Visual Recognition Challenge 是李飞飞等人于2010年创办的图像识别挑战赛&#xff0c;自2010起连续举办8年&#xf…
阅读更多...
推荐文章
最新文章

Copyright @ 2022~2023