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

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

    服务端

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

    Controller层

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

    1. @RestController
    2. @RequestMapping("/config")
    3. public class ConfigController {
    4.  
    5.     @Autowired
    6.     private ConfigService configService;
    7.  
    8.     @PostMapping("/insert")
    9.     public Result<Void> insertConfig(@RequestBody ConfigVO configVO) {
    10.         Result<ConfigBO> result = checkOpConfig(configVO);
    11.         if (result.failed()) {
    12.             return Result.resultToFail(result);
    13.         }
    14.         return configService.insertConfig(result.getData());
    15.     }
    16.  
    17.     @PostMapping("/update")
    18.     public Result<Void> updateConfig(@RequestBody ConfigVO configVO) {
    19.         Result<ConfigBO> result = checkOpConfig(configVO);
    20.         if (result.failed()) {
    21.             return Result.resultToFail(result);
    22.         }
    23.         ConfigBO configBO = result.getData();
    24.  
    25.         long id = configVO.getId();
    26.         if (id <= 0) {
    27.             return Result.fail("配置id错误");
    28.         }
    29.         configBO.setId(id);
    30.         return configService.updateConfig(configBO);
    31.     }
    32.  
    33.     @PostMapping("/delete")
    34.     public Result<Void> delConfig(@RequestBody ConfigVO configVO) {
    35.         long id = configVO.getId();
    36.         if (id <= 0) {
    37.             return Result.fail("配置id错误");
    38.         }
    39.         return configService.delConfig(id, 0L);
    40.     }
    41.  
    42.     @GetMapping("/get")
    43.     public Result<List<ConfigVO>> getAllValidConfig() {
    44.         Result<List<ConfigBO>> result = configService.getAllValidConfig();
    45.         if (result.failed()) {
    46.             return Result.resultToFail(result);
    47.         }
    48.         return Result.success(result.getData().stream().map(configBO -> {
    49.             ConfigVO configVO = new ConfigVO();
    50.             configVO.setId(configBO.getId());
    51.             configVO.setName(configBO.getName());
    52.             configVO.setConfigData(configBO.getConfigData());
    53.             configVO.setCreateTime(DateUtil.date2str1(configBO.getCreateTime()));
    54.             return configVO;
    55.         }).collect(Collectors.toList()));
    56.     }
    57.  
    58.     private Result<ConfigBO> checkOpConfig(ConfigVO configVO) {
    59.         String name = configVO.getName();
    60.         if (name == null || (name = name.trim()).length() == 0) {
    61.             return Result.fail("配置名不能为空");
    62.         }
    63.         JSONObject configData = configVO.getConfigData();
    64.         if (configData == null) {
    65.             return Result.fail("配置内容不能为空");
    66.         }
    67.         ConfigBO configBO = new ConfigBO();
    68.         configBO.setName(name);
    69.         configBO.setConfigData(configData);
    70.         return Result.success(configBO);
    71.     }
    72. }

    Service层

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

    1. @Service
    2. public class ConfigServiceImpl implements ConfigService {
    3.  
    4.     private ConfigDAO configDAO;
    5.  
    6.     @Autowired
    7.     private LocalConfigDAO localConfigDAO;
    8.  
    9.     @Value("${config.center.mode:0}")
    10.     private int configCenterMode;
    11.  
    12.     @PostConstruct
    13.     public void init() {
    14.         ConfigCenterModeEnum configCenterModeEnum = ConfigCenterModeEnum.getEnum(configCenterMode);
    15.         if (configCenterModeEnum == null) {
    16.             throw new IllegalArgumentException("配置config.center.mode错误");
    17.         }
    18.         if (configCenterModeEnum == ConfigCenterModeEnum.STANDALONE) {
    19.             this.configDAO = localConfigDAO;
    20.         }
    21.     }
    22.  
    23.     @Override
    24.     public Result insertConfig(ConfigBO configBO) {
    25.         List configList = configDAO.getAllValidConfig();
    26.         if (configList.stream().anyMatch(c -> c.getName().equals(configBO.getName()))) {
    27.             return Result.fail("配置名重复");
    28.         }
    29.         ConfigDO configDO = new ConfigDO();
    30.         configDO.setName(configBO.getName());
    31.         configDO.setConfigData(configBO.getConfigData().toJSONString());
    32.         configDAO.insertConfigDO(configDO);
    33.         return Result.success(null);
    34.     }
    35.  
    36.     @Override
    37.     public Result updateConfig(ConfigBO configBO) {
    38.         ConfigDO configDO = new ConfigDO();
    39.         configDO.setId(configBO.getId());
    40.         configDO.setName(configBO.getName());
    41.         configDO.setConfigData(configBO.getConfigData().toJSONString());
    42.         configDAO.updateConfig(configDO);
    43.         return Result.success(null);
    44.     }
    45.  
    46.     @Override
    47.     public Result delConfig(long id, long updateUid) {
    48.         configDAO.delConfig(id, updateUid);
    49.         return Result.success(null);
    50.     }
    51.  
    52.     @Override
    53.     public Result> getAllValidConfig() {
    54.         List configList = configDAO.getAllValidConfig();
    55.         return Result.success(configList.stream().map(configDO -> {
    56.             ConfigBO configBO = new ConfigBO();
    57.             configBO.setId(configDO.getId());
    58.             configBO.setName(configDO.getName());
    59.             configBO.setCreateTime(configDO.getCreateTime());
    60.             configBO.setConfigData(JSON.parseObject(configDO.getConfigData()));
    61.             return configBO;
    62.         }).collect(Collectors.toList()));
    63.     }
    64. }

    DAO层

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

    1. @Slf4j
    2. @Repository
    3. public class LocalConfigDAO implements ConfigDAO {
    4.  
    5.     private final Lock insertLock = new ReentrantLock();
    6.  
    7.     @Value("${config.center.standalone.path}")
    8.     private String standalonePath;
    9.  
    10.     @Override
    11.     public long insertConfigDO(ConfigDO configDO) {
    12.         insertLock.lock();
    13.         try {
    14.             long id = 1;
    15.             List<ConfigDO> configList = getAllConfig();
    16.             if (!configList.isEmpty()) {
    17.                 id = configList.get(configList.size() - 1).getId() + 1;
    18.             }
    19.             configDO.setId(id);
    20.             Optional.of(configDO).filter(c -> c.getCreateTime() == null).ifPresent(c -> c.setCreateTime(LocalDateTime.now()));
    21.  
    22.             String configPathStr = standalonePath + "/config";
    23.             Files.createDirectories(Paths.get(configPathStr));
    24.             Path path = Paths.get(configPathStr + "/" + id + ".conf");
    25.             Files.write(path, JSON.toJSONString(configDO).getBytes(StandardCharsets.UTF_8), StandardOpenOption.CREATE_NEW);
    26.             return id;
    27.         } catch (Exception e) {
    28.             throw new RuntimeException(e);
    29.         } finally {
    30.             insertLock.unlock();
    31.         }
    32.     }
    33.  
    34.     @Override
    35.     public void updateConfig(ConfigDO configDO) {
    36.         ConfigDO dbConfigDO = getConfig(configDO.getId());
    37.         Optional.ofNullable(dbConfigDO).map(c -> {
    38.             c.setName(configDO.getName());
    39.             c.setUpdateTime(LocalDateTime.now());
    40.             c.setUpdateUid(configDO.getUpdateUid());
    41.             c.setConfigData(configDO.getConfigData());
    42.             return c;
    43.         }).ifPresent(this::updateConfigDO);
    44.     }
    45.  
    46.     @Override
    47.     public void delConfig(long id, long updateUid) {
    48.         ConfigDO dbConfigDO = getConfig(id);
    49.         Optional.ofNullable(dbConfigDO).map(c -> {
    50.             c.setDeleted(true);
    51.             c.setUpdateTime(LocalDateTime.now());
    52.             c.setUpdateUid(updateUid);
    53.             return c;
    54.         }).ifPresent(this::updateConfigDO);
    55.     }
    56.  
    57.     @Override
    58.     public ConfigDO getConfig(long id) {
    59.         List<ConfigDO> configList = getAllConfig();
    60.         return configList.stream().filter(c -> c.getId() == id).findFirst().orElse(null);
    61.     }
    62.  
    63.     @Override
    64.     public List<ConfigDO> getAllValidConfig() {
    65.         return getAllConfig().stream().filter(c -> !c.isDeleted()).collect(Collectors.toList());
    66.     }
    67.  
    68.     @Override
    69.     public List<ConfigDO> getAllConfig() {
    70.         File[] files;
    71.         File folder = new File(standalonePath + "/config");
    72.         if (!folder.exists() || (files = folder.listFiles()) == null) {
    73.             return new ArrayList<>();
    74.         }
    75.         return Arrays.stream(files).map(File::getAbsolutePath)
    76.                 .filter(p -> p.endsWith(".conf")).map(this::buildConfigDO)
    77.                 .filter(Objects::nonNull).sorted(Comparator.comparing(ConfigDO::getId)).collect(Collectors.toList());
    78.     }
    79.  
    80.     private synchronized ConfigDO buildConfigDO(String path) {
    81.         try {
    82.             byte[] bytes = Files.readAllBytes(Paths.get(path));
    83.             String json = new String(bytes, StandardCharsets.UTF_8);
    84.             return JSON.parseObject(json, ConfigDO.class);
    85.         } catch (Exception e) {
    86.             log.error("buildConfigDO error,path:{}", path, e);
    87.             return null;
    88.         }
    89.     }
    90.  
    91.     private synchronized void updateConfigDO(ConfigDO configDO) {
    92.         Path path = Paths.get(standalonePath + "/config/" + configDO.getId() + ".conf");
    93.         if (Files.exists(path)) {
    94.             try {
    95.                 Files.write(path, JSON.toJSONString(configDO).getBytes(StandardCharsets.UTF_8), StandardOpenOption.WRITE);
    96.             } catch (IOException e) {
    97.                 log.error("updateConfigDO error configDO:{}", configDO, e);
    98.             }
    99.         }
    100.     }
    101. }

    效果

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

    新增配置

    获取所有有效配置

    修改配置

    删除配置

    客户端

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

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

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

  • 相关阅读:
    【天文】基于matlab实现GPS卫星运动仿真附matlab代码
    开槌在即：陈可之油画|《赞红梅》
    【JS 逆向百例】猿人学系列 web 比赛第二题：js 混淆 - 动态 cookie，详细剖析
    Python图像处理丨5种图像处理特效
    ESB+MDM预置样例测试总结
    华为云上安装mysql-5.7.38-极其详细的安装教程
    计算机毕业设计springboot+vue+elementUI基本微信小程序的新冠疫苗预约小程序
    APP稳定性测试-monkey日志分析及内存泄漏分析
    Jmeter基础入门教程【23】--常用功能详解：断言持续时间
    .NET序列化 serializable，反序列化
  • 原文地址：https://blog.csdn.net/cjc000/article/details/136451860