SpringBoot自定义配置注入的方式:自定义配置文件注入,从mysql读取配置进行注入

本文涉及的产品
RDS MySQL Serverless 基础系列,0.5-2RCU 50GB
云数据库 RDS MySQL,集群系列 2核4GB
推荐场景:
搭建个人博客
云数据库 RDS PostgreSQL,集群系列 2核4GB
简介: SpringBoot自定义配置注入的方式:自定义配置文件注入,从mysql读取配置进行注入

创建配置注入测试类

@Configuration
@ConfigurationProperties(prefix = ConfigTestPre.PREFIX)
@Data
public class ConfigTestPre {
   
   

    public static final String PREFIX = "hx.config";

    @Value("${hx.config:}") // 会优先使用prefix的方式注入
    private String test = "1";

    private String cfg;

}

1、自定义配置文件的注入

public class CustomerConfigInject  implements EnvironmentPostProcessor {
   
   
    PropertiesPropertySourceLoader load=new PropertiesPropertySourceLoader();

    @Override
    public void postProcessEnvironment(ConfigurableEnvironment environment, SpringApplication application) {
   
   
        MutablePropertySources propertySources = environment.getPropertySources();
        Resource resource=new ClassPathResource("custom.properties"); 
        PropertySource propertySource; 
        try {
   
   
            propertySource = load.load("customProperties",resource).get(0);
            propertySources.addFirst(propertySource);
        } catch (IOException e){
   
   
            e.printStackTrace();
        }

    }
}

META-INF/spring.factories中指定配置类:

org.springframework.boot.env.EnvironmentPostProcessor=com.hx.temp.config.CustomerConfigInject

在resource文件夹中添加自己的配置文件 custom.properties

hx.config=123

2、从数据库查询配置进行注入

数据库sql

DROP TABLE IF EXISTS `setting_table`;
CREATE TABLE `setting_table`  (
  `id` int(11) NOT NULL AUTO_INCREMENT COMMENT ' ',
  `name` varchar(255) CHARACTER SET utf8mb4 COLLATE utf8mb4_general_ci NULL DEFAULT NULL,
  `value` varchar(255) CHARACTER SET utf8mb4 COLLATE utf8mb4_general_ci NULL DEFAULT NULL,
  PRIMARY KEY (`id`) USING BTREE
) ENGINE = InnoDB AUTO_INCREMENT = 3 CHARACTER SET = utf8mb4 COLLATE = utf8mb4_general_ci ROW_FORMAT = Dynamic;

INSERT INTO `whx`.`setting_table`(`id`, `name`, `value`) VALUES (1, 'hx.config.test', 'fromMysql-test');
INSERT INTO `whx`.`setting_table`(`id`, `name`, `value`) VALUES (2, 'hx.config.cfg', 'fromMysql-cfg');

查询数据库配置,手动绑定配置到指定配置类中

项目启动执行一次,后面可以调接口刷新配置

package com.hx.config.config;

import lombok.extern.slf4j.Slf4j;
import org.springframework.beans.factory.annotation.Autowired;
import org.springframework.beans.factory.annotation.Value;
import org.springframework.boot.context.properties.bind.Bindable;
import org.springframework.boot.context.properties.bind.Binder;
import org.springframework.core.env.*;
import org.springframework.jdbc.core.JdbcTemplate;
import org.springframework.stereotype.Component;
import org.springframework.util.StringUtils;

import javax.annotation.PostConstruct;
import javax.sql.DataSource;
import java.util.*;

/**
 * @ClassName ConfigSupportConfiguration
 * @Description //TODO
 * @Author WHX
 * @Date 2022/6/5 15:00
 **/
@Component
@Slf4j
public class ConfigSupportConfiguration {
   
   
    public  static final String SQL = "select id, name, value from setting_table";
    private static final String SOURCE_NAME = ConfigSupportConfiguration.class.getSimpleName();

    @Value("${hx.config.load_sql:" + SQL + "}")
    private final String settings_sql = SQL;
    @Autowired
    private ConfigurableEnvironment environment;
    @Autowired
    private DataSource dataSource;

    @Autowired
    private ConfigTestPre configTestPre;

    @PostConstruct
    public Object refreshMysqlInjectConfig() {
   
   
        // 从数据库查询配置
        final JdbcTemplate jdbcTemplate = new JdbcTemplate(dataSource);
        final List<Map<String, Object>> rows = jdbcTemplate.queryForList(settings_sql);

        // 获取或者创建 PropertySource
        MapPropertySource propertySource = Optional.ofNullable((MapPropertySource) environment.getPropertySources().get(SOURCE_NAME))
                .orElse(new MapPropertySource(SOURCE_NAME, new HashMap<>()));

        Map<String, Object> source = propertySource.getSource();
        Map<String, Object> updateSource = new HashMap<>();

        for (final Map<String, Object> row : rows) {
   
   
            String name = String.valueOf(row.get("name"));
            String value = String.valueOf(row.get("value"));
            if (!StringUtils.hasText(name) || value == null) {
   
   
                continue;
            }
            Object property = source.get(name);
            if (null != property && property.equals(value)) {
   
   
                // 配置未发生改变
                continue;
            }
            source.put(name, value);
            updateSource.put(name, value);
        }

        if (updateSource.isEmpty()) return "{}";
        environment.getPropertySources().addLast(propertySource);
        // 配置注入早已经执行过了,所以这里手动去执行配置绑定到指定类(prefix的方式绑定)
        // 注意:这个仅针对configTestPre一个类进行了手动配置注入,并不是刷新所有的配置类;
        Binder.get(environment).bind(configTestPre.PREFIX, Bindable.ofInstance(configTestPre));
        return updateSource;
    }
}

刷新配置

定义刷新配置的接口

@RestController
@RequestMapping("/config/refresh")
public class RefreshConfigController {
   
   
    @Autowired
    private ConfigSupportConfiguration configSupportConfiguration;

    @GetMapping("/mysqlInject")
    public Object refreshMysqlInjectConfig(){
   
   
        return configSupportConfiguration.refreshMysqlInjectConfig();
    }
}

修改数据库后,调用刷新接口:

curl localhost:80/config/refresh/mysqlInject
在这里插入图片描述

相关实践学习
如何快速连接云数据库RDS MySQL
本场景介绍如何通过阿里云数据管理服务DMS快速连接云数据库RDS MySQL,然后进行数据表的CRUD操作。
全面了解阿里云能为你做什么
阿里云在全球各地部署高效节能的绿色数据中心,利用清洁计算为万物互联的新世界提供源源不断的能源动力,目前开服的区域包括中国(华北、华东、华南、香港)、新加坡、美国(美东、美西)、欧洲、中东、澳大利亚、日本。目前阿里云的产品涵盖弹性计算、数据库、存储与CDN、分析与搜索、云通信、网络、管理与监控、应用服务、互联网中间件、移动服务、视频服务等。通过本课程,来了解阿里云能够为你的业务带来哪些帮助 &nbsp; &nbsp; 相关的阿里云产品:云服务器ECS 云服务器 ECS(Elastic Compute Service)是一种弹性可伸缩的计算服务,助您降低 IT 成本,提升运维效率,使您更专注于核心业务创新。产品详情: https://www.aliyun.com/product/ecs
相关文章
|
20天前
|
存储 SQL 关系型数据库
MySQL底层概述—4.InnoDB数据文件
本文介绍了InnoDB表空间文件结构及其组成部分,包括表空间、段、区、页和行。表空间是最高逻辑层,包含多个段;段由若干个区组成,每个区包含64个连续的页,页用于存储多条行记录。文章还详细解析了Page结构,分为通用部分(文件头与文件尾)、数据记录部分和页目录部分。此外,文中探讨了行记录格式,包括四种行格式(Redundant、Compact、Dynamic和Compressed),重点介绍了Compact行记录格式及其溢出机制。最后,文章解释了不同行格式的特点及应用场景,帮助理解InnoDB存储引擎的工作原理。
MySQL底层概述—4.InnoDB数据文件
|
27天前
|
SQL 监控 关系型数据库
MySQL补充性文件
通过以上内容,您可以全面了解和掌握 MySQL 补充性文件的配置、查看及其作用,从而提升数据库管理的效率和质量。
69 36
|
5月前
|
SQL 关系型数据库 MySQL
mysql主从复制概述和配置
【10月更文挑战第22天】MySQL 主从复制是一种将主服务器的数据复制到一个或多个从服务器的技术,实现读写分离,提高系统性能和可用性。主服务器记录变更日志,从服务器通过 I/O 和 SQL 线程读取并应用这些变更。适用于读写分离、数据备份和恢复、数据分析等场景。配置步骤包括修改配置文件、创建复制用户、配置从服务器连接主服务器并启动复制进程。
262 1
|
4月前
|
存储 Oracle 关系型数据库
【赵渝强老师】MySQL InnoDB的数据文件与重做日志文件
本文介绍了MySQL InnoDB存储引擎中的数据文件和重做日志文件。数据文件包括`.ibd`和`ibdata`文件,用于存放InnoDB数据和索引。重做日志文件(redo log)确保数据的可靠性和事务的持久性,其大小和路径可由相关参数配置。文章还提供了视频讲解和示例代码。
218 11
【赵渝强老师】MySQL InnoDB的数据文件与重做日志文件
|
3月前
|
关系型数据库 MySQL 数据库
数据库数据恢复—MYSQL数据库文件损坏的数据恢复案例
mysql数据库文件ibdata1、MYI、MYD损坏。 故障表现:1、数据库无法进行查询等操作;2、使用mysqlcheck和myisamchk无法修复数据库。
|
3月前
|
安全 关系型数据库 MySQL
解决MySQL删除/var/lib/mysql下的所有文件后无法启动的问题
删除 `/var/lib/mysql` 下的所有文件后,需要重新初始化数据目录,确保正确的权限设置,并重新启动 MySQL 服务。通过按照上述步骤操作,可以解决 MySQL 无法启动的问题,并恢复数据库的正常运行。初始化数据目录后,别忘了配置安全设置,并根据需要恢复备份数据。这些步骤不仅能够恢复 MySQL 的正常运行,还能确保数据库的安全性和完整性。
204 2
|
3月前
|
SQL 关系型数据库 MySQL
MySQL导入.sql文件后数据库乱码问题
本文分析了导入.sql文件后数据库备注出现乱码的原因,包括字符集不匹配、备注内容编码问题及MySQL版本或配置问题,并提供了详细的解决步骤,如检查和统一字符集设置、修改客户端连接方式、检查MySQL配置等,确保导入过程顺利。
|
4月前
|
关系型数据库 MySQL 数据库
【赵渝强老师】MySQL的参数文件
MySQL启动时会读取配置文件my.cnf来确定数据库文件位置及初始化参数。该文件分为Server和Client两部分,包含动态与静态参数。动态参数可在运行中通过命令修改,而静态参数需修改my.cnf并重启服务生效。文中还提供了相关代码示例和视频教程。
149 6
|
4月前
|
SQL 关系型数据库 MySQL
【赵渝强老师】MySQL的全量日志文件
MySQL全量日志记录所有操作的SQL语句,默认禁用。启用后,可通过`show variables like %general_log%检查状态,使用`set global general_log=ON`临时开启,执行查询并查看日志文件以追踪SQL执行详情。
|
4月前
|
存储 SQL 关系型数据库
2024Mysql And Redis基础与进阶操作系列(1)作者——LJS[含MySQL的下载、安装、配置详解步骤及报错对应解决方法]
Mysql And Redis基础与进阶操作系列(1)之[MySQL的下载、安装、配置详解步骤及报错对应解决方法]