我们先来回顾下前面的章节:

• 使用Nacos实现服务注册与发现

• Springcloud Alibaba入门系列之客户端调用方式
  

• springcloud Alibaba入门系列之springcloud gateway

• springcloud Alibaba入门系列之Nacos作为配置中心

• springcloud Alibaba入门系列之Nacos配置文件加载顺序

前面5篇我们大概知道了Nacos的常见的一些用法,都是围绕它作为服务的注册中心和配置中心来展开,本篇我们来看Nacos的另外一层面纱,那就是数据的持久化过程,该过程很简单,接下来我们来看过程.

数据持久化

我们之前所有的学习过程中都是以Nacos的单机模式来完成,通过官方文档可以发现,在单机模式环境下,是采用嵌入式的数据库来实现数据的存储过程,究竟如何存储的过程,我们是无法直接查看,在之后的版本中可以使用mysql来替代嵌入式数据库来完成数据的存储过程,便于我们数据的直接查看,具体操作请看文档

• 单机模式支持mysql

这里就不啰嗦了,按照文档的要求:

• mysql的版本为5.6.5+

注意:mysql版本为8.0.16是不支持的,亲测有效,如果你的版本为8.0.16按照文档步骤单机启动服务会报如下问题,错误代码如下:

Caused by: com.mysql.jdbc.exceptions.jdbc4.MySQLNonTransientConnectionException: Could not create connection to database server. Attempted reconnect 3 times. Giving up.
    at sun.reflect.NativeConstructorAccessorImpl.newInstance0(Native Method)
    at sun.reflect.NativeConstructorAccessorImpl.newInstance(NativeConstructorAccessorImpl.java:62)
    at sun.reflect.DelegatingConstructorAccessorImpl.newInstance(DelegatingConstructorAccessorImpl.java:45)
    at java.lang.reflect.Constructor.newInstance(Constructor.java:423)
    at com.mysql.jdbc.Util.handleNewInstance(Util.java:377)
    at com.mysql.jdbc.Util.getInstance(Util.java:360)
    at com.mysql.jdbc.SQLError.createSQLException(SQLError.java:956)
    at com.mysql.jdbc.SQLError.createSQLException(SQLError.java:935)
    at com.mysql.jdbc.SQLError.createSQLException(SQLError.java:924)
    at com.mysql.jdbc.SQLError.createSQLException(SQLError.java:870)
    at com.mysql.jdbc.ConnectionImpl.connectWithRetries(ConnectionImpl.java:2144)
    at com.mysql.jdbc.ConnectionImpl.createNewIO(ConnectionImpl.java:2069)
    at com.mysql.jdbc.ConnectionImpl.<init>(ConnectionImpl.java:790)
    at com.mysql.jdbc.JDBC4Connection.<init>(JDBC4Connection.java:44)
    at sun.reflect.NativeConstructorAccessorImpl.newInstance0(Native Method)
    at sun.reflect.NativeConstructorAccessorImpl.newInstance(NativeConstructorAccessorImpl.java:62)
    at sun.reflect.DelegatingConstructorAccessorImpl.newInstance(DelegatingConstructorAccessorImpl.java:45)
    at java.lang.reflect.Constructor.newInstance(Constructor.java:423)
    at com.mysql.jdbc.Util.handleNewInstance(Util.java:377)
    at com.mysql.jdbc.ConnectionImpl.getInstance(ConnectionImpl.java:395)
    at com.mysql.jdbc.NonRegisteringDriver.connect(NonRegisteringDriver.java:325)
    at org.apache.commons.dbcp.DriverConnectionFactory.createConnection(DriverConnectionFactory.java:38)
    at org.apache.commons.dbcp.PoolableConnectionFactory.makeObject(PoolableConnectionFactory.java:582)
    at org.apache.commons.dbcp.BasicDataSource.validateConnectionFactory(BasicDataSource.java:1556)
    at org.apache.commons.dbcp.BasicDataSource.createPoolableConnectionFactory(BasicDataSource.java:1545)
    ... 15 more
 Caused by: java.lang.NullPointerException
    at com.mysql.jdbc.ConnectionImpl.getServerCharset(ConnectionImpl.java:2983)
    at com.mysql.jdbc.MysqlIO.sendConnectionAttributes(MysqlIO.java:1873)
    at com.mysql.jdbc.MysqlIO.proceedHandshakeWithPluggableAuthentication(MysqlIO.java:1802)
    at com.mysql.jdbc.MysqlIO.doHandshake(MysqlIO.java:1206)
    at com.mysql.jdbc.ConnectionImpl.coreConnect(ConnectionImpl.java:2234)
    at com.mysql.jdbc.ConnectionImpl.connectWithRetries(ConnectionImpl.java:2085)
    ... 29 more

上面代码为其中的一部分,如果不知道如何查看mysql版本的话请看如下SQL:

select  version();

直接在mysql操作工具中如Navicat中执行该语句即可,当然还可以采用别的方法,看个人习惯吧,出现这个问题不要慌,当然有解决办法,请看:

解决数据持久化mysql问题

那就是通过Nacos源码我们自己解决:

• 首先用idea工具下载源码链接如:https://github.com/alibaba/nacos/tree/1.0.0-RC3
• 接着我们来替换源码中的mysql连接驱动,来替换成8.0.16的,代码如下:

        <dependency>
            <groupId>mysql</groupId>
            <artifactId>mysql-connector-java</artifactId>
            <version>8.0.16</version>
        </dependency>

替换的位置为父项目的pom文件,我们会发现它这里的mysql驱动为5.1.34版本

• 接下来我们需要修改项目为naming的com.alibaba.nacos.naming.healthcheck.MysqlHealthCheckProcessor类引入的mysql驱动换成我们自己的,代码如下:

import com.mysql.cj.jdbc.MysqlDataSource;

• 然后我们来修改最后一处,找到consul项目下的 resources/META-INF下 nacos-default.properties这个文件中的db.url,进行修改,修改代码如下:

db.url.0=jdbc:mysql://11.162.196.161:3306/diamond_devtest?serverTimezone=GMT%2B8&characterEncoding=utf8&connectTimeout=1000&socketTimeout=3000&autoReconnect=true
db.url.1=jdbc:mysql://11.163.152.91:3306/diamond_devtest?serverTimezone=GMT%2B8&characterEncoding=utf8&connectTimeout=1000&socketTimeout=3000&autoReconnect=true

为什么要这样替换了,因为mysql8.0之后需要带时区的,到这里还差最后一步,那就是打包项目,直接在idea的Terminal台上执行如下命令:

mvn -Prelease-nacos clean install -U

打包完成之后找到项目根目录下的distribution\target中:

• 首先按照官方的要求配置我们的application.properties,添加如下代码:

db.num=1
db.url.0=jdbc:mysql://127.0.0.1:3306/nacos?serverTimezone=GMT%2B8&characterEncoding=utf8&connectTimeout=1000&socketTimeout=3000&autoReconnect=true
db.user=root
db.password=youknow

由于我这里的连接的库为nacos.所以需要创建一个nacos数据库,然后执行conf目录下的mysql脚本

• 再次启动我们的服务会发现错误解决了,到这里基本上完成了,我们访问nacos管理台如图:

微信截图_20191108213221.png

新建一条配置,如图所示,此时我们来到数据库中查看表config_info中有一条数据就是我们加的,如图:

微信截图_20191108213434.png

同样的在his_config_info中也有对应的一条数据,由此可以看出,该表用来存放所有的历史配置信息的数据,其中有张users表是用来存放nacos管理台的登录时的用户名和密码.

• 到这里我们的数据持久化的过程也就讲完了,哈哈哈不用写一行代码,当然你有可以通过接口来测试的,这里我就不写了,肯定行的....