SpringCloud Config统一配置中心问题分析解决与客户端动态刷新实现
作者:爱吃面的猫 发布时间:2023-08-17 17:19:48
一、问题分析及解决方案
1、问题分析
上一章我们讲过远程仓储统一管理配置信息,客户端可以通过统一配置服务中心 config server 服务端获取配置信息。现在我们来做一个改变,并进行分析。
首先启动注册中心、统一配置中心configserver服务端、订单服务。浏览器访问地址:http://localhost:9000/order/getConfig 查看效果。
然后将远程仓储的订单服务dev环境的信息进行改变,在info上增加版本 version=01。
浏览器访问地址:http://localhost:9000/order/getConfig 查看效果
重新启动订单服务,浏览器访问地址http://localhost:9000/order/getConfig 查看效果
我们看到,远端仓储的配置信息改变,如果不重新启动订单服务,则无法刷新远端仓储的配置信息。
2、解决方案
使用动态刷新,动态刷新分为两种形式,一种是手动刷新,一种是自动刷新。
二、手动刷新
1、添加服务监控
在pom文件中添加服务监控依赖spring-boot-starter-actuator ,修改pom如下:
<?xml version="1.0" encoding="UTF-8"?>
<project xmlns="http://maven.apache.org/POM/4.0.0" xmlns:xsi="http://www.w3.org/2001/XMLSchema-instance"
xsi:schemaLocation="http://maven.apache.org/POM/4.0.0 http://maven.apache.org/xsd/maven-4.0.0.xsd">
<parent>
<artifactId>springcloudbase</artifactId>
<groupId>com.hwadee.springcloud2022</groupId>
<version>0.0.1-SNAPSHOT</version>
</parent>
<modelVersion>4.0.0</modelVersion>
<groupId>com.hwadee.springcloud</groupId>
<artifactId>orderServer9000</artifactId>
<dependencies>
<!-- 统一配置服务中心客户端依赖 -->
<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>
<!--web依赖-->
<dependency>
<groupId>org.springframework.boot</groupId>
<artifactId>spring-boot-starter-web</artifactId>
</dependency>
<!-- 管理公共api -->
<dependency>
<groupId>com.hwadee.springcloud</groupId>
<artifactId>springcloud-api</artifactId>
<version>0.0.1-SNAPSHOT</version>
</dependency>
<!--Eureka Client-->
<dependency>
<groupId>org.springframework.cloud</groupId>
<artifactId>spring-cloud-starter-netflix-eureka-client</artifactId>
</dependency>
<!-- 方便创建类的gettter setter -->
<dependency>
<groupId>org.projectlombok</groupId>
<artifactId>lombok</artifactId>
</dependency>
</dependencies>
</project>
2、暴露服务端点
让客户端能感受到配置的更新。
暴露服务端点,让客户端能感受到配置的更新,在bootstrap配置文件中修改如下:
spring:
cloud:
config:
label: master # 指定分支
name: order # 指定应用名称
profile: dev # 指定激活环境
uri: http://localhost:7009 #硬编码 指定访问 config server 远程仓储的地址的ip和端口
#暴露服务端点,让客户端能感受到配置的更新
management:
endpoints:
web:
exposure:
include: "*"
3、刷新业务类controller
刷新业务类controller,在订单服务的controller上使用注解 @RefreshScope ,使用后具备刷新能力,@Refreshscope用来在不需要重启徽服务情况下,将当前scope域中信息刷新为最新配置信息,订单服务的controller代码修改如下:
import com.hwadee.springcloud.entity.Product;
import org.springframework.beans.factory.annotation.Value;
import org.springframework.cloud.context.config.annotation.RefreshScope;
import org.springframework.web.bind.annotation.RequestMapping;
import org.springframework.web.bind.annotation.RestController;
@RestController
@RequestMapping("/order")
@RefreshScope
public class OrderController {
@Value("${env}")
private String env;
@Value("${port}")
private String port;
@Value("${info}")
private String info;
@RequestMapping(value = "/getConfig")
public Product getConfigInfo() {
Product product = new Product();
product.setName(env +"环境 端口:"+ port +" "+ info);
return product;
}
}
4、手动刷新
在cmd窗口进行手动刷新,必须是post请求,且地址固定:curl -X POST "http://localhost:9000/actuator/refresh"。
再次访问:http://localhost:9000/order/getConfig
三、自动刷新
问题:每个微服务如果需要加载最新配置信息,必须向每个微服务手动发送post请求,才能加载最新配置信息。因为微服务一般是集群方式,所以此种方式不方便,我们可以使用一个组件Bus总线,实现自动刷新。Bus总线支持RubbitMQ和kafak消息代理。
什么是总线
在微服务架构的系统中,通常会使用轻量级的消息代理来构建一个共用的消息主题,并让系统中所有微服务实例都连接上来。由于该主题中产生的消息会被所有实例监听和消费,所以称它为消息总线。在总线上的各个实例,都可以方便地广播一些需要让其他连接在该主题上的实例都知道的消息。
基本原理
ConfigClient实例都监听MQ中同一个topic(默认是springCloudBus)。当一个服务刷新数据的时候,它会把这个信息放入到Topic中,这样其它监听同一Topic的服务就能得到通知,然后去更新自身的配置。
来源:https://blog.csdn.net/qq_41946216/article/details/127461068


猜你喜欢
- 本文实例为大家分享了Android实现计步器功能的具体代码,供大家参考,具体内容如下计步器的原理是通过手机的前后摆动模拟步伐节奏检测。我们本
- 使用这个插件时要注意版本的问题,不同的版本可能 PageHelper 不会生效springboot 导入的 pagehelper 包<
- 我们在使用ListView的时候,一般都会为ListView添加一个响应事件android.widget.AdapterView.OnIte
- 大家好,我是梦辛工作室的灵,最近在帮客户修改安卓程序时,有要求到一个按钮要浮动在键盘的上方,下面大概讲一下实现方法:其实很简单,分三步走第一
- 递归三要素:1、明确递归终止条件;2、给出递归终止时的处理办法;3、提取重复的逻辑,缩小问题规模。1、1+2+3+…+nimport jav
- Android application捕获崩溃异常怎么办?通用 application1、收集所有 avtivity 用于彻底退出应用2、捕
- 错误Mybatis-Plus (简称MP) 是mybatis的一个增强工具,在mybatis的基础上只做增强不做改变,简化了开发效率。其实就
- 前言做APP应用开发的时候,用户头像肯定是必不可少的,但是90%以上的需求头像都是圆形的。那么,如何通过自定义View的方式实现圆形头像呢,
- 本文较为详细的描述了重载运算符的方法。一般来说,重载运算符在实际的项目开发中会经常的用到,但如果某些自定义类型通过简短几行代码重载一些常用的
- synchronized原理在java中,每一个对象有且仅有一个同步锁。这也意味着,同步锁是依赖于对象而存在。当我们调用某对象的synchr
- 动态SQL实现前端指定返回字段问题描述在使用ClickHouse时,遇到需要根据业务需求,动态返回指定字段,从而充分利用ClickHouse
- 具体代码如下所示:<?xml version="1.0"?><LinearLayout android
- 谨记:Url表只储存受保护的资源,不在表里的资源说明不受保护,任何人都可以访问1、MyFilterInvocationSecurityMet
- 概述Spring boot 中的 @Conditional 注解是一个不太常用到的注解,但确实非常的有用,我们知道 Spring Boot
- 1.创建项目时选择redis依赖2.修改配置文件,使用SpringBoot就避免了之前很多的xml文件2.1学过redis的同学都知道这个东
- 目录为什么要使用 TaskTask 和 Thread 区别Task 介绍Task 简单实现Task 执行状态1.等待(Wait)2. 返回值
- 本文实例为大家分享了Android来电拦截的方法,供大家参考,具体内容如下权限 <uses-permission andr
- 本文实例为大家分享了Unity实现10天签到系统的具体代码,供大家参考,具体内容如下实现功能:正常在游戏中签到,并把剩下的倒计时给显示出来。
- 本文实例讲述了Android获取手机屏幕大小的方法。分享给大家供大家参考,具体如下:这里主要用了三个对象TextView ,Button ,
- 本地jvm执行flink带web ui使用StreamExecutionEnvironment executionEnvironment =