当前位置： 首页 > news >正文

微服务之注册中心与ShardingSphere关于分库分表的那些事

news 2025/8/17 7:23:12

小伙伴们，你们好呀！我是老寇！跟我一起学习注册中心与ShardingSphere怎么一起使用

使用

nacos-shardingsphere例子，请点击我

注意：需要自己提前创建数据库和表

create database kcloud_platform_test;DROP TABLE IF EXISTS "public"."boot_sys_user_202401";
CREATE TABLE "public"."boot_sys_user_202401" (
"id" int8 NOT NULL GENERATED BY DEFAULT AS IDENTITY,
"name" varchar(50)  NOT NULL,
"create_time" timestamp(6) NOT NULL
)
;
COMMENT ON COLUMN "public"."boot_sys_user_202401"."id" IS 'ID';
COMMENT ON COLUMN "public"."boot_sys_user_202401"."name" IS '名称';
COMMENT ON COLUMN "public"."boot_sys_user_202401"."create_time" IS '创建时间';
ALTER TABLE "public"."boot_sys_user_202401" ADD CONSTRAINT "boot_sys_user_202401_pkey" PRIMARY KEY ("id");DROP TABLE IF EXISTS "public"."boot_sys_user_202402";
CREATE TABLE "public"."boot_sys_user_202402" (
"id" int8 NOT NULL GENERATED BY DEFAULT AS IDENTITY,
"name" varchar(50)  NOT NULL,
"create_time" timestamp(6) NOT NULL
)
;
COMMENT ON COLUMN "public"."boot_sys_user_202402"."id" IS 'ID';
COMMENT ON COLUMN "public"."boot_sys_user_202402"."name" IS '名称';
COMMENT ON COLUMN "public"."boot_sys_user_202402"."create_time" IS '创建时间';
ALTER TABLE "public"."boot_sys_user_202402" ADD CONSTRAINT "boot_sys_user_202402_pkey" PRIMARY KEY ("id");DROP TABLE IF EXISTS "public"."boot_sys_user_202403";
CREATE TABLE "public"."boot_sys_user_202403" (
"id" int8 NOT NULL GENERATED BY DEFAULT AS IDENTITY,
"name" varchar(50)  NOT NULL,
"create_time" timestamp(6) NOT NULL
)
;
COMMENT ON COLUMN "public"."boot_sys_user_202403"."id" IS 'ID';
COMMENT ON COLUMN "public"."boot_sys_user_202403"."name" IS '名称';
COMMENT ON COLUMN "public"."boot_sys_user_202403"."create_time" IS '创建时间';
ALTER TABLE "public"."boot_sys_user_202403" ADD CONSTRAINT "boot_sys_user_202403_pkey" PRIMARY KEY ("id");DROP TABLE IF EXISTS "public"."boot_sys_user_202404";
CREATE TABLE "public"."boot_sys_user_202404" (
"id" int8 NOT NULL GENERATED BY DEFAULT AS IDENTITY,
"name" varchar(50)  NOT NULL,
"create_time" timestamp(6) NOT NULL
)
;
COMMENT ON COLUMN "public"."boot_sys_user_202404"."id" IS 'ID';
COMMENT ON COLUMN "public"."boot_sys_user_202404"."name" IS '名称';
COMMENT ON COLUMN "public"."boot_sys_user_202404"."create_time" IS '创建时间';
ALTER TABLE "public"."boot_sys_user_202404" ADD CONSTRAINT "boot_sys_user_202404_pkey" PRIMARY KEY ("id");DROP TABLE IF EXISTS "public"."boot_sys_user_202405";
CREATE TABLE "public"."boot_sys_user_202405" (
"id" int8 NOT NULL GENERATED BY DEFAULT AS IDENTITY,
"name" varchar(50)  NOT NULL,
"create_time" timestamp(6) NOT NULL
)
;
COMMENT ON COLUMN "public"."boot_sys_user_202405"."id" IS 'ID';
COMMENT ON COLUMN "public"."boot_sys_user_202405"."name" IS '名称';
COMMENT ON COLUMN "public"."boot_sys_user_202405"."create_time" IS '创建时间';
ALTER TABLE "public"."boot_sys_user_202405" ADD CONSTRAINT "boot_sys_user_202405_pkey" PRIMARY KEY ("id");DROP TABLE IF EXISTS "public"."boot_sys_user_202406";
CREATE TABLE "public"."boot_sys_user_202406" (
"id" int8 NOT NULL GENERATED BY DEFAULT AS IDENTITY,
"name" varchar(50)  NOT NULL,
"create_time" timestamp(6) NOT NULL
)
;
COMMENT ON COLUMN "public"."boot_sys_user_202406"."id" IS 'ID';
COMMENT ON COLUMN "public"."boot_sys_user_202406"."name" IS '名称';
COMMENT ON COLUMN "public"."boot_sys_user_202406"."create_time" IS '创建时间';
ALTER TABLE "public"."boot_sys_user_202406" ADD CONSTRAINT "boot_sys_user_202406_pkey" PRIMARY KEY ("id");DROP TABLE IF EXISTS "public"."boot_sys_user_202407";
CREATE TABLE "public"."boot_sys_user_202407" (
"id" int8 NOT NULL GENERATED BY DEFAULT AS IDENTITY,
"name" varchar(50)  NOT NULL,
"create_time" timestamp(6) NOT NULL
)
;
COMMENT ON COLUMN "public"."boot_sys_user_202407"."id" IS 'ID';
COMMENT ON COLUMN "public"."boot_sys_user_202407"."name" IS '名称';
COMMENT ON COLUMN "public"."boot_sys_user_202407"."create_time" IS '创建时间';
ALTER TABLE "public"."boot_sys_user_202407" ADD CONSTRAINT "boot_sys_user_202407_pkey" PRIMARY KEY ("id");DROP TABLE IF EXISTS "public"."boot_sys_user_202408";
CREATE TABLE "public"."boot_sys_user_202408" (
"id" int8 NOT NULL GENERATED BY DEFAULT AS IDENTITY,
"name" varchar(50)  NOT NULL,
"create_time" timestamp(6) NOT NULL
)
;
COMMENT ON COLUMN "public"."boot_sys_user_202408"."id" IS 'ID';
COMMENT ON COLUMN "public"."boot_sys_user_202408"."name" IS '名称';
COMMENT ON COLUMN "public"."boot_sys_user_202408"."create_time" IS '创建时间';
ALTER TABLE "public"."boot_sys_user_202408" ADD CONSTRAINT "boot_sys_user_202408_pkey" PRIMARY KEY ("id");DROP TABLE IF EXISTS "public"."boot_sys_user_202409";
CREATE TABLE "public"."boot_sys_user_202409" (
"id" int8 NOT NULL GENERATED BY DEFAULT AS IDENTITY,
"name" varchar(50)  NOT NULL,
"create_time" timestamp(6) NOT NULL
)
;
COMMENT ON COLUMN "public"."boot_sys_user_202409"."id" IS 'ID';
COMMENT ON COLUMN "public"."boot_sys_user_202409"."name" IS '名称';
COMMENT ON COLUMN "public"."boot_sys_user_202409"."create_time" IS '创建时间';
ALTER TABLE "public"."boot_sys_user_202409" ADD CONSTRAINT "boot_sys_user_202409_pkey" PRIMARY KEY ("id");DROP TABLE IF EXISTS "public"."boot_sys_user_202410";
CREATE TABLE "public"."boot_sys_user_202410" (
"id" int8 NOT NULL GENERATED BY DEFAULT AS IDENTITY,
"name" varchar(50)  NOT NULL,
"create_time" timestamp(6) NOT NULL
)
;
COMMENT ON COLUMN "public"."boot_sys_user_202410"."id" IS 'ID';
COMMENT ON COLUMN "public"."boot_sys_user_202410"."name" IS '名称';
COMMENT ON COLUMN "public"."boot_sys_user_202410"."create_time" IS '创建时间';
ALTER TABLE "public"."boot_sys_user_202410" ADD CONSTRAINT "boot_sys_user_202410_pkey" PRIMARY KEY ("id");
INSERT INTO "public"."boot_sys_user_202410" VALUES (1, 'boot_sys_user_202410_用户1', '2024-10-26 20:14:22');DROP TABLE IF EXISTS "public"."boot_sys_user_202411";
CREATE TABLE "public"."boot_sys_user_202411" (
"id" int8 NOT NULL GENERATED BY DEFAULT AS IDENTITY,
"name" varchar(50)  NOT NULL,
"create_time" timestamp(6) NOT NULL
)
;
COMMENT ON COLUMN "public"."boot_sys_user_202411"."id" IS 'ID';
COMMENT ON COLUMN "public"."boot_sys_user_202411"."name" IS '名称';
COMMENT ON COLUMN "public"."boot_sys_user_202411"."create_time" IS '创建时间';ALTER TABLE "public"."boot_sys_user_202411" ADD CONSTRAINT "boot_sys_user_202411_pkey" PRIMARY KEY ("id");DROP TABLE IF EXISTS "public"."boot_sys_user_202412";
CREATE TABLE "public"."boot_sys_user_202412" (
"id" int8 NOT NULL GENERATED BY DEFAULT AS IDENTITY,
"name" varchar(50)  NOT NULL,
"create_time" timestamp(6) NOT NULL
)
;
COMMENT ON COLUMN "public"."boot_sys_user_202412"."id" IS 'ID';
COMMENT ON COLUMN "public"."boot_sys_user_202412"."name" IS '名称';
COMMENT ON COLUMN "public"."boot_sys_user_202412"."create_time" IS '创建时间';ALTER TABLE "public"."boot_sys_user_202412" ADD CONSTRAINT "boot_sys_user_202412_pkey" PRIMARY KEY ("id");CREATE TABLE "public"."t_user" ("id" int8 NOT NULL GENERATED BY DEFAULT AS IDENTITY,"name" varchar(20) NOT NULL,"creator" int8 NOT NULL DEFAULT 0,"editor" int8 NOT NULL DEFAULT 0,"create_time" timestamp(6) NOT NULL DEFAULT CURRENT_TIMESTAMP,"update_time" timestamp(6) NOT NULL DEFAULT CURRENT_TIMESTAMP,"del_flag" int2 NOT NULL DEFAULT 0,"version" int4 NOT NULL DEFAULT 0,"tenant_id" int8 NOT NULL DEFAULT 0,CONSTRAINT "t_user_pkey" PRIMARY KEY ("id")
);
COMMENT ON COLUMN "public"."t_user"."id" IS 'ID';
COMMENT ON COLUMN "public"."t_user"."name" IS '名称';
COMMENT ON COLUMN "public"."t_user"."creator" IS '创建人';
COMMENT ON COLUMN "public"."t_user"."editor" IS '编辑人';
COMMENT ON COLUMN "public"."t_user"."create_time" IS '创建时间';
COMMENT ON COLUMN "public"."t_user"."update_time" IS '修改时间';
COMMENT ON COLUMN "public"."t_user"."del_flag" IS '删除标识 0未删除 1已删除';
COMMENT ON COLUMN "public"."t_user"."version" IS '版本号';
COMMENT ON COLUMN "public"."t_user"."tenant_id" IS '租户ID';
INSERT INTO "public"."t_user" VALUES (1, '老寇', 1, 1, '2025-04-17 22:35:13.722422', '2025-04-17 22:35:13.722422', 0, 0, 0);
1.引入依赖
  <dependencies><dependency><groupId>org.apache.shardingsphere</groupId><artifactId>shardingsphere-jdbc</artifactId></dependency><dependency><groupId>com.baomidou</groupId><artifactId>mybatis-plus-spring-boot3-starter</artifactId></dependency></dependencies>
2.配置分库分表&读写分离

注意：对shardingsphere数据库用户名/密码进行加密与解密

class ShardingSphereTest {@Testvoid testCrypto() throws Exception {// 私钥加密，公钥解密String str = "123456";String publicKey = "MFwwDQYJKoZIhvcNAQEBBQADSwAwSAJBAJ4o6sn4WoPmbs7DR9mGQzuuUQM9erQTVPpwxIzB0ETYkyKffO097qXVRLA6KPmaV+/siWewR7vpfYYjWajw5KkCAwEAAQ==";String encryptStr = CryptoUtils.encrypt(str);String decryptStr = CryptoUtils.decrypt(publicKey, encryptStr);Assertions.assertEquals(str, decryptStr);}}

application-shardingsphere.yaml【nacos配置】

# 加密公钥
public-key: MFwwDQYJKoZIhvcNAQEBBQADSwAwSAJBAJ4o6sn4WoPmbs7DR9mGQzuuUQM9erQTVPpwxIzB0ETYkyKffO097qXVRLA6KPmaV+/siWewR7vpfYYjWajw5KkCAwEAAQ==
dataSources:# 主表【数据库配置，请按照作者来，请不要瞎几把改！！！】master:dataSourceClassName: com.zaxxer.hikari.HikariDataSourcedriverClassName: org.postgresql.DriverjdbcUrl: jdbc:postgresql://postgresql:5432/kcloud_platform_test?tcpKeepAlive=true&reWriteBatchedInserts=true&stringtype=unspecified&ApplicationName=laokou-sample-shardingsphere&useSSL=falseusername: ENC(VZamSTMi224AH6RUtJGXNldiDp/XEL2ozRhBUu/o9ChodT4JEb9kE/j0EFhXKbjsfvLVacUW0AUzetA6OrNJug==)password: ENC(laIHkPM/z03tYjA95hES4+BhyjyhvrPjJynrC65oDyXnUTP0Tge1UxwERWFBbHoOOQZ2GzzUrRhEYJ3jFb89eQ==)# 从表【数据库配置，请按照作者来，请不要瞎几把改！！！】slave:dataSourceClassName: com.zaxxer.hikari.HikariDataSourcedriverClassName: org.postgresql.DriverjdbcUrl: jdbc:postgresql://postgresql:5432/kcloud_platform_test?tcpKeepAlive=true&reWriteBatchedInserts=true&stringtype=unspecified&ApplicationName=laokou-sample-shardingsphere&useSSL=falseusername: ENC(VZamSTMi224AH6RUtJGXNldiDp/XEL2ozRhBUu/o9ChodT4JEb9kE/j0EFhXKbjsfvLVacUW0AUzetA6OrNJug==)password: ENC(laIHkPM/z03tYjA95hES4+BhyjyhvrPjJynrC65oDyXnUTP0Tge1UxwERWFBbHoOOQZ2GzzUrRhEYJ3jFb89eQ==)
rules:
- !SHARDINGtables:# 分表的表名boot_sys_user:# 分表规则，按月份分表actualDataNodes: master.boot_sys_user_20240$->{1..9},master.boot_sys_user_2024$->{10..12}# 分表策略tableStrategy:# 规格standard:# 按创建时间字段分表shardingColumn: create_date# 自定义分表算法名称shardingAlgorithmName: laokou_table_inline# 主键生成策略keyGenerateStrategy:# 主键字段名称column: id# 主键生成采用的算法名称keyGeneratorName: snowflake# 自定义分表算法shardingAlgorithms:# 自定义分表算法名称laokou_table_inline:# 时间范围分片算法type: INTERVALprops:# 分片键的时间戳格式datetime-pattern: "yyyy-MM-dd HH:mm:ss"# 真实表的后缀格式sharding-suffix-pattern: "yyyyMM"# 时间分片下界值datetime-lower: "2024-01-01 00:00:00"# 时间分片上界值datetime-upper: "2024-12-31 23:59:59"# 分片间隔datetime-interval-amount: 1# 按月分表datetime-interval-unit: "months"# 主键生成器keyGenerators:# 雪花算法配置snowflake:# 雪花算法type: SNOWFLAKE# 属性props:# 机器工作IDwork-id: 123
- !READWRITE_SPLITTING# 数据源分组dataSourceGroups:# 读写分离配置laokou_readwrite_data_sources:# 主节点写入writeDataSourceName: master# 从节点读取readDataSourceNames:- slave# 自定义负载均衡算法名称loadBalancerName: laokou_load_balance_algorithm# 自定义负载均衡算法loadBalancers:# 自定义负载均衡算法名称laokou_load_balance_algorithm:# 轮询调度算法type: ROUND_ROBIN
# 属性配置
props:# 显示SQL语句sql-show: true
3.使用
spring:datasource:dynamic:datasource:master:# 拉取nacos的配置url: jdbc:shardingsphere:nacos:application-shardingsphere.yaml# 这个配置请写死，请不要瞎几把改【基于spi发现】# 这个配置请写死，请不要瞎几把改【基于spi发现】# 这个配置请写死，请不要瞎几把改【基于spi发现】driver-class-name: org.laokou.common.shardingsphere.config.nacos.NacosShardingSphereDrivercloud:# nacos的使用，请参考本教程组件【nacos】一节有详细介绍nacos:discovery:server-addr: nacos:8848username: nacospassword: nacosnamespace: publiccluster-name: laokou-clustergroup: DEFAULT_GROUPconfig:server-addr: nacos:8848username: nacospassword: nacosnamespace: publiccluster-name: laokou-cluster# https://github.com/alibaba/spring-cloud-alibaba/blob/2021.x/spring-cloud-alibaba-docs/src/main/asciidoc-zh/nacos-config.adoc# 指定读取的文件格式file-extension: yamlgroup: DEFAULT_GROUPrefresh-enabled: true
4.启动nacos和laokou-sample-shardingsphere【略】
5.启动并访问 http://localhost:9033

扩展

众所周知，市面上的配置中心五花八门，如何适配各种配置中心？，跟随我来扩展吧！

在开始之前，我们先来看一下ShardingSphereDriver 了解整个加载流程【基于SPI发现】
在这里插入图片描述
在这里插入图片描述
在这里插入图片描述
在这里插入图片描述
在这里插入图片描述

这个流程也很简单，其实就是将yaml文件的数据转换成以shardingsphere形式的数据源，因此，我们可以将公共部分进行抽象，只需要补充各个配置中心拉取配置的代码。

在这里插入图片描述

nacos为例【nacos与consul、apollo类似，我就不一个一个展示啦~】

AbstractShardingSphereDriver

/*** Abstract ShardingSphere driver.** @author laokou*/
@SuppressWarnings("UseAbstractOfJDBCDriverClass")
public abstract class AbstractShardingSphereDriver implements Driver {private static final int MAJOR_DRIVER_VERSION = 5;private static final int MINOR_DRIVER_VERSION = 5;@HighFrequencyInvocation(canBeCached = true)@Overridepublic Connection connect(final String url, final Properties info) throws SQLException {return acceptsURL(url) ? getDriverDataSourceCache().get(url, getDriverUrlPrefix()).getConnection() : null;}@Overridepublic boolean acceptsURL(final String url) {return null != url && url.startsWith(getDriverUrlPrefix());}@Overridepublic DriverPropertyInfo[] getPropertyInfo(final String url, final Properties info) {return new DriverPropertyInfo[0];}@Overridepublic int getMajorVersion() {return MAJOR_DRIVER_VERSION;}@Overridepublic int getMinorVersion() {return MINOR_DRIVER_VERSION;}@Overridepublic boolean jdbcCompliant() {return false;}@Overridepublic Logger getParentLogger() {return Logger.getLogger(Logger.GLOBAL_LOGGER_NAME);}abstract protected AbstractDriverDataSourceCache getDriverDataSourceCache();abstract protected String getDriverUrlPrefix();}

AbstractDriverDataSourceCache

/*** Abstract Driver data source cache.** @author laokou*/
public abstract class AbstractDriverDataSourceCache {private final Map<String, DataSource> DATASOURCE_MAP = new ConcurrentHashMap<>(MapUtil.initialCapacity(16));/*** Get data source.* @param url URL* @param urlPrefix URL prefix* @return got data source*/public DataSource get(final String url, final String urlPrefix) {if (DATASOURCE_MAP.containsKey(url)) {return DATASOURCE_MAP.get(url);}return DATASOURCE_MAP.computeIfAbsent(url,driverUrl -> createDataSource(ShardingSphereURL.parse(driverUrl.substring(urlPrefix.length()))));}abstract protected AbstractShardingSphereURLLoadEngine getShardingSphereURLLoadEngine(ShardingSphereURL url);private <T extends Throwable> DataSource createDataSource(final ShardingSphereURL url) throws T {try {AbstractShardingSphereURLLoadEngine urlLoadEngine = getShardingSphereURLLoadEngine(url);return YamlShardingSphereDataSourceFactory.createDataSource(urlLoadEngine.loadContent());}catch (final IOException ex) {throw (T) new SQLException(ex);}catch (final SQLException ex) {throw (T) ex;}catch (Exception e) {throw new RuntimeException(e);}}}

AbstractShardingSphereURLLoadEngine

/*** Abstract ShardingSphere URL load engine.** @author laokou*/
@Slf4j
public abstract class AbstractShardingSphereURLLoadEngine {private static final Pattern ENC_PATTERN = Pattern.compile("^ENC\\((.*)\\)$");private static final String PUBLIC_KEY = "public-key";private static final String CRYPTO_PREFIX = "ENC(";private static final String CRYPTO_SUFFIX = ")";protected final ShardingSphereURL url;protected AbstractShardingSphereURLLoadEngine(final ShardingSphereURL url) {this.url = url;}/*** Load configuration content.* @return loaded content*/public byte[] loadContent() throws Exception {return resolvePropertyValue(getContent()).getBytes(StandardCharsets.UTF_8);}abstract protected String getContent() throws IOException, NacosException;private String resolvePropertyValue(String value) {List<String> list = getList(value);if (list.isEmpty()) {throw new SystemException("S_ShardingSphere_PullConfigError", "无法拉取ShardingSphere配置");}List<String> strList = list.stream().filter(i -> i.startsWith(PUBLIC_KEY)).toList();String publicKey = StringConstant.EMPTY;if (CollectionUtil.isNotEmpty(strList)) {publicKey = strList.getFirst().substring(11).trim();}StringBuilder stringBuilder = new StringBuilder();String finalPublicKey = publicKey;list.forEach(item -> {if (!item.startsWith(PUBLIC_KEY)) {if (item.contains(CRYPTO_PREFIX) && item.contains(CRYPTO_SUFFIX)) {int index = item.indexOf(StringConstant.RISK);String key = item.substring(0, index + 2);String val = item.substring(index + 2).trim();stringBuilder.append(key).append(decrypt(finalPublicKey, val)).append("\n");}else {stringBuilder.append(item).append("\n");}}});return stringBuilder.toString();}private List<String> getList(String value) {List<String> list = new ArrayList<>(256);try (LineNumberReader reader = new LineNumberReader(new InputStreamReader(new ByteArrayInputStream(value.getBytes(StandardCharsets.UTF_8)), StandardCharsets.UTF_8))) {String str;while (ObjectUtil.isNotNull((str = reader.readLine()))) {// #开头直接丢弃if (!str.trim().startsWith(WELL_NO)) {list.add(str);}}}catch (IOException e) {log.error("错误信息：{}", e.getMessage());}return list;}/*** 字符串解密.* @param cipherText 加密字符串* @param publicKey 公钥*/private String decrypt(String publicKey, String cipherText) {if (StringUtils.hasText(cipherText)) {Matcher matcher = ENC_PATTERN.matcher(cipherText);if (matcher.find()) {try {return CryptoUtils.decrypt(publicKey, matcher.group(1));}catch (Exception e) {log.error("ShardingSphere decrypt error", e);}}}return cipherText;}}

NacosShardingSphereDriver

/*** Nacos ShardingSphere driver.** @author laokou*/
@SuppressWarnings("UseNacosOfJDBCDriverClass")
public final class NacosShardingSphereDriver extends AbstractShardingSphereDriver {private static final String DRIVER_URL_PREFIX = "jdbc:shardingsphere:nacos:";static {try {DriverManager.registerDriver(new NacosShardingSphereDriver());}catch (final SQLException ex) {throw new DriverRegisterException(ex);}}private final NacosDriverDataSourceCache dataSourceCache = new NacosDriverDataSourceCache();@Overrideprotected AbstractDriverDataSourceCache getDriverDataSourceCache() {return dataSourceCache;}@Overrideprotected String getDriverUrlPrefix() {return DRIVER_URL_PREFIX;}}

NacosDriverDataSourceCache

/*** Nacos Driver data source cache.** @author laokou*/
@Getter
public final class NacosDriverDataSourceCache extends AbstractDriverDataSourceCache {@Overrideprotected AbstractShardingSphereURLLoadEngine getShardingSphereURLLoadEngine(ShardingSphereURL url) {return new NacosShardingSphereURLLoadEngine(url);}}

NacosShardingSphereURLLoadEngine

/*** Nacos ShardingSphere URL load engine.** @author laokou*/
@Slf4j
public final class NacosShardingSphereURLLoadEngine extends AbstractShardingSphereURLLoadEngine {private static final String BIND_YAML_NAME = "bootstrap.yml";private static final String YAML_FORMAT = "yaml";private static final String NACOS_CONFIG_PREFIX = "spring.cloud.nacos.config";public NacosShardingSphereURLLoadEngine(ShardingSphereURL url) {super(url);}@Overrideprotected String getContent() throws IOException, NacosException {// Nacos拉取配置NacosConfigProperties properties = PropertyUtil.bindOrCreate(NACOS_CONFIG_PREFIX, NacosConfigProperties.class,BIND_YAML_NAME, YAML_FORMAT);String group = properties.getGroup();NacosConfigManager nacosConfigManager = new NacosConfigManager(properties);ConfigService configService = nacosConfigManager.getConfigService();String dataId = url.getConfigurationSubject();Preconditions.checkArgument(StringUtil.isNotEmpty(dataId),"Nacos dataId is required in ShardingSphere driver URL.");return configService.getConfig(dataId, group, 5000);}}

配置SPI发现

注意：在resources目录下创建META-INF/services文件夹，创建 java.sql.Driver 文件

org.laokou.common.shardingsphere.config.nacos.NacosShardingSphereDriver
org.laokou.common.shardingsphere.config.apollo.ApolloShardingSphereDriver
org.laokou.common.shardingsphere.config.consul.ConsulShardingSphereDriver

在这里插入图片描述
总结：集成其他的配置中心，只需继承三个抽象类。

  • AbstractShardingSphereDriver
  • AbstractDriverDataSourceCache
  • AbstractShardingSphereURLLoadEngine

注意：consul和apollo需要你们自行补充

ApolloShardingSphereURLLoadEngine

/*** Apollo ShardingSphere URL load engine.** @author laokou*/
@Slf4j
public final class ApolloShardingSphereURLLoadEngine extends AbstractShardingSphereURLLoadEngine {public ApolloShardingSphereURLLoadEngine(ShardingSphereURL url) {super(url);}@Overrideprotected String getContent() {// 补充拉取配置的代码return null;}}

ConsulShardingSphereURLLoadEngine

/*** Consul ShardingSphere URL load engine.** @author laokou*/
@Slf4j
public final class ConsulShardingSphereURLLoadEngine extends AbstractShardingSphereURLLoadEngine {public ConsulShardingSphereURLLoadEngine(ShardingSphereURL url) {super(url);}@Overrideprotected String getContent() {// 补充拉取配置的代码return null;}}

我是老寇，我们下次再见啦！

http://www.dtcms.com/a/334545.html

相关文章：

  • 类与类加载器
  • 基于GIS的无人机模拟飞行控制系统设计与实现
  • 某智慧教育平台登录流程分析
  • 元宇宙娱乐：重构数字时代的沉浸式体验
  • 嵌入式 Linux LED 驱动开发实验
  • RK3568 NPU RKNN（五）：RKNN-ToolKit-lite2板端推理
  • 要导入StandardScaler类进行数据标准化，请使用以下语句：
  • JavaScript学习第十章-第三部分(dom)
  • B3865 [GESP202309 二级] 小杨的 X 字矩阵（举一反三）
  • C#计算阶乘程序改进
  • C# 元组的用法
  • Nona生命之树作品TRO突袭，冻结名单曝光
  • Vue2.x核心技术与实战(一)
  • 摩搭api 实现
  • 025 理解文件系统
  • 多机编队——（6）解决机器人跟踪过程中mpc控制转圈问题
  • 第四章 Linux实用操作
  • OpenJDK 17的C1和C2编译器实现中，方法返回前插入安全点（Safepoint Poll）的机制
  • 【LeetCode题解】LeetCode 35. 搜索插入位置
  • [Linux] Linux逻辑卷管理
  • 知识点汇总linuxC高级 -2系统命令压缩与链接
  • RK3568 NPU RKNN（三）：RKNN-ToolKit2模型构建与推理
  • 【LeetCode】算法详解#13 ---回文链表
  • Vue 3.5重磅更新：响应式Props解构，让组件开发更简洁高效
  • [Linux] Linux交换空间管理 Linux系统启动原理
  • 慧穗云开放平台 CDK 开票对接
  • echart中x的0位置出现柱子宽度被裁掉一部分的问题
  • 技术日记2025年08月16日
  • 基于FPGA的实时图像处理系统（1）——SDRAM回环测试
  • python---异常处理