当前位置:网站首页>Nacos 配置中心整体设计原理分析(持久化,集群,信息同步)
Nacos 配置中心整体设计原理分析(持久化,集群,信息同步)
2022-07-02 03:41:00 【、楽.】
1. Nacos的配置中心功能设计
本文主要描述Nacos配置中心功能的相关设计,首先Nacos配置中心具有以下几点核心功能:
- 持久化存储
- 客户端远程访问Nacos-server的配置数据
- 客户端配置的动态刷新,以及Nacos-server配置变更的通知
- 客户端本地缓存
2. 持久化
默认存储至自带的derby数据库
我们在nacos目录中的data目录下可以发现该文件夹,数据默认存储在这里的。
我们也可以将存储切换到Mysql中
那我们应该如何将数据存储到Mysql中呢?
我们可以到conf目录下修改
application.properties
文件中的相关信息:如果需要使用Mysql,我们只需要打开这些配置信息即可,注意修改mysql连接地址等信息。
相关配置信息修改完成后,我们需要到数据库中创建相关数据库,在conf文件夹中也给出了
nacos-mysql.sql
文件。/* * 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. */ /******************************************/ /* 数据库全名 = nacos_config */ /* 表名称 = config_info */ /******************************************/ CREATE TABLE `config_info` ( `id` bigint(20) NOT NULL AUTO_INCREMENT COMMENT 'id', `data_id` varchar(255) NOT NULL COMMENT 'data_id', `group_id` varchar(255) DEFAULT NULL, `content` longtext NOT NULL COMMENT 'content', `md5` varchar(32) DEFAULT NULL COMMENT 'md5', `gmt_create` datetime NOT NULL DEFAULT CURRENT_TIMESTAMP COMMENT '创建时间', `gmt_modified` datetime NOT NULL DEFAULT CURRENT_TIMESTAMP COMMENT '修改时间', `src_user` text COMMENT 'source user', `src_ip` varchar(50) DEFAULT NULL COMMENT 'source ip', `app_name` varchar(128) DEFAULT NULL, `tenant_id` varchar(128) DEFAULT '' COMMENT '租户字段', `c_desc` varchar(256) DEFAULT NULL, `c_use` varchar(64) DEFAULT NULL, `effect` varchar(64) DEFAULT NULL, `type` varchar(64) DEFAULT NULL, `c_schema` text, PRIMARY KEY (`id`), UNIQUE KEY `uk_configinfo_datagrouptenant` (`data_id`,`group_id`,`tenant_id`) ) ENGINE=InnoDB DEFAULT CHARSET=utf8 COLLATE=utf8_bin COMMENT='config_info'; /******************************************/ /* 数据库全名 = nacos_config */ /* 表名称 = config_info_aggr */ /******************************************/ CREATE TABLE `config_info_aggr` ( `id` bigint(20) NOT NULL AUTO_INCREMENT COMMENT 'id', `data_id` varchar(255) NOT NULL COMMENT 'data_id', `group_id` varchar(255) NOT NULL COMMENT 'group_id', `datum_id` varchar(255) NOT NULL COMMENT 'datum_id', `content` longtext NOT NULL COMMENT '内容', `gmt_modified` datetime NOT NULL COMMENT '修改时间', `app_name` varchar(128) DEFAULT NULL, `tenant_id` varchar(128) DEFAULT '' COMMENT '租户字段', PRIMARY KEY (`id`), UNIQUE KEY `uk_configinfoaggr_datagrouptenantdatum` (`data_id`,`group_id`,`tenant_id`,`datum_id`) ) ENGINE=InnoDB DEFAULT CHARSET=utf8 COLLATE=utf8_bin COMMENT='增加租户字段'; /******************************************/ /* 数据库全名 = nacos_config */ /* 表名称 = config_info_beta */ /******************************************/ CREATE TABLE `config_info_beta` ( `id` bigint(20) NOT NULL AUTO_INCREMENT COMMENT 'id', `data_id` varchar(255) NOT NULL COMMENT 'data_id', `group_id` varchar(128) NOT NULL COMMENT 'group_id', `app_name` varchar(128) DEFAULT NULL COMMENT 'app_name', `content` longtext NOT NULL COMMENT 'content', `beta_ips` varchar(1024) DEFAULT NULL COMMENT 'betaIps', `md5` varchar(32) DEFAULT NULL COMMENT 'md5', `gmt_create` datetime NOT NULL DEFAULT CURRENT_TIMESTAMP COMMENT '创建时间', `gmt_modified` datetime NOT NULL DEFAULT CURRENT_TIMESTAMP COMMENT '修改时间', `src_user` text COMMENT 'source user', `src_ip` varchar(50) DEFAULT NULL COMMENT 'source ip', `tenant_id` varchar(128) DEFAULT '' COMMENT '租户字段', PRIMARY KEY (`id`), UNIQUE KEY `uk_configinfobeta_datagrouptenant` (`data_id`,`group_id`,`tenant_id`) ) ENGINE=InnoDB DEFAULT CHARSET=utf8 COLLATE=utf8_bin COMMENT='config_info_beta'; /******************************************/ /* 数据库全名 = nacos_config */ /* 表名称 = config_info_tag */ /******************************************/ CREATE TABLE `config_info_tag` ( `id` bigint(20) NOT NULL AUTO_INCREMENT COMMENT 'id', `data_id` varchar(255) NOT NULL COMMENT 'data_id', `group_id` varchar(128) NOT NULL COMMENT 'group_id', `tenant_id` varchar(128) DEFAULT '' COMMENT 'tenant_id', `tag_id` varchar(128) NOT NULL COMMENT 'tag_id', `app_name` varchar(128) DEFAULT NULL COMMENT 'app_name', `content` longtext NOT NULL COMMENT 'content', `md5` varchar(32) DEFAULT NULL COMMENT 'md5', `gmt_create` datetime NOT NULL DEFAULT CURRENT_TIMESTAMP COMMENT '创建时间', `gmt_modified` datetime NOT NULL DEFAULT CURRENT_TIMESTAMP COMMENT '修改时间', `src_user` text COMMENT 'source user', `src_ip` varchar(50) DEFAULT NULL COMMENT 'source ip', PRIMARY KEY (`id`), UNIQUE KEY `uk_configinfotag_datagrouptenanttag` (`data_id`,`group_id`,`tenant_id`,`tag_id`) ) ENGINE=InnoDB DEFAULT CHARSET=utf8 COLLATE=utf8_bin COMMENT='config_info_tag'; /******************************************/ /* 数据库全名 = nacos_config */ /* 表名称 = config_tags_relation */ /******************************************/ CREATE TABLE `config_tags_relation` ( `id` bigint(20) NOT NULL COMMENT 'id', `tag_name` varchar(128) NOT NULL COMMENT 'tag_name', `tag_type` varchar(64) DEFAULT NULL COMMENT 'tag_type', `data_id` varchar(255) NOT NULL COMMENT 'data_id', `group_id` varchar(128) NOT NULL COMMENT 'group_id', `tenant_id` varchar(128) DEFAULT '' COMMENT 'tenant_id', `nid` bigint(20) NOT NULL AUTO_INCREMENT, PRIMARY KEY (`nid`), UNIQUE KEY `uk_configtagrelation_configidtag` (`id`,`tag_name`,`tag_type`), KEY `idx_tenant_id` (`tenant_id`) ) ENGINE=InnoDB DEFAULT CHARSET=utf8 COLLATE=utf8_bin COMMENT='config_tag_relation'; /******************************************/ /* 数据库全名 = nacos_config */ /* 表名称 = group_capacity */ /******************************************/ CREATE TABLE `group_capacity` ( `id` bigint(20) unsigned NOT NULL AUTO_INCREMENT COMMENT '主键ID', `group_id` varchar(128) NOT NULL DEFAULT '' COMMENT 'Group ID,空字符表示整个集群', `quota` int(10) unsigned NOT NULL DEFAULT '0' COMMENT '配额,0表示使用默认值', `usage` int(10) unsigned NOT NULL DEFAULT '0' COMMENT '使用量', `max_size` int(10) unsigned NOT NULL DEFAULT '0' COMMENT '单个配置大小上限,单位为字节,0表示使用默认值', `max_aggr_count` int(10) unsigned NOT NULL DEFAULT '0' COMMENT '聚合子配置最大个数,,0表示使用默认值', `max_aggr_size` int(10) unsigned NOT NULL DEFAULT '0' COMMENT '单个聚合数据的子配置大小上限,单位为字节,0表示使用默认值', `max_history_count` int(10) unsigned NOT NULL DEFAULT '0' COMMENT '最大变更历史数量', `gmt_create` datetime NOT NULL DEFAULT CURRENT_TIMESTAMP COMMENT '创建时间', `gmt_modified` datetime NOT NULL DEFAULT CURRENT_TIMESTAMP COMMENT '修改时间', PRIMARY KEY (`id`), UNIQUE KEY `uk_group_id` (`group_id`) ) ENGINE=InnoDB DEFAULT CHARSET=utf8 COLLATE=utf8_bin COMMENT='集群、各Group容量信息表'; /******************************************/ /* 数据库全名 = nacos_config */ /* 表名称 = his_config_info */ /******************************************/ CREATE TABLE `his_config_info` ( `id` bigint(64) unsigned NOT NULL, `nid` bigint(20) unsigned NOT NULL AUTO_INCREMENT, `data_id` varchar(255) NOT NULL, `group_id` varchar(128) NOT NULL, `app_name` varchar(128) DEFAULT NULL COMMENT 'app_name', `content` longtext NOT NULL, `md5` varchar(32) DEFAULT NULL, `gmt_create` datetime NOT NULL DEFAULT CURRENT_TIMESTAMP, `gmt_modified` datetime NOT NULL DEFAULT CURRENT_TIMESTAMP, `src_user` text, `src_ip` varchar(50) DEFAULT NULL, `op_type` char(10) DEFAULT NULL, `tenant_id` varchar(128) DEFAULT '' COMMENT '租户字段', PRIMARY KEY (`nid`), KEY `idx_gmt_create` (`gmt_create`), KEY `idx_gmt_modified` (`gmt_modified`), KEY `idx_did` (`data_id`) ) ENGINE=InnoDB DEFAULT CHARSET=utf8 COLLATE=utf8_bin COMMENT='多租户改造'; /******************************************/ /* 数据库全名 = nacos_config */ /* 表名称 = tenant_capacity */ /******************************************/ CREATE TABLE `tenant_capacity` ( `id` bigint(20) unsigned NOT NULL AUTO_INCREMENT COMMENT '主键ID', `tenant_id` varchar(128) NOT NULL DEFAULT '' COMMENT 'Tenant ID', `quota` int(10) unsigned NOT NULL DEFAULT '0' COMMENT '配额,0表示使用默认值', `usage` int(10) unsigned NOT NULL DEFAULT '0' COMMENT '使用量', `max_size` int(10) unsigned NOT NULL DEFAULT '0' COMMENT '单个配置大小上限,单位为字节,0表示使用默认值', `max_aggr_count` int(10) unsigned NOT NULL DEFAULT '0' COMMENT '聚合子配置最大个数', `max_aggr_size` int(10) unsigned NOT NULL DEFAULT '0' COMMENT '单个聚合数据的子配置大小上限,单位为字节,0表示使用默认值', `max_history_count` int(10) unsigned NOT NULL DEFAULT '0' COMMENT '最大变更历史数量', `gmt_create` datetime NOT NULL DEFAULT CURRENT_TIMESTAMP COMMENT '创建时间', `gmt_modified` datetime NOT NULL DEFAULT CURRENT_TIMESTAMP COMMENT '修改时间', PRIMARY KEY (`id`), UNIQUE KEY `uk_tenant_id` (`tenant_id`) ) ENGINE=InnoDB DEFAULT CHARSET=utf8 COLLATE=utf8_bin COMMENT='租户容量信息表'; CREATE TABLE `tenant_info` ( `id` bigint(20) NOT NULL AUTO_INCREMENT COMMENT 'id', `kp` varchar(128) NOT NULL COMMENT 'kp', `tenant_id` varchar(128) default '' COMMENT 'tenant_id', `tenant_name` varchar(128) default '' COMMENT 'tenant_name', `tenant_desc` varchar(256) DEFAULT NULL COMMENT 'tenant_desc', `create_source` varchar(32) DEFAULT NULL COMMENT 'create_source', `gmt_create` bigint(20) NOT NULL COMMENT '创建时间', `gmt_modified` bigint(20) NOT NULL COMMENT '修改时间', PRIMARY KEY (`id`), UNIQUE KEY `uk_tenant_info_kptenantid` (`kp`,`tenant_id`), KEY `idx_tenant_id` (`tenant_id`) ) ENGINE=InnoDB DEFAULT CHARSET=utf8 COLLATE=utf8_bin COMMENT='tenant_info'; CREATE TABLE `users` ( `username` varchar(50) NOT NULL PRIMARY KEY, `password` varchar(500) NOT NULL, `enabled` boolean NOT NULL ); CREATE TABLE `roles` ( `username` varchar(50) NOT NULL, `role` varchar(50) NOT NULL, UNIQUE INDEX `idx_user_role` (`username` ASC, `role` ASC) USING BTREE ); CREATE TABLE `permissions` ( `role` varchar(50) NOT NULL, `resource` varchar(255) NOT NULL, `action` varchar(8) NOT NULL, UNIQUE INDEX `uk_role_permission` (`role`,`resource`,`action`) USING BTREE ); INSERT INTO users (username, password, enabled) VALUES ('nacos', '$2a$10$EuWPZHzz32dJN7jexM34MOeYirDdFAZm2kuWj7VEOJhhZkDrxfvUu', TRUE); INSERT INTO roles (username, role) VALUES ('nacos', 'ROLE_ADMIN');
处理完成后,我们启动nacos,创建相关配置信息,然后至数据库中查看。可以发现现在已经使用mysql作为持久化了。
3. 配置信息的同步
配置信息的同步意义在于当我们的配置信息发生变化后,需要通知到各个节点。
同步的方式之前稍微提到过,无非就是两种方式:
push (服务端主动push)
客户端和服务端之间会保持一个连接,由客户端发送心跳,服务端感知。所以当数据变化的时候,服务端可以直接通过socket发送通知。
pull (客户端轮询获取)
客户端的定时任务每隔几秒去拉取一次数据
而我们的nacos却是使用的long pull(长轮询)
的方式。
什么是长轮询呢?相对于短轮询来说,我发起请求后并不会立马结束,这个会话会一直保持,所以当服务端数据变化后直接往管道中回写数据即可。
它的整个实现机制如下所示:
客户端每隔一段时间会发起一个请求到服务端,服务端收到请求后不会立马返回,而是会将请求放到一个队列中,这个队列保存的是所有向服务端获取配置变更事件的客户端的请求会话。
当我们的控制台修改配置信息后,会触发配置更新事件,然后会对队列中的请求进行轮询。
这个长轮询并不是一直保持的,超过30秒之后就会自动断开。
以上便是长轮询去完成事件动态更新的方式,从而使得客户端能够动态感知配置的变化。
4. Nacos配置中心集群
为了保证高可用,我们肯定需要对其搭建集群。接下来我们简单了解一下:
Nacos配置中心的集群和我们之前搭建的集群不太一样,他没有主从之分,因为我们知道,nacos的数据都是存储在数据库中的,所以我们不需要确保他的数据一致性;如果为了确保数据不会丢失,那就是mysql层面的主备搭建了;但nacos也不仅仅只有这样,在每个nacos节点和mysql之间还有一层磁盘缓存,在启动的时候会先从数据库获取数据缓存到磁盘中,同时他还有一个定时任务,每隔6小时将数据库中的全量数据更新到磁盘中。所以当我们的客户端从nacos中获取数据的时候,nacos是直接从磁盘获取的,这样可以提升一定的性能。
那如果我们的数据发生变化之后呢?这种无中心化的集群怎么同步数据呢?
当客户端更新数据到某个节点后,该nacos节点会找到集群中的其他节点,广播一个数据同步的事件,收到事件的nacos节点会从数据库拿取数据同步到缓存(注意是增量,而不是全量)。数据更新顺序是先更新数据库在更新磁盘。
了解大致原理后,我们该如何搭建集群呢?
这里主要说的是配置中心的集群搭建,如果是注册中心集群搭建的话那就至少3个节点,因为注册中心集群使用到了raft算法,和这里不太一样。
集群的搭建只需要如下两步即可:
3个节点
直接复制三份即可,在
application
文件中修改端口号。修改
conf
目录下的cluster.conf
文件将
cluster.conf.example
文件复制并修改名字即可,然后在里面添加三个节点的地址和端口号。启动方式
直接默认启动即可,不需要使用单节点模式
边栏推荐
- MySQL advanced (Advanced) SQL statement (II)
- Set vscode. When double clicking, the selected string includes the $symbol - convenient for PHP operation
- Oracle 常用SQL
- 初识string+简单用法(二)
- Didi open source Delta: AI developers can easily train natural language models
- Retrofit's callback hell is really vulnerable in kotlin synergy mode
- Detailed explanation of ThreadLocal
- Fourier series
- Kotlin基础学习 16
- [untitled] basic operation of raspberry pie (2)
猜你喜欢
蓝桥杯单片机省赛第九届
【直播回顾】战码先锋首期8节直播完美落幕,下期敬请期待!
The 9th Blue Bridge Cup single chip microcomputer provincial competition
[HCIA continuous update] overview of dynamic routing protocol
[designmode] builder model
汇率的查询接口
蓝桥杯单片机省赛第五届
MySQL index, transaction and storage engine
滴滴开源DELTA:AI开发者可轻松训练自然语言模型
0 foundation how to learn automated testing? Follow these seven steps step by step and you will succeed
随机推荐
[mv-3d] - multi view 3D target detection network
Generate random numbers that obey normal distribution
Kotlin基础学习 15
蓝桥杯单片机省赛第十一届第二场
蓝桥杯单片机省赛第五届
[database]jdbc
Detailed explanation of ThreadLocal
Global and Chinese market of X-ray detectors 2022-2028: Research Report on technology, participants, trends, market size and share
The 8th Blue Bridge Cup single chip microcomputer provincial competition
aaaaaaaaaaaaa
Yan Rong looks at how to formulate a multi cloud strategy in the era of hybrid cloud
< job search> process and signal
Knowing things by learning | self supervised learning helps improve the effect of content risk control
焱融看 | 混合雲時代下,如何制定多雲策略
0 foundation how to learn automated testing? Follow these seven steps step by step and you will succeed
蓝桥杯单片机省赛第十一届第一场
MySQL advanced (Advanced) SQL statement (II)
[personal notes] PHP common functions - custom functions
How to establish its own NFT market platform in 2022
【人员密度检测】基于形态学处理和GRNN网络的人员密度检测matlab仿真