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

png素材网站,博客园和wordpress,wordpress博客非插件,海外教育集团网站建设1、概述 Apache ShardingSphere 是一款分布式的数据库生态系统#xff0c; 可以将任意数据库转换为分布式数据库#xff0c;并通过数据分片、弹性伸缩、加密等能力对原有数据库进行增强。 Apache ShardingSphere 设计哲学为 Database Plus#xff0c;旨在构建异构数据库上… 1、概述 Apache ShardingSphere 是一款分布式的数据库生态系统 可以将任意数据库转换为分布式数据库并通过数据分片、弹性伸缩、加密等能力对原有数据库进行增强。 Apache ShardingSphere 设计哲学为 Database Plus旨在构建异构数据库上层的标准和生态。 它关注如何充分合理地利用数据库的计算和存储能力而并非实现一个全新的数据库。 它站在数据库的上层视角关注它们之间的协作多于数据库自身。 ShardingShpere的两个核心模块 ShardingSphere-JDBCShardingSphere-JDBC 定位为轻量级 Java 框架在 Java 的 JDBC 层提供的额外服务。ShardingSphere-ProxyShardingSphere-Proxy 定位为透明化的数据库代理端通过实现数据库二进制协议对异构语言提供支持。 在开发中实现分库分表的操作我们一般使用的ShardingSphere-JDBC这个模块。 具体详情请参考官网https://shardingsphere.apache.org/document/current/cn/overview/ 说实话看这个官网需要一定的编码功底懂的都懂。 ShardingSphere的分库分表操作的逻辑图 开发者配置了分库分表策略后我们只需要操作逻辑表名就可以了。 2、数据分片带来的优缺点 数据分片主要是用来解决海量的数据访问的问题将数据库采用垂直拆分或者水平拆分的方式将海量、复杂的数据分布到不同的数据库、数据表中以此来实现专库专用、提高访问性能。 优点 提高可扩展性通过将数据拆分成多个小型数据库每个数据库仅处理一部分数据可以在数据增长时动态地添加新的分片从而提高整个系统的可扩展性。提升性能分片后的每个小型数据库只处理部分数据减轻了单个节点的压力从而提升了整个系统的性能。 缺点 复杂性增加数据分片意味着需要更多的数据库来存储和管理数据这增加了系统的复杂性。同时对于每个查询可能需要跨多个数据库进行查找增加了查询的复杂性。并发控制在分布式系统中并发控制是一个重要的问题。如果多个节点同时更新同一片数据就可能导致数据不一致的问题。因此需要采用并发控制技术来保证数据的正确性。数据迁移和恢复当新增或删除分片时需要进行数据迁移和恢复。这个过程可能会导致数据的不一致或丢失。因此需要设计合理的迁移和恢复策略来保证数据的正确性。 我们所使用ShardingSphere组件通过配置Yaml文件来降低我们的编码复杂度。并发控制何数据迁移与恢复都是需要其他的方式来解决。 3、ShardingSphere分表操作 ShardingSphere的分库分表操作都是基于ShardingSphere-JDBC这个模块来实现。在当前开发中一般都需要和Springboot进行整合而且只要是流行的框架、组件SpringBoot一般都会有一个集成的依赖。 3.1、依赖 当前JDK已经到了21当然我这里使用的还是JDK17因为JDK21对于SpringBoot 3.1 以下的版本都不友好会出现一个错误所以今年刚出的JDK21可以作为爱好先了解毕竟刚出来很多东西都还需要完善。 dependencygroupIdorg.apache.shardingsphere/groupIdartifactIdshardingsphere-jdbc-core-spring-boot-starter/artifactIdversion5.1.1/version /dependencydependencygroupIdorg.springframework.boot/groupIdartifactIdspring-boot-starter-web/artifactIdversion2.7.14/version /dependencydependencygroupIdcom.baomidou/groupIdartifactIdmybatis-plus-boot-starter/artifactIdversion3.5.4.1/version /dependency3.2、操作方式一Yaml文件配置 在引入了ShardingSphere-JDBC模块后可以通过YAML文件配置的方式轻松的配置分表操作。 spring:shardingsphere:props:sql-show: true # 是否展示ShardingSphere的SQL日志datasource: # 配置数据源ds0:username: rootpassword: 123456url: jdbc:mysql://127.0.0.1:3306/mysqltest?serverTimezoneAsia/Shanghaitype: com.zaxxer.hikari.HikariDataSource # 这个参数是必须要有的否则会报错。driver-class-name: com.mysql.cj.jdbc.Drivernames: ds0 # 所有数据源的名称用逗号隔开rules: # ShardingSphere规则sharding:sharding-algorithms: # 分片算法配置table-inline: # 分片算法名称自定义的名称type: INLINE # 分片算法类型props: # 分片算法属性配置algorithm-expression: test\(-{id % 2} # 分片规则指定语句tables: # 分片表配置logic_table_name: # 自定义的逻辑表名称actual-data-nodes: ds0.test_0, ds0.test_1 # 真实的表名称数据源.表名称多个表之间用逗号隔开也支持表达式ds0.test_\)-{0..1}table-strategy: # 表分片策略standard: # 标准分片策略sharding-column: id # 分片的列名sharding-algorithm-name: table-inline # 分片算法mode:type: Memory # 运行模式类型。可选配置内存模式 Memory、单机模式 Standalone、集群模式 Clusterrepository:type: JDBC在YAML文件中通过rules.sharding.sharding-algorithms属性来配置数据分片的分片方式比如说test_\(-{id % 2}这个就是按照奇偶的方式对数据进行划分数据。 在rules.sharding.sharding-algorithms.type参数主要用于指定分片算法的类型。以下是一些常见的 type 选项 参数名称参数描述inline行表达式分片算法。该算法允许你使用行表达式来定义分片规则适用于简单的分片场景。hintHint 分片算法。该算法允许你使用 Hint 来指定分片规则适用于一些特殊的分片场景。mod_sharding取模分片算法。根据指定的分片数量进行取模运算来进行分片例如 user_id % 8range_sharding范围分片算法。允许你定义一个范围来进行分片适用于范围查询等场景。hash_sharding哈希分片算法。根据指定的哈希算法进行分片适用于一些需要一致性哈希的场景。 rules.sharding.tables.logic_table_name.table-strategy参数用来配置表分片的策略可配置的属性如下 1、standard标准分片策略。 参数名称参数描述sharding-column分片列名称precise-algorithm-class-name精确分片算法类名称用于 和 IN 查询。range-algorithm-class-name范围分片算法类名称用于 BETWEEN 查询。 2、complex复合分片策略。 参数名称参数描述sharding-columns分片列名称列表多个列以逗号分隔。algorithm-class-name复合分片算法类名称。 3、inline行表达式分片策略。 参数名称参数描述sharding-column分片列名称。algorithm-expression分片算法行表达式例如\){column} % 2。 4、hintHint 分片策略。 参数名称参数描述algorithm-class-nameHint分片算法类名称。 3.3、操作方式二自定义分片算法 使用YAML文件的配置只能用于简单的分表配置像test_0test_1这种简单的而像某些表名不同的复杂分表操作就不方便使用YAML的配置方式了此时就需要使用自定义分片策略。 3.3.1、实现StandardShardingAlgorithm接口 自定义分表策略需要实现StandardShardingAlgorithm接口。通过doSharding方法来返回要操作的真实表名。 public class TestShardingAlgorithm implements StandardShardingAlgorithmInteger {private static Object[] TABLE_NAME_LIST null;/*** 实现精确分片* param collection yaml中定义的真实的表名列表* param preciseShardingValue 分片的信息* 1、getColumnName(): 获取分片策略中的sharding-column参数的值* 2、getValue(): sharding-column参数所对应类的值* return 真正需要执行的表名*/Overridepublic String doSharding(CollectionString collection, PreciseShardingValueInteger preciseShardingValue) {if(TABLE_NAME_LIST null){TABLE_NAME_LIST collection.toArray();}int index preciseShardingValue.getValue() % TABLE_NAME_LIST.length;return (String) TABLE_NAME_LIST[index];}// 实现范围分片Overridepublic CollectionString doSharding(CollectionString collection, RangeShardingValueInteger rangeShardingValue) {return collection;}Overridepublic void init() {// 进行初始化的配置}// 分片策略的 keyOverridepublic String getType() {return TestShardingAlgorithm;} }在单体系统中doSharding和getType两个方法是必须要编写的ShardingSphere会根据这两个方法来调用分表策略。 我们也可以使用这种方式来实现动态分表策略将需要分表的表名存放在一张表中每次的操作都会进行数据库的访问来确定需要操作的表。存储媒介不光是数据库还可以是Nacos、Zookeeper等。 3.3.2、配置Yaml文件 spring:shardingsphere:props:sql-show: truedatasource:ds0:username: rootpassword: 123456url: jdbc:mysql://127.0.0.1:3306/mysql_test?serverTimezoneAsia/Shanghaitype: com.zaxxer.hikari.HikariDataSourcedriver-class-name: com.mysql.cj.jdbc.Drivernames: ds0rules:sharding:sharding-algorithms:table-inline:type: TestShardingAlgorithmprops:algorithm-class-name: com.tt.shardingpheredemo.config.TestShardingAlgorithmtables:t_user:actual-data-nodes: ds0.test_0, ds0.test_1# 分表策略table-strategy:standard:sharding-column: idsharding-algorithm-name: table-inlinemode:type: Memoryrepository:type: JDBCmain:banner-mode: off自定义分片策略的引入需要修改rules.sharding.sharding-algorithms参数中的type和props.algorithm-class-name两个参数。 type参数的值一定要是自定义策略类中的getType()返回值。 3.3.3、配置分片类载入文件 当我们完成上述的操作后按照逻辑来说是没问题了的但是世事有例外启动项目的时候直接报错 No implementation class load from SPI org.apache.shardingsphere.sharding.spi.ShardingAlgorithm with type TestShardingAlgorithm.如果type这个参数不是和getType()方法的值一致也会报这个错误。 报这个错误的原因是TestShardingAlgorithm这个类没有被加载进程序ShardingSphere的底层基于Java SPI机制。 我们不妨来看看StandardShardingAlgorithm其他的实现类是如何实现的。 StandardShardingAlgorithm的实现类还是不少的其中就有上面说的几种分片策略。 在ShardingSphere的源码中我们看到这几种分片策略都不是通过SpringBoot的注入方式来加载入项目的而是通过SPI机制来加载入项目在源码中有一个org.apache.shardingsphere.sharding.spi.ShardingAlgorithm文件这个文件存放着ShardingSphere所提供的分片策略方式。 #

Licensed to the Apache Software Foundation (ASF) under one or more

contributor license agreements. See the NOTICE file distributed with

this work for additional information regarding copyright ownership.

The ASF licenses this file to You 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.

#org.apache.shardingsphere.sharding.algorithm.sharding.inline.InlineShardingAlgorithm org.apache.shardingsphere.sharding.algorithm.sharding.mod.ModShardingAlgorithm org.apache.shardingsphere.sharding.algorithm.sharding.mod.HashModShardingAlgorithm org.apache.shardingsphere.sharding.algorithm.sharding.range.VolumeBasedRangeShardingAlgorithm org.apache.shardingsphere.sharding.algorithm.sharding.range.BoundaryBasedRangeShardingAlgorithm org.apache.shardingsphere.sharding.algorithm.sharding.datetime.AutoIntervalShardingAlgorithm org.apache.shardingsphere.sharding.algorithm.sharding.datetime.IntervalShardingAlgorithm org.apache.shardingsphere.sharding.algorithm.sharding.classbased.ClassBasedShardingAlgorithm org.apache.shardingsphere.sharding.algorithm.sharding.complex.ComplexInlineShardingAlgorithm org.apache.shardingsphere.sharding.algorithm.sharding.hint.HintInlineShardingAlgorithm org.apache.shardingsphere.sharding.algorithm.sharding.cosid.CosIdModShardingAlgorithm org.apache.shardingsphere.sharding.algorithm.sharding.cosid.CosIdIntervalShardingAlgorithm org.apache.shardingsphere.sharding.algorithm.sharding.cosid.CosIdSnowflakeIntervalShardingAlgorithm所以我们想要使用自定义的分片策略那么就要使用源码中的方式将自定义的分片策略类加载入系统使用Spring Boot的Component方式是没有用的。 我们需要在项目的resources目录下创建一个同名的properties文件来存放自定义的分片策略类的全限定名。 org.apache.shardingsphere.sharding.spi.ShardingAlgorithm文件一定要在META_INF.services目录下因为源码中的文件就在这个目录下。 3.4、测试 3.4.1、实体类配置 因为系统中集成了Mybatis-plus这个组件所以在编码上也会轻松很多Dao层、Service层都和日常开发一样的唯一不同的就是Entity上。 Data AllArgsConstructor NoArgsConstructor TableName(value logic_table_name) public class Test{TableId(type IdType.AUTO)private int id;private String testName;private int abc;}实体类的主要不同就在于TableName的value值。 value值不再指向的是数据库中的真实表名而是指向ShardingSphere配置中的逻辑表名。
3.4.2、数据库 两张表test_1和test_1。 CREATE TABLE test_0 (id int NOT NULL AUTO_INCREMENT,test_name varchar(255) NOT NULL,abc int NOT NULL,PRIMARY KEY (id) ) ENGINEInnoDB AUTO_INCREMENT10 DEFAULT CHARSETutf8mb4 COLLATEutf8mb4_0900_ai_ci;CREATE TABLE test_1 (id int NOT NULL AUTO_INCREMENT,test_name varchar(255) NOT NULL,abc int NOT NULL,PRIMARY KEY (id) ) ENGINEInnoDB AUTO_INCREMENT10 DEFAULT CHARSETutf8mb4 COLLATEutf8mb4_0900_ai_ci;3.4.3、测试结果 本次测试采用奇偶分片策略分片键为id。 test_0表中存放了id为偶数的数据test_1表中存放了id为奇数的数据。 4、总结 ShardingSphere虽然支持市面上大部分的分库分表方式也是市面上当前最火的分库分表组件之一但是 ShardingSphere的配置相对复杂需要用户具备一定的数据库和中间件知识。配置过程中需要考虑分片键的选择、分片算法的设计、数据的迁移等因素这些都需要用户进行深入的思考和规划。学习成本高由于ShardingSphere是一个相对复杂的系统用户需要花费一定的时间和精力来学习它的原理、配置和使用方法。这对于一些新手来说可能是一个挑战。