【深入理解SpringCloud微服务】深入理解微服务配置中心原理，并手写一个微服务配置中心

2024-09-01 09:52
文章标签 java 配置 服务 spring 深入 理解 原理 springcloud 中心 手写

本文主要是介绍【深入理解SpringCloud微服务】深入理解微服务配置中心原理，并手写一个微服务配置中心，希望对大家解决编程问题提供一定的参考价值，需要的开发者们随着小编来一起学习吧！

【深入理解SpringCloud微服务】深入理解微服务配置中心原理，并手写一个微服务配置中心

  • 为什么要使用配置中心
  • 配置中心原理
  • 如何手写一个配置中心
    • 使用PropertySourceLocator
    • 监听配置变更，刷新配置
  • 实现一个微服务配置中心
    • 服务端
      • 库表
      • ConfigCenterController
      • ConfigCenterService
      • LongPollingService
      • ConfigCenterServerConfig
    • 客户端
      • ConfigService
      • SimpleMicroserviceConfigPropertySourceLocator
      • ConfigCenterClientConfig
      • LongPollingClient
      • RefreshListener
      • LongPollingClientConfig
    • 总结

为什么要使用配置中心

在没有配置中心以前，我们应用程序的配置都是保存在本地，如果是单体架构的话，这种方式是没有问题的，优点是非常的简单。

在这里插入图片描述

但是如果在微服务架构下，每个微服务自己管理自己的配置文件的话，这种方式就太混乱，不利于运维人员对配置文件的维护。

因此，在微服务架构下，通常会引入配置中心，所有微服务的配置都统一维护在配置中心，应用程序从配置中心读取配置并加载，这样对不同服务配置的维护就显得更方便。

在这里插入图片描述

配置中心原理

配置中心通常分为配置中心服务端和配置中心客户端。配置中心服务端通过某种存储方式存储配置信息，比如数据库、文件、github。而配置中心客户端请求配置中心服务端拉取配置信息，常见的是通过http请求拉取配置。

在这里插入图片描述

配置中心还会提供接口或者一个界面去进行配置添加和修改。

在这里插入图片描述
然后配置中心客户端从配置中心服务端拉取到配置信息后，会加载配置信息到本地环境中，这样我们的应用程序就能读取到从配置中心拉取回来的配置。

在这里插入图片描述

最后，配置中心通常还会有配置变更通知的功能。当配置中心发生配置变更时，需要通知客户端，可以使用与客户端维持的长连接进行推送，或者由客户端主动轮询。当客户端收到配置变更通知时，会刷新本地环境。

在这里插入图片描述

如何手写一个配置中心

以上的一整套操作，如果从零搞起，是非常麻烦的，如果我们基于Spring，使用SpringBoot开发的话，有一些接口是可以复用的，我们下面了解一下。

使用PropertySourceLocator

SpringBoot在启动的时候，会使用PropertySourceLocator#locate()方法查找配置信息，PropertySourceLocator#locate()方法返回PropertySource，里面包含了查找到的配置信息，然后SpringBoot会把PropertySource添加到Environment对象中。

在这里插入图片描述

于是，我们可以自己实现一个PropertySourceLocator重写locate()方法，locate()方法请求配置中心获取配置。我们把自己实现的PropertySourceLocator注册到Spring容器中，SpringBoot启动时就会调用我们的PropertySourceLocator去配置中心拉取配置，加载到Environment中，这样就省掉了很多代码。

在这里插入图片描述

监听配置变更，刷新配置

当配置中心发生配置变更时，要通知客户端。配置中心可以利用长连接进行推送，也可以客户端自己进行长轮询。

当客户端接收到配置变更时的环境刷新操作。客户端需要重新请求配置中心拉取配置，刷新本地环境Environment，然后还要把变更的配置重新赋值到引用该配置的对象当中。

在SpringBoot中，有一个RefreshEventListener监听器，会监听RefreshEvent事件，当RefreshEventListener监听到RefreshEvent事件时，会创建一个新SpringContext去加载配置信息，并且销毁被@RefreshScope注解修饰的bean。在下一次请求使用到被销毁的bean时，Spring会重新实例化，那么这个bean就会读取到最新的配置。

在这里插入图片描述

这样，当客户端接收到配置中心的配置变更通知时，只要通过通过Spring的事件监听机制发布一个RefreshEvent事件即可，这样又能省掉很多代码。

在这里插入图片描述

实现一个微服务配置中心

下面是我手写实现的一个配置中心，由于篇幅关系，只会展示核心代码。如果要看详细代码的话，文末会附上git仓库的地址，从上面下载即可。

服务端

配置中心服务端是基于SpringBoot开发的，采用传统的MVC架构。

库表

我们的配置中心是基于数据库存储配置信息的。

CREATE TABLE `t_config_file` (`f_id` bigint(20) NOT NULL,`f_environment` varchar(1024) DEFAULT NULL COMMENT '环境（自定义，如：dev、test）',`f_service_name` varchar(1024) DEFAULT NULL COMMENT '配置所属服务名',`f_name` varchar(1024) DEFAULT NULL COMMENT '配置文件名',`f_priority` int(11) DEFAULT 0 COMMENT '优先级，值越大越优先',`f_create_time` bigint(20) DEFAULT NULL COMMENT '创建时间',`f_modify_date` timestamp NOT NULL DEFAULT current_timestamp() ON UPDATE current_timestamp() COMMENT '修改时间',PRIMARY KEY (`f_id`),KEY `idx_config_file_modify_date` (`f_modify_date`)
) ENGINE=InnoDB DEFAULT CHARSET=utf8 ROW_FORMAT=COMPACT COMMENT='配置文件表';CREATE TABLE `t_config_file_item` (`f_id` bigint(20) NOT NULL,`f_config_file_id` bigint(20) NOT NULL COMMENT '配置文件id',`f_name` varchar(1024) NOT NULL COMMENT '配置项名称',`f_value` varchar(1024) NOT NULL COMMENT '配置项内容',`f_create_time` bigint(20) DEFAULT NULL COMMENT '创建时间',`f_modify_date` timestamp NOT NULL DEFAULT current_timestamp() ON UPDATE current_timestamp() COMMENT '修改时间',PRIMARY KEY (`f_id`),KEY `idx_config_file_item_modify_date` (`f_modify_date`)
) ENGINE=InnoDB DEFAULT CHARSET=utf8 ROW_FORMAT=COMPACT COMMENT='配置文件配置项表';
  • t_config_file是配置文件表
  • t_config_file_item是配置文件配置项表
  • t_config_file_item通过f_config_file_id关联t_config_file表，t_config_file与t_config_file_item是一对多关系。

t_config_file里的一条记录表示一个配置文件，t_config_file_item里的一条记录表示配置文件里的一个配置项。

在这里插入图片描述

ConfigCenterController

@RestController
@RequestMapping("/config/center")
public class ConfigCenterController {@Autowiredprivate ConfigCenterService configCenterService;...}

ConfigCenterController暴露了配置文件的增删改查接口，调用ConfigCenterService进行处理。

在这里插入图片描述

ConfigCenterService

@Service
public class ConfigCenterService {...@Autowiredprivate ConfigFileDao configFileDao;...// modify()修改配置的方法，// 修改完后，会调用LongPollingService通知客户端发生配置变更...}

上面只展示了ConfigCenterService的修改配置文件和根据服务名查询所有配置文件的这两个方法。

ConfigCenterService调用ConfigFileDao操作数据库，对t_config_file表和t_config_file_item表进行增删改查操作。

其中modify方法做完修改操作后，判断如果修改操作执行成功，还会调用LongPollingService通过长连接通知客户端。

在这里插入图片描述

LongPollingService

我们采用了websocket保持客户端与服务端的长连接，当有配置变更时，通过websocket通知客户端刷新配置信息。

在这里插入图片描述

LongPollingService正是服务端暴露的websocket端点，被@ServerEndpoint注解修饰。LongPollingService里面封装了websocket连接建立和关闭时进行的操作，以及推送配置变更通知的操作。

// 对外暴露websocket端点
@ServerEndpoint("/ws/config/center")
@Component
public class LongPollingService {// 当建立websocket连接后，会保存websocket连接对应的Session到Map中// 格式为 [environmen: [serviceName: session]] 双层Map...// 通知客户端发生配置变更public static void notify(String environmen, String serviceName) throws IOException {// 根据指定环境environmen指定服务名environmen，取得对应的Session// 该Session代表与对应客户端建立的长连接Map<String, Session> serviceNameSessionMap = envServiceNameSessionMapping.get(environmen);if (serviceNameSessionMap != null) {Session session = serviceNameSessionMap.get(serviceName);if (session != null) {// 通过session向客户端推送配置变更通知session.getBasicRemote().sendText(Constant.CONFIG_CHANGE_MARK);}}}}

当建立websocket连接后，会保存websocket连接对应的Session到LongPollingService的Map中，格式为“[environmen: [serviceName: session]]”这样的双层Map。

LongPollingService.notify(environmen, serviceName)会通过environmen环境名（比如dev、uat）和serviceName服务名从Map中获取到对应的session，这个session表示与指定环境指定服务名的客户端建立的websocket长连接。然后通过这个session向对应客户端推送配置变更通知。

在这里插入图片描述

ConfigCenterServerConfig

ConfigCenterServerConfig是一个被@Configuration注解修饰的配置类，通过在spring.factories指定该配置类进行自动装配。

ConfigCenterServerConfig会通过@ComponentScan、@Bean等注解配置我们上面说到的类。

在这里插入图片描述

客户端

客户端也是使用SpringBoot进行开发的，以jar包的形式被其他微服务引用。

ConfigService

ConfigService是一个接口，定义了获取配置信息的方法。

public interface ConfigService {List<ConfigFileDto> getAll(String environment, String serviceName, String name);ConfigFileDto get(String fileId);}

ConfigService的实现类内部通过OkHttp请求配置中心服务端拉取配置信息。

在这里插入图片描述

SimpleMicroserviceConfigPropertySourceLocator

SimpleMicroserviceConfigPropertySourceLocator就是我们上面说的实现了Spring的PropertySourceLocator接口的实现类，重写了locate方法，在locate方法中调用ConfigService通过http请求配置中心拉取配置信息，再把配置中心返回的配置信息转换成CompositePropertySource返回。

SimpleMicroserviceConfigPropertySourceLocator.locate(Environment)

    @Overridepublic PropertySource<?> locate(Environment environment) {// 创建一个CompositePropertySource，用于保存请配置中心拉取回来的配置信息CompositePropertySource compositePropertySource = new CompositePropertySource(PROPERTY_SOURCE_NAME);// 调用configService从配置中心拉取配置信息List<ConfigFileDto> configFileDtos = configService.getAll(simpleMicroserviceConfigProperties.getEnvironment(), simpleMicroserviceConfigProperties.getServiceName(), null);// 拉取回来的配置信息，保存到CompositePropertySourceconfigFileDtos.stream().map(configFileDto -> new MapPropertySource(configFileDto.getName(), configFileDto.getConfigMap())).forEach(compositePropertySource::addFirstPropertySource);return compositePropertySource;}

SpringBoot在启动之后，会调用PropertySourceLocator的locate方法，然后把locate方法方法返回的PropertySource添加到Environment中。SpringBoot会调用这里的SimpleMicroserviceConfigPropertySourceLocator的locate方法，然后把返回的CompositePropertySource添加到Environment中。

在这里插入图片描述

ConfigCenterClientConfig

ConfigCenterClientConfig就是一个配置类，被spring.factories指定自动装配，通过@Bean注解往Springboot注册ConfigService和SimpleMicroserviceConfigPropertySourceLocator。

在这里插入图片描述

LongPollingClient

@Component
public class LongPollingClient implements ApplicationListener<ApplicationReadyEvent>, ApplicationContextAware {...public void connect() {...// 通过okhttp与配置中心服务端建立websocket连接// RefreshListener是一个监听器，收到配置中心的通知会回调mOkHttpClient.newWebSocket(request, new RefreshListener(...));...}// 监听ApplicationReadyEvent事件，触发websocket连接建立@Overridepublic void onApplicationEvent(ApplicationReadyEvent event) {...this.connect();}...
}

LongPollingClient实现了Spring的ApplicationListener接口，监听ApplicationReadyEvent事件，触发与配置中心服务端的websocket连接建立，建立websocket连接依然是使用okhttp。

然后在创建websocket连接，设置了一个监听器RefreshListener，在收到配置中心的通知时会回调该监听器。

在这里插入图片描述

RefreshListener

RefreshListener继承了WebSocketListener，WebSocketListener是OKHttp提供的抽象类，代表一个websocket监听器。

public class RefreshListener extends WebSocketListener {...// websocket连接建立后的回调，向配置中心服务端注册// 发送environmen（环境）和serviceName（服务名）到注册中心@Overridepublic void onOpen(WebSocket webSocket, Response response) {JSONObject message = new JSONObject();message.put("environmen", environmen);message.put("serviceName", serviceName);webSocket.send(message.toJSONString());}// 收到配置中心服务端通知时回调，通过Spring事件监听机制，发一个RefreshEvent事件@Overridepublic void onMessage(WebSocket webSocket, String text) {applicationContext.publishEvent(new RefreshEvent(this, null, "refresh config"));}...}

当websocket连接建立后，会回调RefreshListener的onOpen方法，会向配置中心服务端注册自己对应的environmen和serviceName，配置中心服务端会以environmen和serviceName为key，记录与该websocket连接对应的Session的映射关系，方便配置变更时通知客户端。

当客户端收到配置中心服务端的配置变更通知时，会回调RefreshListener的onMessage方法，会通过Spring事件监听机制，发一个RefreshEvent事件。发送的RefreshEvent事件会被RefreshEventListener接收，触发配置的重新加载和销毁旧的bean，上面已经说过。

在这里插入图片描述

LongPollingClientConfig

LongPollingClientConfig也是一个配置了，被spring.factories指定自动装配，通过@Bean往Spring注册一个LongPollingClient。

在这里插入图片描述

总结

这里我们可以再回顾一下服务端的LongPollingService和客户端的LongPollingClient的关系。

在这里插入图片描述

  1. 通过websocket建立了长连接
  2. 建立连接后，会回调监听器RefreshListener发送对应的environment和serviceName，LongPollingService接收到后会保存其与Session的对应关系
  3. 当服务端发生配置变更，会调用LongPollingService发送配置变更通知，LongPollingService会通过environment和serviceName取得对应的Session，通过Session推送配置变更通知
  4. 当客户端接收到配置变更通知后，会回调RefreshListener发送一个RefreshEvent事件
  5. 通过Spring的事件监听机制，RefreshEventListener接收到RefreshEvent事件，触发配置的重新加载和销毁旧的bean

由于篇幅关系，上面并没有展示详细的代码，如果想详细阅读代码的，可以git仓库下载：
https://gitee.com/huang_junyi/simple-microservice
在这里插入图片描述

这篇关于【深入理解SpringCloud微服务】深入理解微服务配置中心原理，并手写一个微服务配置中心的文章就介绍到这儿，希望我们推荐的文章对编程师们有所帮助！


http://www.chinasem.cn/article/1126611。

相关文章

Java中流式并行操作parallelStream的原理和使用方法

Java中流式并行操作parallelStream的原理和使用方法

《Java中流式并行操作parallelStream的原理和使用方法》本文详细介绍了Java中的并行流（parallelStream）的原理、正确使用方法以及在实际业务中的应用案例,并指出在使用并行流... 目录Java中流式并行操作parallelStream0. 问题的产生1. 什么是parallelS
阅读更多...
MySQL数据库双机热备的配置方法详解

MySQL数据库双机热备的配置方法详解

《MySQL数据库双机热备的配置方法详解》在企业级应用中,数据库的高可用性和数据的安全性是至关重要的,MySQL作为最流行的开源关系型数据库管理系统之一,提供了多种方式来实现高可用性,其中双机热备（M... 目录1. 环境准备1.1 安装mysql1.2 配置MySQL1.2.1 主服务器配置1.2.2 从
阅读更多...
Java中Redisson 的原理深度解析

Java中Redisson 的原理深度解析

《Java中Redisson的原理深度解析》Redisson是一个高性能的Redis客户端,它通过将Redis数据结构映射为Java对象和分布式对象,实现了在Java应用中方便地使用Redis,本文... 目录前言一、核心设计理念二、核心架构与通信层1. 基于 Netty 的异步非阻塞通信2. 编解码器三、
阅读更多...
SpringBoot基于注解实现数据库字段回填的完整方案

SpringBoot基于注解实现数据库字段回填的完整方案

《SpringBoot基于注解实现数据库字段回填的完整方案》这篇文章主要为大家详细介绍了SpringBoot如何基于注解实现数据库字段回填的相关方法,文中的示例代码讲解详细,感兴趣的小伙伴可以了解... 目录数据库表pom.XMLRelationFieldRelationFieldMapping基础的一些代
阅读更多...
一篇文章彻底搞懂macOS如何决定java环境

一篇文章彻底搞懂macOS如何决定java环境

《一篇文章彻底搞懂macOS如何决定java环境》MacOS作为一个功能强大的操作系统,为开发者提供了丰富的开发工具和框架,下面：本文主要介绍macOS如何决定java环境的相关资料,文中通过代码... 目录方法一：使用 which命令方法二：使用 Java_home工具（Apple 官方推荐）那问题来了，
阅读更多...
Java HashMap的底层实现原理深度解析

Java HashMap的底层实现原理深度解析

《JavaHashMap的底层实现原理深度解析》HashMap基于数组+链表+红黑树结构,通过哈希算法和扩容机制优化性能,负载因子与树化阈值平衡效率,是Java开发必备的高效数据结构,本文给大家介绍... 目录一、概述：HashMap的宏观结构二、核心数据结构解析1. 数组（桶数组）2. 链表节点（Node
阅读更多...
Java AOP面向切面编程的概念和实现方式

Java AOP面向切面编程的概念和实现方式

《JavaAOP面向切面编程的概念和实现方式》AOP是面向切面编程,通过动态代理将横切关注点（如日志、事务）与核心业务逻辑分离,提升代码复用性和可维护性,本文给大家介绍JavaAOP面向切面编程的概... 目录一、AOP 是什么？二、AOP 的核心概念与实现方式核心概念实现方式三、Spring AOP 的关
阅读更多...
详解SpringBoot+Ehcache使用示例

详解SpringBoot+Ehcache使用示例

《详解SpringBoot+Ehcache使用示例》本文介绍了SpringBoot中配置Ehcache、自定义get/set方式,并实际使用缓存的过程,文中通过示例代码介绍的非常详细,对大家的学习或者... 目录摘要概念内存与磁盘持久化存储：配置灵活性：编码示例引入依赖：配置ehcache.XML文件：配置
阅读更多...
Java 虚拟线程的创建与使用深度解析

Java 虚拟线程的创建与使用深度解析

《Java虚拟线程的创建与使用深度解析》虚拟线程是Java19中以预览特性形式引入,Java21起正式发布的轻量级线程,本文给大家介绍Java虚拟线程的创建与使用,感兴趣的朋友一起看看吧... 目录一、虚拟线程简介1.1 什么是虚拟线程？1.2 为什么需要虚拟线程？二、虚拟线程与平台线程对比代码对比示例：三
阅读更多...
Linux云服务器手动配置DNS的方法步骤

Linux云服务器手动配置DNS的方法步骤

《Linux云服务器手动配置DNS的方法步骤》在Linux云服务器上手动配置DNS（域名系统）是确保服务器能够正常解析域名的重要步骤,以下是详细的配置方法,包括系统文件的修改和常见问题的解决方案,需要... 目录1. 为什么需要手动配置 DNS？2. 手动配置 DNS 的方法方法 1：修改 /etc/res
阅读更多...

Copyright China编程 23002807@qq.com

沪ICP备2023033072号-2