手写分布式配置中心（二）实现分布式配置中心的简单版本

这一篇文章比较简单，就是一个增删改查的服务端和一个获取配置的客户端，旨在搭建一个简单的配置中心架构，代码在 https://gitee.com/summer-cat001/config-center

服务端

服务端选择用springboot 2.7.14搭建，设计了4个接口/config/insert、/config/update、/config/delete、/config/get。

Controller层

Controller层做了请求参数的校验，和对服务层的转发

@RestController
@RequestMapping("/config")
public class ConfigController {@Autowiredprivate ConfigService configService;@PostMapping("/insert")public Result<Void> insertConfig(@RequestBody ConfigVO configVO) {Result<ConfigBO> result = checkOpConfig(configVO);if (result.failed()) {return Result.resultToFail(result);}return configService.insertConfig(result.getData());}@PostMapping("/update")public Result<Void> updateConfig(@RequestBody ConfigVO configVO) {Result<ConfigBO> result = checkOpConfig(configVO);if (result.failed()) {return Result.resultToFail(result);}ConfigBO configBO = result.getData();long id = configVO.getId();if (id <= 0) {return Result.fail("配置id错误");}configBO.setId(id);return configService.updateConfig(configBO);}@PostMapping("/delete")public Result<Void> delConfig(@RequestBody ConfigVO configVO) {long id = configVO.getId();if (id <= 0) {return Result.fail("配置id错误");}return configService.delConfig(id, 0L);}@GetMapping("/get")public Result<List<ConfigVO>> getAllValidConfig() {Result<List<ConfigBO>> result = configService.getAllValidConfig();if (result.failed()) {return Result.resultToFail(result);}return Result.success(result.getData().stream().map(configBO -> {ConfigVO configVO = new ConfigVO();configVO.setId(configBO.getId());configVO.setName(configBO.getName());configVO.setConfigData(configBO.getConfigData());configVO.setCreateTime(DateUtil.date2str1(configBO.getCreateTime()));return configVO;}).collect(Collectors.toList()));}private Result<ConfigBO> checkOpConfig(ConfigVO configVO) {String name = configVO.getName();if (name == null || (name = name.trim()).length() == 0) {return Result.fail("配置名不能为空");}JSONObject configData = configVO.getConfigData();if (configData == null) {return Result.fail("配置内容不能为空");}ConfigBO configBO = new ConfigBO();configBO.setName(name);configBO.setConfigData(configData);return Result.success(configBO);}
}

Service层

Service层做了数据的转换和对dao层的调用，对于这个配置中心数据的存储，我做了两个模式，1是单机模式，2是集群模式。简单的来说就是一个存在数据库中，一个存在本地。根据配置文件中的config.center.mode来指定使用哪种模式

@Service
public class ConfigServiceImpl implements ConfigService {private ConfigDAO configDAO;@Autowiredprivate LocalConfigDAO localConfigDAO;@Value("${config.center.mode:0}")private int configCenterMode;@PostConstructpublic void init() {ConfigCenterModeEnum configCenterModeEnum = ConfigCenterModeEnum.getEnum(configCenterMode);if (configCenterModeEnum == null) {throw new IllegalArgumentException("配置config.center.mode错误");}if (configCenterModeEnum == ConfigCenterModeEnum.STANDALONE) {this.configDAO = localConfigDAO;}}@Overridepublic Result<Void> insertConfig(ConfigBO configBO) {List<ConfigDO> configList = configDAO.getAllValidConfig();if (configList.stream().anyMatch(c -> c.getName().equals(configBO.getName()))) {return Result.fail("配置名重复");}ConfigDO configDO = new ConfigDO();configDO.setName(configBO.getName());configDO.setConfigData(configBO.getConfigData().toJSONString());configDAO.insertConfigDO(configDO);return Result.success(null);}@Overridepublic Result<Void> updateConfig(ConfigBO configBO) {ConfigDO configDO = new ConfigDO();configDO.setId(configBO.getId());configDO.setName(configBO.getName());configDO.setConfigData(configBO.getConfigData().toJSONString());configDAO.updateConfig(configDO);return Result.success(null);}@Overridepublic Result<Void> delConfig(long id, long updateUid) {configDAO.delConfig(id, updateUid);return Result.success(null);}@Overridepublic Result<List<ConfigBO>> getAllValidConfig() {List<ConfigDO> configList = configDAO.getAllValidConfig();return Result.success(configList.stream().map(configDO -> {ConfigBO configBO = new ConfigBO();configBO.setId(configDO.getId());configBO.setName(configDO.getName());configBO.setCreateTime(configDO.getCreateTime());configBO.setConfigData(JSON.parseObject(configDO.getConfigData()));return configBO;}).collect(Collectors.toList()));}
}

DAO层

DAO层提供了一个接口com.config.center.dao.ConfigDAO。单机和集群模式分别实现这个接口，例如单机模式是com.config.center.dao.impl.LocalConfigDAO实现类（集群模式就是访问数据库，大家估计都用吐了，这个就不多介绍了）。
单机模式就是将配置文件存储到本地的一个路径中，这个路径根据配置文件的config.center.standalone.path配置来指定，保存的是以配置id为文件名.conf为后缀的文件。其中id是从1开始自增，增加配置接口用了锁，所以id不会重复

@Slf4j
@Repository
public class LocalConfigDAO implements ConfigDAO {private final Lock insertLock = new ReentrantLock();@Value("${config.center.standalone.path}")private String standalonePath;@Overridepublic long insertConfigDO(ConfigDO configDO) {insertLock.lock();try {long id = 1;List<ConfigDO> configList = getAllConfig();if (!configList.isEmpty()) {id = configList.get(configList.size() - 1).getId() + 1;}configDO.setId(id);Optional.of(configDO).filter(c -> c.getCreateTime() == null).ifPresent(c -> c.setCreateTime(LocalDateTime.now()));String configPathStr = standalonePath + "/config";Files.createDirectories(Paths.get(configPathStr));Path path = Paths.get(configPathStr + "/" + id + ".conf");Files.write(path, JSON.toJSONString(configDO).getBytes(StandardCharsets.UTF_8), StandardOpenOption.CREATE_NEW);return id;} catch (Exception e) {throw new RuntimeException(e);} finally {insertLock.unlock();}}@Overridepublic void updateConfig(ConfigDO configDO) {ConfigDO dbConfigDO = getConfig(configDO.getId());Optional.ofNullable(dbConfigDO).map(c -> {c.setName(configDO.getName());c.setUpdateTime(LocalDateTime.now());c.setUpdateUid(configDO.getUpdateUid());c.setConfigData(configDO.getConfigData());return c;}).ifPresent(this::updateConfigDO);}@Overridepublic void delConfig(long id, long updateUid) {ConfigDO dbConfigDO = getConfig(id);Optional.ofNullable(dbConfigDO).map(c -> {c.setDeleted(true);c.setUpdateTime(LocalDateTime.now());c.setUpdateUid(updateUid);return c;}).ifPresent(this::updateConfigDO);}@Overridepublic ConfigDO getConfig(long id) {List<ConfigDO> configList = getAllConfig();return configList.stream().filter(c -> c.getId() == id).findFirst().orElse(null);}@Overridepublic List<ConfigDO> getAllValidConfig() {return getAllConfig().stream().filter(c -> !c.isDeleted()).collect(Collectors.toList());}@Overridepublic List<ConfigDO> getAllConfig() {File[] files;File folder = new File(standalonePath + "/config");if (!folder.exists() || (files = folder.listFiles()) == null) {return new ArrayList<>();}return Arrays.stream(files).map(File::getAbsolutePath).filter(p -> p.endsWith(".conf")).map(this::buildConfigDO).filter(Objects::nonNull).sorted(Comparator.comparing(ConfigDO::getId)).collect(Collectors.toList());}private synchronized ConfigDO buildConfigDO(String path) {try {byte[] bytes = Files.readAllBytes(Paths.get(path));String json = new String(bytes, StandardCharsets.UTF_8);return JSON.parseObject(json, ConfigDO.class);} catch (Exception e) {log.error("buildConfigDO error,path:{}", path, e);return null;}}private synchronized void updateConfigDO(ConfigDO configDO) {Path path = Paths.get(standalonePath + "/config/" + configDO.getId() + ".conf");if (Files.exists(path)) {try {Files.write(path, JSON.toJSONString(configDO).getBytes(StandardCharsets.UTF_8), StandardOpenOption.WRITE);} catch (IOException e) {log.error("updateConfigDO error configDO:{}", configDO, e);}}}
}

效果

到这里就已经完成了服务端的构建了，简单吧，下面看看效果

新增配置

获取所有有效配置

修改配置

删除配置

客户端

客户端就更简单了，就是在启动时通过http调用上面的/config/get接口获取配置，并且赋值给对象的成员变量，之后直接使用这个成员变量即可

public class ConfigCenterClient {/*** 服务端地址*/private String url;public List<ConfigVO> getAllValidConfig() {HttpRespBO httpRespBO = HttpUtil.httpGet(url + "/config/get");if (!httpRespBO.success()) {throw new IllegalArgumentException("获取配置失败：code:" + httpRespBO.getCode() + ",msg:" + httpRespBO.getMessage());}if (httpRespBO.getBody() == null) {throw new IllegalArgumentException("获取配置失败 body is null：code:" + httpRespBO.getCode() + ",msg:" + httpRespBO.getMessage());}Result<?> result = JSON.parseObject(new String(httpRespBO.getBody(), StandardCharsets.UTF_8), Result.class);if (result.failed()) {throw new IllegalArgumentException("获取配置失败 result:" + result);}return JSON.parseArray(JSON.toJSONString(result.getData()), ConfigVO.class);}public void setUrl(String url) {this.url = url;}}
public class ClientTest {private String userName;private String userAge;private List<Object> education;public ClientTest() {ConfigCenterClient configCenterClient = new ConfigCenterClient();configCenterClient.setUrl("http://localhost:8088");List<ConfigVO> configList = configCenterClient.getAllValidConfig();configList.stream().map(ConfigVO::getConfigData).map(c -> c.getJSONObject("user")).findFirst().ifPresent(user -> {this.userName = user.getString("name");this.userAge = user.getString("age");this.education = user.getJSONArray("education");});}public String toString() {return "姓名:" + userName + ",年龄:" + userAge + ",教育经历:" + education;}public static void main(String[] args) {ClientTest clientTest = new ClientTest();System.out.println(clientTest);}
}

这样整个配置中心的简单版本就完成了，不过这样只是在new对象的时候设置了配置的值，但是如果配置中心的配置发生变化后，客户端是无法感知的，为了解决这个问题需要加入配置自动刷新功能，这个我们在下一篇文章中介绍。

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

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

相关文章

物联网主机：为智能交通赋能

物联网主机：为智能交通赋能

物联网&#xff08;IoT&#xff09;技术的发展为智能交通领域带来了许多创新的解决方案。而在物联网应用中&#xff0c;物联网主机起着关键的作用。本文将为大家介绍一款名为E6000的物联网主机&#xff0c;它是一种多协议、多接口的物联网主机&#xff0c;为智能交通系统的建设…
阅读更多...
It is also possible that a host key has just been changed

It is also possible that a host key has just been changed

问题&#xff1a;ssh失败&#xff0c;提示如上图 分析: ssh的key存在上图里的路径里。 解决&#xff1a;win10删这个文件C:\Users\admin\.ssh\known_hosts , linux删这个文件.ssh\known_hosts ,或者删除这个文件里的制定ip的那一行&#xff0c;例如“106.1.1.22 ecdsa-sha2-…
阅读更多...
FreeRTOS操作系统学习——FreeRTOS工程创建

FreeRTOS操作系统学习——FreeRTOS工程创建

FreeROTS工程创建 详细步骤 如无特殊情况&#xff0c;大部人都要配置为外部高速时钟 另外&#xff0c;本实验使用了FreeRTOS&#xff0c;FreeRTOS的时基使用的是Systick&#xff0c;而 STM32CubeMX中默认的HAL库时基也是Systick&#xff0c;为了避免可能的冲突&#xff0c;最…
阅读更多...
【学习】torchvision.datasets.ImageFolder()

【学习】torchvision.datasets.ImageFolder()

在分类任务中&#xff0c;数据集文件存储往往是如下形式&#xff1a; - train- class1- image1.jpg- image2.jpg...- class2- image1.jpg- image2.jpg......此时&#xff0c;我们想要获取图片和标签&#xff0c;标签即为文件名&#xff08;class1、class2…&#xff09; 可以使…
阅读更多...
数据链路层----滑动窗口协议的相关计算

数据链路层----滑动窗口协议的相关计算

目录 1.窗口大小的相关计算 •停等协议&#xff1a; •后退N帧协议&#xff1a; •选择重传协议&#xff1a; 2.信道利用率相关计算 •停等协议的信道利用率&#xff1a; •连续ARQ&#xff08;后退N帧协议&#xff0c;选择重传协议&#xff09;的信道利用率&#xff1a;…
阅读更多...
Java 反射详解：动态创建实例、调用方法和访问字段

Java 反射详解：动态创建实例、调用方法和访问字段

“一般情况下&#xff0c;我们在使用某个类之前已经确定它到底是个什么类了&#xff0c;拿到手就直接可以使用 new 关键字来调用构造方法进行初始化&#xff0c;之后使用这个类的对象来进行操作。” Writer writer new Writer(); writer.setName("少年");像上面这个…
阅读更多...
no declaration can be found for element ‘rabbit:connection-factory‘

no declaration can be found for element ‘rabbit:connection-factory‘

spring-mvc 配置 rabbitmq 出现问题。 我的解决方案如下&#xff1a; 1 找到配置文件 spring-rabbitmq.xml 我的配置文件叫&#xff1a;spring-rabbitmq.xml&#xff0c;你们按照自己的查找。 2 定位如下URI 接着 Ctrl鼠标左键 3 确定spring-rabbit-x.x.xsd 按照步骤2 &…
阅读更多...
鸿蒙Harmony应用开发—ArkTS声明式开发（通用属性：组件标识）

鸿蒙Harmony应用开发—ArkTS声明式开发（通用属性：组件标识）

id为组件的唯一标识&#xff0c;在整个应用内唯一。本模块提供组件标识相关接口&#xff0c;可以获取指定id组件的属性&#xff0c;也提供向指定id组件发送事件的功能。 说明&#xff1a; 从API Version 8开始支持。后续版本如有新增内容&#xff0c;则采用上角标单独标记该内容…
阅读更多...
C++基于多设计模式下的同步异步日志系统day7（终）

C++基于多设计模式下的同步异步日志系统day7（终）

C基于多设计模式下的同步&异步日志系统day7&#xff08;终&#xff09; &#x1f4df;作者主页&#xff1a;慢热的陕西人 &#x1f334;专栏链接&#xff1a;C基于多设计模式下的同步&异步日志系统 &#x1f4e3;欢迎各位大佬&#x1f44d;点赞&#x1f525;关注&#…
阅读更多...
美易官方《盘前：美国股指期货温和走低》

美易官方《盘前：美国股指期货温和走低》

美国股指期货在盘前交易中温和走低&#xff0c;市场情绪在美联储主席鲍威尔即将作证前显得谨慎。投资者对即将公布的证词内容充满期待&#xff0c;以寻求对美联储未来货币政策的更多线索。 鲍威尔即将在国会作证&#xff0c;这是市场关注的焦点事件之一。他的证词可能会对美元汇…
阅读更多...
字节同事问我：我的Postman为什么连不了数据库？

字节同事问我：我的Postman为什么连不了数据库？

postman本身没有数据库连接功能&#xff0c;所以用到了node.js中的xmysql实现Rest API的生成&#xff0c;利用postman进行请求&#xff0c;获取需要的数据&#xff0c;来做数据准备或断言。 1 安装 安装node.js&#xff1a;要求版本大于等于7.6 首先保证你的环境上有node.js…
阅读更多...
【NR 定位】3GPP NR Positioning 5G定位标准解读（四）

【NR 定位】3GPP NR Positioning 5G定位标准解读（四）

目录 前言 6 Signalling protocols and interfaces 6.1 支持定位操作的网络接口 6.1.1 通用LCS控制平面架构 6.1.2 NR-Uu接口 6.1.3 LTE-Uu接口 6.1.4 NG-C接口 6.1.5 NL1接口 6.1.6 F1接口 6.1.7 NR PC5接口 6.2 终端协议 6.2.1 LTE定位协议&#xff08;LPP&#x…
阅读更多...
贪心算法(区间问题)

贪心算法(区间问题)

452. 用最少数量的箭引爆气球 题目(求无重复区间) 有一些球形气球贴在一堵用 XY 平面表示的墙面上。墙面上的气球记录在整数数组 points &#xff0c;其中points[i] [xstart, xend] 表示水平直径在 xstart 和 xend之间的气球。你不知道气球的确切 y 坐标。 一支弓箭可以沿着…
阅读更多...
爬虫入门到精通_实战篇11(使用代理处理反爬抓取微信文章)_PyQuery使用

爬虫入门到精通_实战篇11(使用代理处理反爬抓取微信文章)_PyQuery使用

1 目标 搜狗-微信这个网址来爬取微信的文章&#xff1a; ps&#xff1a;登录后才能查看第10页之后的内容&#xff1a; 量翻页触发了网站的反爬虫措施&#xff0c;导致ip被封&#xff0c;需要进行解锁。 然而从doc中可以看到&#xff0c;请求失败的那页&#xff08;状态码应…
阅读更多...
【力扣白嫖日记】1045.买下所有产品的客户

【力扣白嫖日记】1045.买下所有产品的客户

前言 练习sql语句&#xff0c;所有题目来自于力扣&#xff08;https://leetcode.cn/problemset/database/&#xff09;的免费数据库练习题。 今日题目&#xff1a; 1045.买下所有产品的客户 表&#xff1a;Customer 列名类型customer_idintproduct_keyint 该表可能包含重复…
阅读更多...
【Vue3】深入理解Vue中的ref属性

【Vue3】深入理解Vue中的ref属性

&#x1f497;&#x1f497;&#x1f497;欢迎来到我的博客&#xff0c;你将找到有关如何使用技术解决问题的文章&#xff0c;也会找到某个技术的学习路线。无论你是何种职业&#xff0c;我都希望我的博客对你有所帮助。最后不要忘记订阅我的博客以获取最新文章&#xff0c;也欢…
阅读更多...
MyCAT集群——MyCAT2如何配置读写分离

MyCAT集群——MyCAT2如何配置读写分离

先搭载MySQL一主两从 192.168.20.110MyCAT192.168.20.111Master192.168.20.112slave1192.168.20.113slave2 配置就不写了&#xff0c;比较基础&#xff0c;写一下步骤 1.进入mysql配置文件或者其子配置文件&#xff0c;添加server_id,开启gtidgtid_modeON,enforce-gtid-cons…
阅读更多...
个人社区 项目测试

个人社区 项目测试

目 录 一.背景及介绍二.功能详情三.手动测试1.编写测试用例2.测试 一.背景及介绍 该项目采用了前后端分离技术&#xff0c;把我们的数据保存到数据库中&#xff0c;操作对象是用户和个人文章编辑保存&#xff0c;前端的页面实现了登录&#xff0c;列表&#xff0c;编辑&#x…
阅读更多...
学习JAVA的第十三天（基础）

学习JAVA的第十三天（基础）

目录 API之Arrays 将数组变成字符串 二分查找法查找元素 拷贝数组 填充数组 排序数组 Lambda表达式 集合的进阶 单列集合 体系结构 Collection API之Arrays 操作数组的工具类 将数组变成字符串 //将数组变成字符串char[] arr {a,b,c,d,e};System.out.println(Arra…
阅读更多...
leetcode--接雨水（双指针法，动态规划，单调栈）

leetcode--接雨水（双指针法，动态规划，单调栈）

目录 方法一&#xff1a;双指针法 方法二&#xff1a;动态规划 方法三&#xff1a;单调栈 42. 接雨水 - 力扣&#xff08;LeetCode&#xff09; 黑色的是柱子&#xff0c;蓝色的是雨水&#xff0c;我们先来观察一下雨水的分布情况: 雨水落在凹槽之间&#xff0c;在一个凹槽的…
阅读更多...
最新文章
推荐文章

Copyright @ 2022~2023