nacos适配达梦、人大金仓数据库

您所在的位置：网站首页 › 国产化适配中心 › nacos适配达梦、人大金仓数据库

nacos适配达梦、人大金仓数据库

2023-09-03 03:39| 来源: 网络整理| 查看: 265

准备工作 1、下载nacos源码、编译，官网更详细

https://nacos.io/zh-cn/docs/quick-start.html

2、下载源码，按官网更详细

git地址：https://github.com/alibaba/nacos.git

3、下载达梦、人大金仓数据库驱动

我下载的是：Dm、Kingbase依赖

dm: https://download.csdn.net/download/qq_24101357/20677620 kingbase: https://download.csdn.net/download/qq_24101357/20677646

修改nacos源码引入达梦数据库驱动依赖

nacos-all的pom.xml

1.8 8.2.0 com.dameng Dm8JdbcDriver18 ${dm-connector-java.version} com.kingbase kingbase8 ${kingbase-connector-java.version}

nacos-config的pom.xml

com.dameng Dm8JdbcDriver18 com.kingbase kingbase8 修改数据库配置

nacos-console模块的application.properties：

主要修改了：

1、增加了驱动db.jdbcDriverName；

2、spring.datasource.platform=mysql，现在的意思其实是是否使用外置数据库，直接mysql就等于是使用外置数据库，使用什么数据库则由db.jdbcDriverName决定；

#*************** Config Module Related Configurations ***************# #达梦 ### If user MySQL as datasource: spring.datasource.platform=mysql ### Count of DB: db.num=1 db.jdbcDriverName=dm.jdbc.driver.DmDriver ### Connect URL of DB: db.url.0=jdbc:dm://127.0.0.1:5236/NACOS?STU&zeroDateTimeBehavior=convertToNull&useUnicode=true&characterEncoding=utf-8 db.user.0=root db.password.0=root #人大金仓 #spring.datasource.platform=mysql #db.num=1 #db.jdbcDriverName=com.kingbase8.Driver #db.url.0=jdbc:kingbase8://127.0.0.1:54321/nacos #db.user.0=root #db.password.0=root #mysql #spring.datasource.platform=mysql #db.jdbcDriverName=com.mysql.cj.jdbc.Driver #db.num=1 #db.url.0=jdbc:mysql://127.0.0.1:3306/nacos?characterEncoding=utf8&connectTimeout=1000&socketTimeout=3000&autoReconnect=true&useUnicode=true&useSSL=false&serverTimezone=UTC #db.use.0r=root #db.password.0=root 修改的程序

nacos-config模块：

com.alibaba.nacos.config.server.service.datasource.ExternalDataSourceProperties

其实就改了可以通过配置文件指定数据库驱动

/* * Copyright 1999-2018 Alibaba Group Holding Ltd. * * Licensed under the Apache License, Version 2.0 (the "License"); you may not use this file except in compliance with * the License. You may obtain a copy of the License at * * http://www.apache.org/licenses/LICENSE-2.0 * * Unless required by applicable law or agreed to in writing, software distributed under the License is distributed on * an "AS IS" BASIS, WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied. See the License for the * specific language governing permissions and limitations under the License. */ package com.alibaba.nacos.config.server.service.datasource; import static com.alibaba.nacos.common.utils.CollectionUtils.getOrDefault; import java.util.ArrayList; import java.util.List; import java.util.Objects; import java.util.concurrent.TimeUnit; import org.apache.commons.collections.CollectionUtils; import org.springframework.boot.context.properties.bind.Bindable; import org.springframework.boot.context.properties.bind.Binder; import org.springframework.core.env.Environment; import com.google.common.base.Preconditions; import com.zaxxer.hikari.HikariDataSource; /** * Properties of external DataSource * * @author Nacos */ public class ExternalDataSourceProperties{ private static final String JDBC_DRIVER_NAME = "com.mysql.cj.jdbc.Driver"; public static final long CONNECTION_TIMEOUT_MS = 3000L; public static final long VALIDATION_TIMEOUT = 10L; public static final String TEST_QUERY = "SELECT 1 FROM dual"; public static final int DEFAULT_MAX_POOL_SIZE = 20; public static final int DEFAULT_MINIMUM_IDLE = 50; private Integer num; private List url = new ArrayList(); private List user = new ArrayList(); private List password = new ArrayList(); private List maxPoolSize = new ArrayList(); private List minIdle = new ArrayList(); /** * 数据库驱动 * 增加对达梦、人大金仓数据库的支持 */ private String jdbcDriverName; public String getJdbcDriverName() { return jdbcDriverName; } public void setJdbcDriverName(String jdbcDriverName) { this.jdbcDriverName = jdbcDriverName; } public void setNum(Integer num) { this.num = num; } public void setUrl(List url) { this.url = url; } public void setUser(List user) { this.user = user; } public void setPassword(List password) { this.password = password; } public void setMaxPoolSize(List maxPoolSize) { this.maxPoolSize = maxPoolSize; } public void setMinIdle(List minIdle) { this.minIdle = minIdle; } /** * * @param environment * {@link Environment} * @param callback * Callback function when constructing data source * @return List of {@link HikariDataSource} */ List build(Environment environment, Callback callback) { List dataSources = new ArrayList(); Binder.get(environment).bind("db", Bindable.ofInstance(this)); Preconditions.checkArgument(Objects.nonNull(num), "db.num is null"); Preconditions.checkArgument(CollectionUtils.isNotEmpty(user), "db.user or db.user.[index] is null"); Preconditions.checkArgument(CollectionUtils.isNotEmpty(password), "db.password or db.password.[index] is null"); for (int index = 0; index < num; index++) { int currentSize = index + 1; Preconditions.checkArgument(url.size() >= currentSize, "db.url.%s is null", index); HikariDataSource ds = new HikariDataSource(); // ds.setDriverClassName(JDBC_DRIVER_NAME) // 增加对达梦、人大金仓数据库的支持 ds.setDriverClassName(jdbcDriverName); if(StringUtils.isNotEmpty(jdbcDriverName)){ // 增加对达梦、人大金仓数据库的支持 ds.setDriverClassName(jdbcDriverName); }else{ //默认使用mysql驱动 ds.setDriverClassName(JDBC_DRIVER_NAME); } ds.setJdbcUrl(url.get(index).trim()); ds.setUsername(getOrDefault(user, index, user.get(0)).trim()); ds.setPassword(getOrDefault(password, index, password.get(0)).trim()); ds.setConnectionTimeout(CONNECTION_TIMEOUT_MS); ds.setMaximumPoolSize(getOrDefault(maxPoolSize, index, DEFAULT_MAX_POOL_SIZE)); ds.setMinimumIdle(getOrDefault(minIdle, index, DEFAULT_MINIMUM_IDLE)); // Check the connection pool every 10 minutes ds.setValidationTimeout(TimeUnit.MINUTES.toMillis(VALIDATION_TIMEOUT)); ds.setConnectionTestQuery(TEST_QUERY); dataSources.add(ds); callback.accept(ds); } Preconditions.checkArgument(CollectionUtils.isNotEmpty(dataSources), "no datasource available"); return dataSources; } interface Callback { /** * Perform custom logic * @param dataSource */ void accept(DataSource dataSource); } } 重新编译、运行nacos

mvn -Prelease-nacos -Dmaven.test.skip=true clean install -U

或：mvn -Prelease-nacos -Dmaven.test.skip=true -Drat.skip=true clean install -U

或：mvn -Prelease-nacos -Dmaven.test.skip=true -Dcheckstyle.skip=true clean install -U

成功后，编译好的在这里 distribution\target\nacos-server-1.3.0\nacos\bin\startup.cmd

此时，nacos已支持达梦数据库，其实也支持oracle数据库，只要更换驱动就可以

（注：可以查看nacos文件夹，目录里面有一个BUILDING文件中说明）

关于nacos集群

集群和数据库没有关系，业务系统也不需要作任何改变

主要是以下步骤：

1、修改conf/cluster.conf文件，指定参与集群的3个nacos

192.168.4.128:8845 192.168.4.128:8846 192.168.4.128:8847

2、通过nginx代理nacos

upstream nacos { server 192.168.4.128:8845; server 192.168.4.128:8846; server 192.168.4.128:8847; } server { listen 8848; server_name localhost; #charset koi8-r; #access_log logs/host.access.log main; location / { root html; index index.html index.htm; } location /nacos { proxy_pass http://nacos; } error_page 500 502 503 504 /50x.html; location = /50x.html { root html; } }

备注：dm和kingbase，创建数据库时，需要注意用户和模式的问题，当然最好都用public的，减少错误的问题。

dm版本打包好的服务下载：（包含dm达梦，nacos初始化sql脚本） nacos-dm oracle版本打包好的服务下载：（包含oracle，nacos初始化sql脚本） nacos-oracle

【本文地址】

nacos适配达梦、人大金仓数据库

nacos适配达梦、人大金仓数据库

今日新闻

推荐新闻