SpringCloud Config统一配置中心问题分析解决与客户端动态刷新实现

 更新时间:2022年10月24日 15:34:07   作者:爱吃面的猫  
springcloud config是一个解决分布式系统的配置管理方案。它包含了 client和server两个部分,server端提供配置文件的存储、以接口的形式将配置文件的内容提供出去,client端通过接口获取数据、并依据此数据初始化自己的应用

一、问题分析及解决方案

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的服务就能得到通知,然后去更新自身的配置。

到此这篇关于SpringCloud Config统一配置中心问题分析解决与客户端动态刷新实现的文章就介绍到这了,更多相关SpringCloud Config配置中心内容请搜索脚本之家以前的文章或继续浏览下面的相关文章希望大家以后多多支持脚本之家!

相关文章

  • java实现开根号的运算方式

    java实现开根号的运算方式

    这篇文章主要介绍了java实现开根号的运算方式,具有很好的参考价值,希望对大家有所帮助。如有错误或未考虑完全的地方,望不吝赐教
    2023-07-07
  • Druid连接池未关闭导致内存泄漏问题

    Druid连接池未关闭导致内存泄漏问题

    这篇文章主要介绍了Druid连接池未关闭导致内存泄漏问题,具有很好的参考价值,希望对大家有所帮助,如有错误或未考虑完全的地方,望不吝赐教
    2023-12-12
  • Java中JFinal框架动态切换数据库的方法

    Java中JFinal框架动态切换数据库的方法

    这篇文章主要介绍了Java中JFinal框架动态切换数据库的方法,本文通过两种方法结合示例代码给大家介绍的非常详细,对大家的学习或工作具有一定的参考借鉴价值,需要的朋友可以参考下
    2021-03-03
  • SpringBoot中使用 RabbitMQ的教程详解

    SpringBoot中使用 RabbitMQ的教程详解

    这篇文章主要介绍了SpringBoot中使用 RabbitMQ的教程详解,本文通过图文并茂的形式给大家介绍的非常详细,对大家的学习或工作具有一定的参考借鉴价值,需要的朋友可以参考下
    2020-11-11
  • Java如何实现内存缓存

    Java如何实现内存缓存

    内存缓存(Memory caching)是一种常见的缓存技术,它利用计算机的内存存储临时数据,以提高数据的读取和访问速度,本文就来和大家聊聊Java如何实现内存缓存吧
    2023-08-08
  • 浅谈Spring 中 @EnableXXX 注解的套路

    浅谈Spring 中 @EnableXXX 注解的套路

    本文主要介绍了浅谈Spring 中 @EnableXXX 注解的套路,文中通过示例代码介绍的非常详细,对大家的学习或者工作具有一定的参考学习价值,需要的朋友们下面随着小编来一起学习学习吧
    2022-05-05
  • 详解使用Spring Cloud Consul实现服务的注册和发现

    详解使用Spring Cloud Consul实现服务的注册和发现

    这篇文章主要介绍了详解使用Spring Cloud Consul实现服务的注册和发现,小编觉得挺不错的,现在分享给大家,也给大家做个参考。一起跟随小编过来看看吧
    2018-06-06
  • Java中HashMap和Hashtable的区别浅析

    Java中HashMap和Hashtable的区别浅析

    这篇文章主要介绍了Java中HashMap和Hashtable的区别浅析,本文总结了6条它们之间的不同之处,需要的朋友可以参考下
    2015-03-03
  • Java如何获取属性的注释信息详解

    Java如何获取属性的注释信息详解

    Java注解是从Java5开始添加到Java的,这篇文章主要给大家介绍了关于Java如何获取属性的注释信息的相关资料,文中介绍的非常详细,需要的朋友可以参考下
    2021-07-07
  • javaweb servlet中使用请求转发乱码的实现

    javaweb servlet中使用请求转发乱码的实现

    下面小编就为大家带来一篇javaweb servlet中使用请求转发乱码的实现。小编觉得挺不错的,现在就分享给大家,也给大家做个参考。一起跟随小编过来看看吧
    2016-08-08

最新评论