【死磕Sharding-jdbc】—基于 SSM...
zhangmin
zhangmin 793 0
2019-09-23 14:07
生于文水,岂能不看文水信息港。商务合作QQ:群:483714163
撸了今年阿里、腾讯和美团的面试,我有一个重要发现…….

原文作者:阿飞Javaer
 原文链接:https://www.jianshu.com/p/7b6997c3586d
本篇文章讲解如何在ssm(spring、springmvc、mybatis)结构的程序上集成sharding-jdbc(版本为2.0.3)进行分库分表;
假设分库分表行为如下:

    [*]将auth_user表分到4个库(user_0~user_3)中;
    [*]其他表不进行分库分表,保留在default_db库中;
1. POM配置

以spring配置文件为例,新增如下POM配置:
 io.shardingjdbc sharding-jdbc-core 2.0.3 io.shardingjdbc sharding-jdbc-core-spring-namespace 2.0.32 . 配置数据源

spring-datasource.xml配置所有需要的数据源如下–auth_user分库分表后需要的4个库user_0~user_3,以及不分库分表的默认库default_db:
                                   properties配置文件内容如下:
sj_user_0.driver=com.mysql.jdbc.Driversj_user_0.url=jdbc:mysql://localhost:3306/user_0sj_user_0.username=rootsj_user_0.password=RootAfei_1sj_user_1.driver=com.mysql.jdbc.Driversj_user_1.url=jdbc:mysql://localhost:3306/user_1sj_user_1.username=rootsj_user_1.password=RootAfei_1sj_user_2.driver=com.mysql.jdbc.Driversj_user_2.url=jdbc:mysql://localhost:3306/user_2sj_user_2.username=rootsj_user_2.password=RootAfei_1sj_user_3.driver=com.mysql.jdbc.Driversj_user_3.url=jdbc:mysql://localhost:3306/user_3sj_user_3.username=rootsj_user_3.password=RootAfei_1sj_default.driver=com.mysql.jdbc.Driversj_default.url=jdbc:mysql://localhost:3306/default_dbsj_default.username=rootsj_default.password=RootAfei_13. 集成sharding数据源

spring-sharding.xml配置如下:
              true 2            
说明:spring-sharding.xml配置的分库分表规则:auth_user表分到id为sj_ds_${0..3}的四个库中,表名保持不变;其他表在id为sj_ds_default库中,不分库也不分表;集成sharding-jdbc的核心就是将SqlSessionFactoryBean需要的dataSource属性修改为shardingDataSource,把数据源交给sharding-jdbc处理;
另外,通过对比这里和sharding-jdbc1.5.4.1版本的配置请戳链接:[url]https://www.jianshu.com/p/602e24845ed3[/url],差异还是比较大,大概提现在如下一些地方:

    [*]namespace由rdb改为sharding;
    [*]默认数据库策略和默认表策略被设置为“节点的属性,分别是default-database-strategy-ref和default-table-strategy-ref;
    [*]默认数据源被设置为“节点的属性,即default-data-source-name;
    [*]“一些属性变更,例如:actual-tables改为actual-data-nodes,database-strategy改为database-strategy-ref;
我们平常开发过程中,可以参考sharding-jdbc源码sharding-jdbc-core-spring-namespace模块中META.rdb目录下的xml,作者对几乎各种使用方式都有实例;
分库逻辑AuthUserDatabaseShardingAlgorithm的代码很简单,源码如下:
/** * @author wangzhenfei9 * @version 1.0.0 * @since 2018年05月14日 */public class AuthUserDatabaseShardingAlgorithm implements PreciseShardingAlgorithm { private final Logger logger = LoggerFactory.getLogger(this.getClass()); private static final int SHARDING_NUMBER = 4; @Override public String doSharding(final Collection availableTargetNames, final PreciseShardingValue shardingValue) { for (String each : availableTargetNames) { if (each.endsWith(shardingValue.getValue() % SHARDING_NUMBER + "")) { logger.debug("the target database name: {}", each); return each; } } throw new UnsupportedOperationException(); }}
这段代码参考sharding-jdbc源码中PreciseShardingAlgorithm.java接口的实现即可,例如PreciseModuloDatabaseShardingAlgorithm.java;这里和sharding-jdbc1.5.4.1版本的差异也比较大,sharding-jdbc1.5.4.1对于分库或者分表sharding算法实现的接口是不一样的,sharding-jdbc2.0.3将两者合二为一,且只有一个方法,即doSharding();
4. 注意事项

无法识别sharding-jdbc分库分表规则inline-expression问题,例如:
“

    [*]根本原因:
    根本原因是spring把${}当做占位符,${0..3}这种表达式,spring会尝试去properties文件中找key为0..3的属性。但是这里是sharding-jdbc分库分表规则的inline表达式,需要spring忽略这种行为。否则会抛出异常:
    java.lang.IllegalArgumentException: Could not resolve placeholder ‘0..3’ in value “sj_ds_${0..3}.auth_user”
    [*]解决办法:
    配置: 或者:
5. Main测试

Main.java用来测试分库分表是否OK,其源码如下:
/** * @author wangzhenfei9 * @version 1.0.0 * @since 2018年05月14日 */public class Main { public static void main(String[] args) { ApplicationContext context = new ClassPathXmlApplicationContext( "/META-INF/spring/spring-*.xml"); // auth_user有进行分库, AuthUserMapper authUserMapper = context.getBean(AuthUserMapper.class); AuthUser authUser = authUserMapper.selectByPrimaryKey(7L); System.out.println("-----> The auth user: "+JSON.toJSONString(authUser)); // user_permission没有分库分表 UserPermissionMapper userPermissionMapper = context.getBean(UserPermissionMapper.class); UserPermission userPermission = userPermissionMapper.selectPermissionByUsername("wangzhenfei", "FINANCE_WALLET"); System.out.println("-----< The user permission: "+JSON.toJSONString(userPermission)); }}
AuthUserMapper.selectByPrimaryKey()和UserPermissionMapper.selectPermissionByUsername()的代码和没有分库分表的代码完全一样;
6&#46; 遗留问题

Main方法测试,或者启动服务后的调用测试都没有问题,但是通过junit测试用例访问就会抛出异常,作为一个待解决的遗留问题:
org.springframework.beans.factory.NoUniqueBeanDefinitionException: No qualifying bean of type 'javax.sql.DataSource' available: expected single matching bean but found 6: sj_ds_0,sj_ds_1,sj_ds_2,sj_ds_3,sj_ds_default,shardingDataSource

本文内容来源文水手机台,如有侵权请立即与我们联系,我们将及时处理!
分享:
游客
要评论请先登录 或者 注册
返回顶部