我们先来回顾下前面的章节:
前面5篇我们大概知道了Nacos的常见的一些用法,都是围绕它作为服务的注册中心和配置中心来展开,本篇我们来看Nacos的另外一层面纱,那就是数据的持久化过程,该过程很简单,接下来我们来看过程.
数据持久化
我们之前所有的学习过程中都是以Nacos的单机模式来完成,通过官方文档可以发现,在单机模式环境下,是采用嵌入式的数据库来实现数据的存储过程,究竟如何存储的过程,我们是无法直接查看,在之后的版本中可以使用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管理台的登录时的用户名和密码.
- 到这里我们的数据持久化的过程也就讲完了,哈哈哈不用写一行代码,当然你有可以通过接口来测试的,这里我就不写了,肯定行的....
网友评论